task_manager.cpp

ACE的通信程序

#include "ace/Message_Block.h"
#include "Server.h"

namespace ACE_Server
{
	int Task_Manager::svc(void)
	{
		Task_Worker task_tp;
		task_tp.activate(THR_NEW_LWP | THR_JOINABLE, TASK_THREAD_POOL_SIZE);

		while(1)
		{
			ACE_Message_Block *mb = NULL;
			if(this->getq(mb) < 0)
			{
				task_tp.msg_queue()->deactivate();
				task_tp.wait();
			}
			task_tp.putq(mb);
		}
		return 0;
	}
}