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

#include "Server.h"

namespace ACE_Server
{
	int Task_Worker::svc(void)
	{
		while(1)
		{
			ACE_Message_Block *mb = NULL;
			if(this->getq(mb) == -1)
			{
				continue;
			}
			process_task(mb);
		}
		return 0;
	}
	void Task_Worker::process_task(ACE_Message_Block *mb)
	{
		//進行數據處理,數據的起始地址為mb->rd_ptr(),長度為mb->length()
		ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%t) Processing task: %s length %d\n"), mb->rd_ptr()+4, mb->length()));	//字符串跳過了四個字節的長度數據
		ACE_OS::sleep(3);  //模擬數據處理過程
		mb->release();
	}
}