Active Object并发模式在Java中的应用 - 编程入门网

Active Object并发模式在Java中的应用(5)

Activation List 的实际上就是一个线程同步机制保护下的 Method Request 队列，对该队列的所有 操作 (insert/remove) 都应该是线程安全的。从本质上讲，Activation List 所基于的就是典型的生产 者 / 消费者并发编程模型，调用者线程作为生产者把 Method Request 放入该队列，Active Object 线 程作为消费者从该队列拿出 Method Request, 并执行。

实现 Scheduler，如清单 5 所示：

清单 5. MQ_Scheduler

class　MQ_Scheduler　{ public: 　　 //　Initialize　the　<Activation_List>　and　make　<MQ_Scheduler> 　　 //　run　in　its　own　thread　of　control. 　　　　　 //　we　call　this　thread　as　Active　Object　thread. 　　 MQ_Scheduler　() 　　 :　act_list_()　{ 　　　　 //　Spawn　separate　thread　to　dispatch　method　requests. 　　　　 //　The　following　call　is　leveraging　the　parallelism　available　on　native 　OS　 　　　　 //　transparently 　　　　 Thread_Manager::instance　()->spawn　(&svc_run,this); 　　 } 　　 //　...　Other　constructors/destructors,　etc. 　　 //　Put　<Method_Request>　into　<Activation_List>.　This 　　 //　method　runs　in　the　thread　of　its　client,i.e. 　　 //　in　the　proxy''s　thread. 　　 void　insert　(Method_Request　*mr)　{ 　　　　 act_list_.insert　(mr); 　　 } 　　 //　Dispatch　the　method　requests　on　their　servant 　　 //　in　its　scheduler''s　thread　of　control. 　　 virtual　void　dispatch　()　{ 　　　　 //　Iterate　continuously　in　a　separate　thread(Active　Object　thread). 　　　　 for　(;;)　{ 　　　　　　 Activation_List::iterator　request; 　　　　　　 //　The　iterator''s　<begin>　method　blocks 　　　　　　 //　when　the　<Activation_List>　is　empty. 　　　　　　 for(request　=　act_list_.begin　();　request　!=　act_list_.end　 ();++request){ 　　　　　　　　 //　Select　a　method　request　whose 　　　　　　　　 //　guard　evaluates　to　true. 　　　　　　　　 if　((*request).can_run　())　{ 　　　　　　　　　　 //　Take　<request>　off　the　list. 　　　　　　　　　　 act_list_.remove　(*request); 　　　　　　　　　　 (*request).call　()　; 　　　　　　　　　　 delete　*request; 　　　　　　　　 } 　　　　　　　　 //　Other　scheduling　activities　can　go　here, 　　　　　　　　 //　e.g.,　to　handle　when　no　<Method_Request>s 　　　　　　　　 //　in　the　<Activation_List>　have　<can_run> 　　　　　　　　 //　methods　that　evaluate　to　true. 　　　　　　 } 　　　　 } 　　 } private: 　　 //　List　of　pending　Method_Requests. 　　 Activation_List　act_list_; 　　 //　Entry　point　into　the　new　thread. 　　 static　void　*svc_run　(void　*arg)　{ 　　　　 MQ_Scheduler　*this_obj　=　　static_cast<MQ_Scheduler　*>　(args); 　　　　 this_obj->dispatch　(); 　　 } };

Active Object并发模式在Java中的应用(6)

凌众科技专业提供服务器租用、服务器托管、企业邮局、虚拟主机等服务，公司网站：http://www.lingzhong.cn 为了给广大客户了解更多的技术信息，本技术文章收集来源于网络,凌众科技尊重文章作者的版权，如果有涉及你的版权有必要删除你的文章，请和我们联系。以上信息与文章正文是不可分割的一部分,如果您要转载本文章,请保留以上信息，谢谢!