ACE多线程编程（1）

2012-06-27

ACE多线程编程（一）使用ACE进行多线程编程的内容相对较多，分多篇总结。本文中主要介绍线程的创建、互斥体和线

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<T>在守卫创建和析构过程中，使用锁类T的acquire()和release()方法。ACE_Read_Guad<T>在构造时调用acquire_read()ACE_Write_Guad<T>在构造时调用acquire_write()ACE_TSS_Guad<T>在堆上分配守卫，，并在线程专有存储中保存它的引用。这样即使线程通过ACE_Thread::exit()显示退出，锁也会被释放。ACE_TSS_Read_Guad<T>线程专有的守卫的读版本ACE_TSS_Write_Guad<T>线程专有的守卫的写版本</p>3.2、守卫宏<p>为了方便的使用守卫类，ACE提供了一组守卫宏。</p><p>无返回值守卫宏：</p>ACE_GUARD(LockType, GuardName, LockObject)ACE_WRITE_GUARD(LockType, GuardName, LockObject)ACE_READ_GUARD(LockType, GuardName, LockObject)<p>带返回值的守卫宏：在出错时返回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<ACE_MT_SYNCH>{    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->getq (mb, &wait_for) != -1)         {               if (mb->msg_type () == ACE_Message_Block::MB_HANGUP)            {                   canceled = true;                mb->release ();                 break;            }               ACE_LOG_MSG->log_hexdump (LM_DEBUG, mb->rd_ptr (), mb->length (), "Message Block received");            mb->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->copy ("Hello", ACE_OS::strlen ("Hello") + 1);     my_task.putq (mb);    ACE_NEW_RETURN (mb, ACE_Message_Block(1024), -1);    mb->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 ();}

热点排行