ASIO协程彻底转变你的思维

qinggeng

yulihua49 发表于 2013-04-16 12:39
这样有什么好处呢？我用多线程+context表示状态，每次线程调用这个context时从相应的状态点运行，也可以进 ...

实际的代码？

yulihua49

qinggeng 发表于 2013-04-16 12:43
实际的代码？

这个，不扣题吧？人家说单线程asio，我说多线程asio。

1. static void *thread_work(void *param)
   
2. {
   
3. resource *rs=(resource *)param;
   
4. int ret,fds;
   
5. TCB *task;//你可以按需要定义你自己的context。
   
6. port_event_t event;
   
7. 
   
8.         rs->tid=pthread_self();
   
9.         while(1) {
   
10. //从就绪队列取一个任务
    
11.                 pthread_mutex_lock(&rpool.mut);
    
12.                 while(!(task=rdy_get())) {         //这部分先不要管
    
13.                         if(rpool.flg >= tpool.rdy_num) break;
    
14.                         rpool.flg++;
    
15.                         ret=pthread_cond_wait(&rpool.cond,&rpool.mut); //没有任务，等待
    
16.                         rpool.flg--;
    
17.                 }
    
18.                 pthread_mutex_unlock(&rpool.mut);
    
19.                 if(!task) {
    
20.                         ret = port_get(g_port_fd, &event, NULL); //每个线程等事件，solaris的port事件管理器，=epoll_wait
    
21.                         if(ret < 0){
    
22.                                 ShowLog(1,"%s:port_get err=%d,%s",__FUNCTION__,errno,strerror(errno));
    
23.                                 sleep(30);
    
24.                                 continue;
    
25.                         }
    
26.                         task = (TCB *)event.portev_user;//拿到context
    
27.                         task->events=event.portev_events;
    
28. //检查事件是否健康
    
29.                         if(!task->call_back && !(event.portev_events&POLLIN)) {
    
30.                                 client_del(task);
    
31.                                 continue;
    
32.                         }
    
33.                 }
    
34. //              rs->timestamp=
    
35.                 task->timestamp=now_usec();
    
36.                 ret=do_work(task);//处理你的context。记住，处理完毕要把你的fd重新加入g_port_fd。好进行下一阶段的工作。
    
37.         }
    
38.         ShowLog(1,"%s:tid=%lu canceled",__FUNCTION__,pthread_self());
    
39.         mthr_showid_del(rs->tid);
    
40.         rs->timestamp=now_usec();
    
41.         rs->status=0;
    
42.         rs->tid=0;
    
43.         return NULL;
    
44. }
    
45. 
    

复制代码

上述代码实现了彻底异步的TCP代理服务器。
当然那个代理的代码量比较大，但是多线程异步处理就在这了。

windoze

我这儿也有个多线程+asio+corotine的，包装了下iostream，代码看起来顺眼多了

https://github.com/windoze/coroserver

蔡万钊

回复 9# qinggeng


    恩，是的

蔡万钊

回复 5# yulihua49


    简单的使用多个线程跑 boost::asio::io_servier::run 即可。

蔡万钊

yulihua49 发表于 2013-04-16 16:22
这个，不扣题吧？人家说单线程asio，我说多线程asio。上述代码实现了彻底异步的TCP代理服务器。
当然那个 ...

这个代码又臭又长，充满了指针。

蔡万钊

把代码的说明加上了

yulihua49

蔡万钊 发表于 2013-04-16 17:35
这个代码又臭又长，充满了指针。

长吗？才44行，这个长度都读不下去？以致臭汗淋漓？
指针，是C优于其他任何语言的利器。我们靠他提高效率。
epoll怎么提高的性能？event指针，usrdata指针。。。。立即获取，无需从数组中查找。。。。
再说，你的，不也是到处指针（m_request->。。。），使用C/C++，谁又能逃脱指针呢？
因为这是个实际的东西，作为原理，你把10-18行忽略，令task=NULL，进入等待事件的流程。在去掉关于错误处理和日志的部分，功能实体没有几行。

言归正传。
do_work()包含了一个异步结束后和新的异步开始前的所有操作，在新的异步开始前，设置状态，把fd装入事件，返回。
在do_work()里按照context的状态处理每个阶段的动作，算是所谓“协程”吗？
这个逻辑是清晰的，以至于无需调试，大家按规则办，流程就顺畅。
如果线程池只有一个线程，是否与你的东东差不多了？
当然我至少需要2个线程，一个守候非IO事件（就是10-18行的内容），一个守候IO事件。

仅仅交流交流，没有否定你的意思。

易风云

我想请教楼主，您做过dns干扰吗，能不能指点一下

yulihua49

蔡万钊 发表于 2013-04-16 17:33
回复 5# yulihua49

“那么，这个问题就复杂化了， “avbot 收到消息后，遍历这个列队执行消息发送” 这个做法，不可避免的带来了阻塞。好吧，异步遍历吧。

要是异步遍历还没遍历完，又来一个消息呢？ 考虑这个问题，你会发疯的。因为异步，太多的细节需要考虑了。真的。”

这个交给epoll处理。


“好吧，又有个好主意了，为每个客户端建立一个列队，每次遍历就是把要发送的消息挂入列队即可。这样也不需要异步遍历了，同步就可以。解决了异步遍历的时候又来一个消息导致的痛苦的调度。

然后细分，考虑每个客户端，就是等待 “发送列队” 不为空！等等，一直这么等待也不行，如果客户断开了链接呢？ 所以要 “同时等待发送列队不为空&&客户正常在线，并且已经发送了 HTTP 请求头部””


这个就由context，或称为session来解决。



----- 我的办法