怎样安全的退出Task中创建的各个线程？

peakzhang

Task中的线程都在getq处阻塞了，我怎样安全的退出他们？之前好像在什么地方看到过有，说是发一个什么消息，但有找不到了，所以再问一下。哪位知道的帮忙顶一下。

peakzhang

看看是不是这个

virtual int ACE_Message_Queue<>::deactivate  ( void    )  [virtual]

Deactivate the queue and wakeup all threads waiting on the queue so they can continue. No messages are removed from the queue, however. Any other operations called until the queue is activated again will immediately return -1 with <errno> == ESHUTDOWN. Returns WAS_INACTIVE if queue was inactive before the call and WAS_ACTIVE if queue was active before the call.

peakzhang

可以通过ACE_Message_Block::MB_STOP
  

1. ACE_Message_Block* lastMsg = new ACE_Message_Block(0, ACE_Message_Block::MB_STOP)
2.   otherTask->putq(lastMsg);
4.   otherTask在接收到的时候如下处理
6.    int OtherTask::svc()
7.    {
8.           ACE_Message_Block* mb;
9.            while(1)
10.            {
11.              getq(mb);
12.             if(mb->get_tpye() == ACE_Message_Block::MB_STOP)
13.            {
14.               mb->release();
15.               break; //退出这个永久限环)
16.            }
17.            else
18.            {
19.               handle_message(mb); //处理这条消息
20.            }
21.    return 0;
22.          
23.     }

复制代码

thisisatest

用test_cancel函数