关于ACE_TP_Reactor

发布时间：2020-12-15 05:03:23 所属栏目：百科来源：网络整理

导读：前段时间用了ACE_TP_Reactor做了一个东西，但是对这块东西不是很有底，所以借着假期仔细的看了一下这一块的东西，又上网查了一下相关的资料。在Addison-Wesley - C++NetworkProgrammingVol2的4.3 The ACE_TP_Reactor Class中有这样几句话，让我足足想了一天

前段时间用了ACE_TP_Reactor做了一个东西，但是对这块东西不是很有底，所以借着假期仔细的看了一下这一块的东西，又上网查了一下相关的资料。

在Addison-Wesley - C++NetworkProgrammingVol2的4.3 The ACE_TP_Reactor Class中有这样几句话，让我足足想了一天。

1.Multiple threads running an ACE_TP_Reactor event loop can process events concurrently on different handles
2.They can also dispatch timeout and I/O callback methods concurrently on the same event handler
3.The only serialization in the ACE_TP_Reactor occurs when I/O events occur concurrently on the same handle
4.After a thread obtains a set of active handles from select(),the other reactor threads dispatch from that handle set instead of calling select() again

其实上面的3句话主要表达这样的几层含义
1.并行处理不同handle上的事件
2.并行处理同一event handler上的超时回调函数和I/O回调函数
3.多个线程串行处理同一个handle上的I/O事件。
4.虽然TP_Reactor是用leader/follow模式轮流调用select,但是如果一个select()获得了多个激活的handle,那么其他的线程会分发这些handle ，而不是去再次调用select.
(这点还没有想通，也没有看见是如何实现的？)

“多个线程串行处理同一个handle上的I/O事件”
这个是如何达到的呢？ACE源码中，当处理I/O事件的时候，会将 HANDLE挂起，使得不再对该 HANDLE做事件侦听。来达到同一个 handle上的I/O事件是被多个线程串行地处理。

"并行处理同一event handler上的超时回掉函数和I/O回调函数"
这样好像就比较麻烦了。因为这就意味着TP_Reactor只保证同一个handle下不会有多线程同时调用I/O事件，但是却有可能同时调用超时回调函数和I/O回调函数。如果在这两个函数中有对数据的访问和操作，这就意味着需要有锁的引入。例外，如果在定时器处理中，超过定时的事件间隔，就会有令一个线程再次调用定时器的处理函数，一下子引入了很多同步的问题。如何解决这个问题呢？

方法一：

更改ACE的源码，象处理socket事件一样，在处理定时事件的时候，也把HANDLE挂起。来自http://cpunion.cnblogs.com/archive/2005/08/09/210941.html

int
ACE_TP_Reactor::handle_timer_events(&/*event_count*/,
ACE_TP_Token_Guardguard)
{
//Getthecurrenttime
ACE_Time_Valuecur_time(this->timer_queue_gettimeofday()+timer_skew());

Lookforanodeinthetimerqueuewhosetimer<=thepresent
time.ACE_Timer_Node_Dispatch_Infoinfo;

if(dispatch_info(cur_time,
info))
{
********fixedbylijie***********(info.type_get_handle()!=ACE_INVALID_HANDLE)
{
is_suspended_i(info.type_get_handle()))
return0;

suspend_handler(info.type_get_handle());
}
********end**********************constvoid*upcall_act=Preinvoke.preinvoke(info,
cur_time,
upcall_act);

Releasethetokenbeforedispatchingnotifiesguard.release_token();

callthefunctorupcall(info,
cur_time);

Postinvokepostinvoke(info,
upcall_act);

Wehavedispatchedatimer1;
}

;
}

handle_timer处理完以后，返回以前，加上这句话
this->reactor ()->resume_handler (this->get_handle ());

当然别忘了为Handler编写get_handle()函数：

ACE_HANDLETest_Handler::get_handle()
{
peer().get_handle();
}

方法二：
利用ACE_Pipe和ACE_Message_Queue把所有的事件都排队到同一个I/O HANDLE上去，再由ACE_TP_Reactor通过多个线程顺序串行地触发我们旧的event_handler来处理这些已经排好队的事件/消息。我比较赞成用这样方法。该方法来自：http://blog.csdn.net/zhdaniel/archive/2006/06/29/850888.aspx

方法三： ^_^干脆就不要对同一个event handler注册I/O事件和其他事件。

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!