ACE多线程编程（1）

ACE多线程编程（一）

使用ACE进行多线程编程的内容相对较多，分多篇总结。

本文中主要介绍线程的创建、互斥体和线程间通信。

1、线程的创建

使用ACE进行多线程编程比较简单，只需：

从ACE_Task_Base创建子类；重新实现svc()虚方法，这个函数是新线程的进入点。新线程从svc函数开始执行，函数返回，则新线程也结束；调用ACE_Task_Base::activate()方法启动新线程；调用ACE_Task_Base::wait()方法等待新线程结束。调用wait方法的父线程将阻塞，一直等待所有子线程结束。

注：如果父线程没有等待子线程，而是提前退出，则子线程也将被迫终止。

2、互斥体

ACE提供了一系列的互斥体，互斥体提供了简单的acquire()和release()接口。在多线程的互斥保护中，我们可以使用ACE_Thread_Mutex互斥体。

举一个简单的例子，多个线程使用同一个socket发送数据，为了防止交叉写，我们需要使用互斥体，示例代码如下：

<caption>ACE 守卫类</caption><th scope="col">守卫</th><th scope="col">描述</th>ACE_Guad&lt;T&gt;在守卫创建和析构过程中，使用锁类T的acquire()和release()方法。ACE_Read_Guad&lt;T&gt;在构造时调用acquire_read()ACE_Write_Guad&lt;T&gt;在构造时调用acquire_write()ACE_TSS_Guad&lt;T&gt;在堆上分配守卫，，并在线程专有存储中保存它的引用。这样即使线程通过ACE_Thread::exit()显示退出，锁也会被释放。ACE_TSS_Read_Guad&lt;T&gt;线程专有的守卫的读版本ACE_TSS_Write_Guad&lt;T&gt;线程专有的守卫的写版本</p>3.2、守卫宏<p>为了方便的使用守卫类，ACE提供了一组守卫宏。</p><p>无返回&#20540;守卫宏：</p>ACE_GUARD(LockType, GuardName, LockObject)ACE_WRITE_GUARD(LockType, GuardName, LockObject)ACE_READ_GUARD(LockType, GuardName, LockObject)<p>带返回&#20540;的守卫宏：在出错时返回ReturnValue</p>ACE_GUARD_RETURN (LockType, GuardName, LockObject, ReturnValue)ACE_WRITE_GUARD_RETURN (LockType, GuardName, LockObject, ReturnValue)ACE_READ_GUARD_RETURN (LockType, GuardName, LockObject, ReturnValue)<p></p><p>守卫宏使用方法如下：</p><p></p><textarea readonly name="code" class="cpp">#include "ace/Task.h"class MyTask : public ACE_Task&lt;ACE_MT_SYNCH&gt;{    public:        int svc ();     private:        bool canceled;};int MyTask::svc (){    ACE_Message_Block *mb;    ACE_Time_Value wait_for;    while (!canceled) {        wait_for = ACE_OS::gettimeofday ();         wait_for += 2;        while (this-&gt;getq (mb, &wait_for) != -1)         {               if (mb-&gt;msg_type () == ACE_Message_Block::MB_HANGUP)            {                   canceled = true;                mb-&gt;release ();                 break;            }               ACE_LOG_MSG-&gt;log_hexdump (LM_DEBUG, mb-&gt;rd_ptr (), mb-&gt;length (), "Message Block received");            mb-&gt;release ();         }       }       return 0;}int ACE_TMAIN (int argc, ACE_TCHAR *argv[]){    MyTask my_task;    my_task.activate ();     ACE_Message_Block *mb;    ACE_NEW_RETURN (mb, ACE_Message_Block(1024), -1);    mb-&gt;copy ("Hello", ACE_OS::strlen ("Hello") + 1);     my_task.putq (mb);    ACE_NEW_RETURN (mb, ACE_Message_Block(1024), -1);    mb-&gt;copy (" World", ACE_OS::strlen (" World") + 1);    my_task.putq (mb);    ACE_NEW_RETURN (mb, ACE_Message_Block(0, ACE_Message_Block::MB_HANGUP), -1);    my_task.putq (mb);    my_task.wait ();}

ACE多线程编程（1）

热点推荐