`
pleasetojava
  • 浏览: 730484 次
  • 性别: Icon_minigender_2
  • 来自: 上海
文章分类
社区版块
存档分类
最新评论

关于ACE_Task::last_thread()

阅读更多

关于ACE_Task::last_thread()

在ACE应用中,我们经常用ACE_Task类实现多线程处理。由于ACE_Svc_Handler从ACE_Task派生,当你写的应用程序使用了Acceptor-Connector框架同时又直接使用ACE_Task,如线程池,这时你会使用到ACE_Task。
因为许多ACE_Task对应是动态分配的,所以,必须在不再需要时把它们正确地释放掉,知道何时可以释放对象,这一点非常重要。C++NPv2第189页描述了当多线程涉及到的task对象在它们退出时,使用ACE_Task::thr_count()方法确定正确释放它们的方法。

在C++NPv2文档中描述的过程并不不安全,这里有一个用例可以说明这一点。原因如下:

ACE在调用ACE_Task::close()挂钩(hook)函数前检查线程计数。

线程锁(task thread)使控制线程计数顺序化,所以不能通过调用ACE_Task::close()达到控制线程数这一目的,这是因为关闭挂勾(close hook)方法会删除task 对象。因此,多个线程检查ACE_Task:: thr_count()的值都为0是可能存在的。

举例来说吧,我们假设这里有两个线程,A和B,这给都要退出。线程A从svc()方法中退出控制,同时,ACE开始线程记录保护(record-keeping)。ACE获得线程锁并把活动线程数从2减为1,接着,ACE释放线程锁并调用task的close()挂钩方法。其间,线程B也从svc()方法中退出。在线程A检查ACE_Task::thr_count()之前,ACE已执行线程B的清楚操作可能导致task的线程计数器从1变为0.如果那样,线程A和B都会看到线程计数器为0,并都试图清理task对象。这一点肯定不是好事.......

发现并指出这一问题是一位长时间使用ACE的用户,Howard Finer,经过一些迭代和试验Howard找到一个解决这一问题的办法,即额外的维护线程计数器,记住到底是哪一个线程真实的把线程计数器从1变为0,(上述例子中的线程B)。这就要求ACE_Task增加一个新的方法 :
ACE_thread_t ACE_Task::last_thread (void) const
所以,在你的代码实现ACE_Task::close()时需要包含如下的检查

if (ACE_OS::thr_equal (ACE_Thread::self (),
this->last_thread ()))
{
// Do the cleanup here...
}


这个方法可能会出现在ACE 5.5.2中。

分享到:
评论

相关推荐

    ACE_OS::mktime函数源代码

    static __time64_t __cdecl _make__time64_t ( struct tm *tb, int ultflag ) { __time64_t tmptm1, tmptm2, tmptm3; struct tm tbtemp; long dstbias = 0;... long timezone = 0;...= NULL ), EINVAL, ( ( __time64...

    analysis of ACE_Task-putq with timeout=0 when queue is full on Linux platform.pdf

    ### 分析ACE_Task::putq在队列满且timeout为0的情况 #### 0. 引言 在本文中,我们将深入探讨调用`ACE_Task::putq`函数时的各种行为,尤其是当队列满且`timeout`参数设为0的情况。我们将分析涉及的多个层面,包括...

    ACE_OS命名空间函数参考文档

    - `ACE_OS::last_error()`: 获取最近发生的错误代码。 - `ACE_OS::strerror()`: 将错误代码转换为错误消息字符串。 9. **网络通信** - `ACE_OS::inet_addr()`: 将IP地址字符串转换为二进制表示。 - `ACE_OS::...

    ACE_Thread.txt ACE_Thread.txt ACE_Thread.txt ACE_Thread.txt ACE_Thread.txt ACE_Thread.txt

    if (ACE_OS::thr_equal(ACE_Thread::self(), this->last_thread())) { // 清理资源 delete this; } return 0; } virtual int svc(void) { return 0; } }; ``` - `open()`方法:在此方法中通过`activate()`...

    ACE框架知识

    - **ACE::strdelete(char*)**: 删除动态分配的字符串空间。 #### 四、总结 ACE框架通过提供丰富的API支持,使得开发者能够方便地实现高性能的服务端应用程序。无论是基于事件驱动的I/O操作,还是定时器管理和信号...

    ACE_server.rar_ACE server_ACE tcp_ACE_SERVER_ACE框架_ace server cl

    4. `ACE_Thread_Manager`:用于管理线程,确保资源的正确释放。 客户端可能包含以下组件: 1. `ACE_SOCK_Connector`:尝试连接到服务器的指定端口。 2. `ACE_Svc_Handler`:与服务器端类似,处理客户端的I/O事件和...

    利用ace的ACE_Task等类实现线程池的方法详解

    在提供的代码片段中,`Thread_Pool`类继承自`ACE_Task<ACE_MT_SYNCH>`,其中`ACE_MT_SYNCH`是一个模板参数,表示使用多线程(Multithreaded)和同步(Synchronized)策略。`Thread_Pool`类添加了一些额外的功能,如...

    日志系统之ACE日志服务[文].pdf

    ACE日志服务提供了多种日志输出宏,例如ACE_DEBUG、ACE_INFO、ACE_WARNING、ACE_ERROR等,用于输出不同级别的日志信息。这些宏可以根据需要进行定义和使用,例如: ACE_DEBUG((LM_DEBUG, "This is a debug message...

    ACE_MFC.rar_ACE_ACE_MFC

    ACE(Adaptive Communication Environment)是一个跨平台的网络通信框架,由Douglas C. Schmidt领导的团队在1995年开发。它提供了大量的C++模板类和函数,以支持高效、可靠的分布式系统开发。ACE_MFC是ACE框架的一个...

    ACE入门 编译 配置 中文版

    ACE_Task用于定义任务的执行;ACE_Pipes和Filters组件用于创建可插拔和可重用的通信管道。ACE还提供了ACE_Thread类,用于管理线程的生命周期,包括创建、设置优先级、挂起、恢复、取消、同步、等待等。 ACE中的线程...

    ACE.rar_ACE 网络 编程_visual c

    这个RAR压缩包中的资源,"ACE.chm",是一部关于ACE网络编程的开发说明文档,特别适合初学者入门学习。通过这份文档,你可以深入理解ACE的核心概念和技术,并学会如何在Visual C++环境下进行实际的网络编程。 一、...

    ACE的进程管理

    ACE(Adaptive Communication Environment,自适应通信环境)是AT&T实验室开发的一个跨平台的C++软件框架,它提供了丰富的网络编程接口,包括进程管理、线程管理、并发控制、I/O复用等。在ACE中,对进程的管理主要...

    ace_reactor:王牌React堆服务器

    Ace Reactor是一个基于Ace库开发的高性能网络反应堆,它被设计用于构建高效、可扩展的网络服务。Ace是AT&T实验室开发的一个跨平台、事件驱动的C++网络编程框架,而Ace Reactor是其核心组件,用于处理异步事件和网络I...

    ACE_SOCK_TCP.rar_ACE_ACE TCP C++_ACE tcp_ace-6

    例如,ACE_SOCK_Stream的get_last_error()方法可以帮助我们获取错误信息,而ACE_Transport_Cache则可以管理连接状态,自动重连或关闭无效连接。 在“ACE_SOCK_TCP.rar”压缩包中的示例代码“ACE_SOCK_TCP”,可能...

    ACE并发编程示例及Task类的实现

    在《ACE并发编程.docx》文档中,你可以找到关于如何创建和使用ACE_Task的详细步骤,包括初始化、消息处理、线程管理和销毁等过程。《ACE_Task类讲解.docx》则可能进一步深入到类的成员函数、接口以及实际应用示例,...

    ACE入门教程

    ACE_thread_t threadId; ACE_hthread_t threadHandle; ACE_Thread::spawn( (ACE_THR_FUNC)worker, // 线程执行函数 NULL, // 执行函数参数 THR_JOINABLE | THR_NEW_LWP, &threadId, &threadHandle ); ``` ...

    ACE多级线程实例

    ACE框架提供了一个强大的任务类`ACE_Task`,用于创建和管理线程。该类是所有ACE线程类的基础,继承自`ACE_Task_Base`类。一个典型的ACE线程实例包括以下步骤: 1. **定义一个派生自`ACE_Task_Base`的类**:例如`HA_...

    ACE继承层次图

    - **ACE_Task_Base**:是所有任务类的基础,提供了基本的任务控制接口。 3. **ACE_Shared_Memory_Pool**:管理共享内存池,用于进程间或线程间的共享数据交换。 - **ACE_Lite_MMAP_Memory_Pool**:轻量级的内存池...

    bootstrap ace模版1.4:ace_v1.4_2016.3.28.zip

    Bootstrap Ace模版1.4是基于流行的前端框架Bootstrap构建的一款高效、美观的后台管理模版。这个版本,标记为"ace_v1.4_2016.3.28.zip",包含了2016年3月28日更新的全部内容,旨在提供丰富的界面元素和组件,方便...

    ACE编写的简单网络服务器

    ACE(Adaptive Communication Environment)是一个跨平台的C++库,专为分布式系统和网络编程设计。这个库提供了许多高级服务,如并发处理、线程管理、网络通信、定时器、I/O复用等,使开发者能够高效地构建复杂的、...

Global site tag (gtag.js) - Google Analytics