#include <string>
#include <msg/msg.h>
#include "synchro.h"
+#include "sync_queue.h"
class message {
public:
message_type get_type() const { return type; }
double get_amount() const { return amount; }
+ double get_size() const;
std::string to_string();
private:
mutex_t mutex;
condition_t cond;
- std::queue<m_task_t> queue;
+ sync_queue<m_task_t> queue;
};
#endif // !MESSAGES_H