acl/lib_acl_cpp/include/acl_cpp/stdlib/mbox.hpp

#pragma once
#include "acl_cpp/acl_cpp_define.hpp"
#include "acl_cpp/stdlib/noncopyable.hpp"

struct ACL_MBOX;

namespace acl
{

class ACL_CPP_API mobj
{
public:
	mobj(void) {}
	virtual ~mobj(void) {}
};

class ACL_CPP_API mbox : public noncopyable
{
public:
	mbox(void);
	~mbox(void);

	/**
	 * 发送消息对象
	 * @param o {mobj*} 非空消息对象
	 * @return {bool} 发送是否成功
	 */
	bool push(mobj* o);

	/**
	 * 接收消息对象
	 * @param timeout {int} 大于 0 时设置读等待超时时间(秒)，否则永远等待
	 *  直到读到消息对象或出错
	 * @param success {bool*} 可以用于辅助确定读操作是否成功
	 * @return {mobj*} 非 NULL 表示读到一个消息对象，为 NULL 时，还需通过
	 *  success 参数的返回值检查操作是否成功
	 */
	mobj* pop(int timeout = 0, bool* success = NULL);

	/**
	 * 统计当前已经发送的消息数
	 * @return {size_t}
	 */
	size_t push_count(void) const;

	/**
	 * 统计当前已经接收到的消息数
	 * @return {size_t}
	 */
	size_t pop_count(void) const;

private:
	ACL_MBOX* mbox_;
};

} // namespace acl