为何队列中只能取出2条消息呢，其他消息都搞不出来
1.main.cpp#include "Header.h"
class HA_CommandHandler:public ACE_Task<ACE_MT_SYNCH>
{
public:
HA_CommandHandler(const char * name) : name_(name){
}
virtual int svc(void)
{
ACE_DEBUG((LM_DEBUG,ACE_TEXT("%t starting up %C%D\n"),name_));
ACE_OS::sleep(3);
ACE_Message_Block *mb = 0;
while (this->getq(mb) > 0){
process_message();
}
return 0;
}
void process_message()
{
ACE_DEBUG((LM_DEBUG,ACE_TEXT("(%t) processing message %C%D\n"),name_));
}
private:
const char * name_;
};
int ACE_TMAIN(int, ACE_TCHAR *[])
{
HA_CommandHandler lp_handler("low");
lp_handler.activate();
ACE_DEBUG((LM_DEBUG,ACE_TEXT("start hp_handler succeed. %D\n")));
ACE_Message_Block mb;
for (int i = 0 ; i < 10 ; i ++)
{
lp_handler.putq(&mb);
}
ACE_DEBUG((LM_DEBUG,ACE_TEXT("putq succeed. %D\n")));
lp_handler.wait();
return 0;
}
2. Header.h
#ifndef HEADER_H
#define HEADER_H
/// ace include
#include <ace/ACE.h>
#include <ace/OS.h>
#include <ace/Log_Msg.h>
#include <ace/SOCK_Dgram.h>
#include <ace/Reactor.h>
#include <ace/Svc_Handler.h>
#include <ace/Synch.h>
#include <ace/SOCK_Acceptor.h>
#include <ace/SOCK_Connector.h>
#include <ace/Signal.h>
#include <ace/Version.h>
#include <ace/Synch.h>
#include <ace/Event.h>
#include <ace/Acceptor.h>
#include <ace/Connector.h>
#include <ace/Process.h>
#include <ace/High_Res_Timer.h>
#include <ace/FILE_IO.h>
#include <ace/FILE_Addr.h>
#include <ace/FILE_Connector.h>
#include <ace/DEV_IO.h>
#include <ace/DEV_Addr.h>
#include <ace/DEV_Connector.h>
#include <ace/TTY_IO.h>
#include <ace/Time_Value.h>
#include <ace/Timer_Heap_T.h>
#include <ace/Timer_Queue_Adapters.h>
#include <ace/SOCK_Dgram_Bcast.h>
#include <ace/SOCK_Dgram_Mcast.h>
#include "ace/System_Time.h"
#include "ace/os_include/os_pthread.h"
/// stl include
#include <exception>
#include <string>
#include <vector>
#include <queue>
#include <set>
#include <map>
#include <fstream>
#include <sstream>
#include <iomanip>
#include <iostream>
#endif // HEADER_H
哪位大侠帮看看，为什么不论我扔进去多少条消息，最多只能取出两条呢，然后getq就不返回了,一直阻塞在那里。 ACE_Message_Block mb;
局部变量？ 对task的理解和使用有点错误。
参考一下ACE的实例代码。
页:
[1]