tbox新增stackless协程支持

waruqi

回复 8# yulihua49
我不会去用lockless机制构建生产者/消费者模型
而是通过channel或者协程lock，或者协程版本的信号量来处理，得不到资源，这个协程会被挂起，除非unlock（内部会resume协程），否者这个协程永远不会被调度到
我内部实现协程的 suspend/resume和yield是有区别的，等待lock的suspend模式，会把这个协程从调度链里面移除掉，不再被调度，除非unlock(resume)，所以不存在cpu问题

而yield是让出当前协程，但是之后还是会被调度到，跟suspend还是有区别的，因此我在实现协程锁的时候，内部并没有用yield，而是直接suspend了。

sditmaner

楼主加油，我们都看好你哦

yulihua49

waruqi 发表于 2016-12-20 11:25
而且我并没说必须要使用stackless协程，我的库里面stackfull和stackless都实现了，根据自己的实际需求，可 ...

这个多线程就好，何必协程？
sleep和挂起锁倒是可以考虑采用协程。
可以考虑实现：
coroutine_mutex_lock
coroutine_mutex_unlock
coroutine_cond_wait
coroutine_cond_signal
coroutine_sleep

waruqi

回复 13# yulihua49

多线程同步还得加lock同步，我还是比较喜欢用协程简单写写就好了，一个线程就搞定了，没必要去浪费线程资源。。
下面的那些接口，我都有实现。。

wlmqgzm

不错，支持，加油

yulihua49

waruqi 发表于 2016-12-07 22:46
tbox之前提供的stackfull协程库，虽然切换效率已经非常高了，但是由于每个协程都需要维护一个独立的堆栈，  ...

tbox跟tboox是一回事吗？

zylthinking

yulihua49 发表于 2016-12-09 10:36
以前跟猫讨论过这个问题。stackless对使用的限制不是一般的大，你的应用不可能不使用第三方软件。人家如何 ...

你这个是怎么一个用法啊

corotine(char* addr) {
   int ip = addr;
    char buf[];
    while(1) {
        int n = readfrom(*buf, ip);
        char c = buf[9];
        int n2 = readfrom(ip);

        write(buf, ip);
    }
}

比如这样的协程, 切换发生在 readfrom 和 write 内部; 你如何做到 只给活动协程分配栈 的同时还能保存 ip, n, n2, buf  这些数据?
注意它还是个 while(1);  意思是 ip, buf 应该始终可访问;
你的是类似任务池似得吧, 本质是将缓冲, 各种寄存器保存到任务上, 处理这个任务的协程从任务本身加载寄存器,
类似这种:

thread(char* addr) {
    while(1) {
         fd = epoll_wait();        
         if (null == (task = task_get(fd))) {
            task = new task();
            task.ip = proc;
            task.sp = malloc();
            bind_task_to(fd, task);
            corutine_add_run_list(task);
         } else {
            corutine_resume(task);
        }
    }
}

one theead in corotine threads pool()
{
    while(1) {
        mysp = sp;
        myip = ip;

        select one task from runlist;
        load register from task
        jmp to task.ip
    }
}


proc(task) {        
        char buf[];

        int n = readfrom(*buf, ip); // yield when not ready
        char c = buf[9];
        write(c, ip);  // yield when not ready

        bind_task_to(fd, null);        
        free(task);
        add_to_epoll_noblock(fd);
        sp = mysp;
        jmp myip;
}

但这个其实并没有简化编程;  
如果硬要给他一个意义,
只能假设这里 task 是一个动作, 而是为了达到这个动作需要进行多次协议交换, 因此相关协议在一个函数内顺序处理, 比普通 epoll 所有协议平坦处理看上去要容易理解;
但这个 task 也不能有一个 session 级别的生命期; 否则, 就是每个连接一个 task, 每个  task 一个私有栈,  那也就是标准的 taskfull, 也就达不到所谓节省内存的目的了

如果 task 只代表一个协议呢, 那其实和不用协程的带任务队列的 epoll 没区别,  至少, 不用花多大力气, 就能做到同样效果

yulihua49

zylthinking 发表于 2017-01-23 16:18
你这个是怎么一个用法啊

corotine(char* addr) {

在epoll_wait（）之后为task分配栈，之后由makecontext()配置工作函数入口，由swapcontext转移到工作函数。所有的收发都在工作函数里。
实际的过程比说的复杂的多，当然是不省事，而且调试极为困难，搞了好几个月。但是这部分是框架，只弄一次，以后你所有的do_work()都会非常省事。

1. static void *thread_work(void *param)
   
2. {
   
3. resource *rs=(resource *)param;
   
4. int ret,fds;
   
5. TCB *task=NULL;
   
6. struct epoll_event event;
   
7. 
   
8.         ShowLog(2,"%s:thread %lx start!",__FUNCTION__,pthread_self());
   
9.         getcontext(&rs->tc);
   
10.         if(task)  pthread_mutex_unlock(&task->lock);
    
11. 
    
12.         while(1) {
    
13. //从就绪队列取一个任务
    
14.                 pthread_mutex_lock(&rpool.mut);
    
15.                 while(!(task=rdy_get())) {
    
16.                         if(rpool.flg >= tpool.rdy_num) break;
    
17.                         rpool.flg++;
    
18.                         ret=pthread_cond_wait(&rpool.cond,&rpool.mut); //没有任务，等待
    
19.                         rpool.flg--;
    
20.                 }
    
21.                 pthread_mutex_unlock(&rpool.mut);
    
22.                 if(task) {
    
23.                         if(!task->AIO_flg && !task->call_back) {
    
24.                                 task->fd=task->conn.Socket;
    
25.                                 ShowLog(5,"%s:tid=%lx,TCB_no=%d from rdy_queue",__FUNCTION__,
    
26.                                         pthread_self(),task->sv.TCB_no);
    
27.                                 if(task->fd>=0) {
    
28.                                         do_epoll(task,0,0);
    
29.                                 }
    
30.                                 continue;
    
31.                         }
    
32.                 } else  {
    
33.                         fds = epoll_wait(g_epoll_fd, &event, 1 , -1);
    
34.                         if(fds < 0){
    
35.                                         ShowLog(1,"%s:epoll_wait err=%d,%s",__FUNCTION__,errno,strerror(errno));
    
36.                                 usleep(30000000);
    
37.                                 continue;
    
38.                                 }
    
39.                          task = (TCB *)event.data.ptr;
    
40.                         if(task->events) {
    
41.                             ShowLog(1,"%s:tid=%lx,TCB_no=%d,task->events=%08X,conflict!",__FUNCTION__,
    
42.                                     pthread_self(),task->sv.TCB_no,task->events);//发现惊群
    
43.                             task=NULL;
    
44.                             continue;//丢掉它
    
45.                         }
    
46.                         task->events=event.events;
    
47.                 }
    
48.                 rs->timestamp=now_usec();
    
49.                 if(task->status>0) set_showid(task->ctx);//Showid 应该在会话上下文结构里
    
50.                
    
51.                 if(task->AIO_flg) {//fiber task
    
52.                     task->uc.uc_link=&rs->tc;
    
53.                     rs->tc.uc_link=(ucontext_t *)task;
    
54. ShowLog(5,"%s:tid=%lx,resume to TCB_no=%d",__FUNCTION__,pthread_self(),task->sv.TCB_no);
    
55.                         pthread_mutex_lock(&task->lock);//防止其他线程提前闯入
    
56.                         setcontext(&task->uc);        //== longjmp()
    
57.                         continue;//no action,logic only
    
58.                 }
    
59.                 if(task->uc.uc_stack.ss_size>0) {//call_back模式，抢入了，进入同步模式
    
60.             rs->tc.uc_link=NULL;
    
61. ShowLog(5,"%s:tid %lx 抢入 SYNC",__FUNCTION__,pthread_self());
    
62.                         do_work(task->sv.TCB_no);
    
63.                         continue;
    
64.                 }
    
65.                 if(!rs->tc.uc_stack.ss_sp) {
    
66. ShowLog(5,"%s:%lx create fiber for TCB_no=%d",__FUNCTION__,rs->tid,task->sv.TCB_no);
    
67.                         task->uc.uc_stack.ss_sp=mmap(0, use_stack_size,
    
68.                                 PROT_READ | PROT_WRITE | PROT_EXEC,
    
69.                                 MAP_PRIVATE | MAP_ANON | MAP_GROWSDOWN, -1, 0);
    
70.                         if(task->uc.uc_stack.ss_sp==MAP_FAILED) {
    
71.                                 task->uc.uc_stack.ss_sp=NULL;
    
72.                                 do_work(task->sv.TCB_no); //进行你的服务,不使用AIO
    
73.                                 continue;
    
74.                         }
    
75.                 } else {
    
76. //ShowLog(5,"%s:%lx reuse fiber for TCB_no=%d",__FUNCTION__,rs->tid,task->sv.TCB_no);
    
77.                         task->uc.uc_stack.ss_sp=rs->tc.uc_stack.ss_sp;
    
78.                         rs->tc.uc_stack.ss_sp=NULL;
    
79.                         rs->tc.uc_stack.ss_size=0;
    
80.                 }
    
81.                 task->uc.uc_stack.ss_size=use_stack_size;
    
82.                 task->uc.uc_link=&rs->tc;
    
83.                 rs->tc.uc_link=(ucontext_t *)task;
    
84.                 makecontext(&task->uc,(void (*)())do_work,1,task->sv.TCB_no);
    
85. 
    
86.                 ret=swapcontext(&rs->tc,&task->uc);
    
87.                 if(ret<0) {
    
88.                         ShowLog(1,"%s:swapcontext fault TCB_NO=%d,tid=%lx,errno=%d,%s",
    
89.                                 __FUNCTION__,task->sv.TCB_no,pthread_self(),ret,strerror(abs(ret)));
    
90.                         rs->tc.uc_link=NULL;
    
91.                         task->uc.uc_link=NULL;
    
92.                         if(task->uc.uc_stack.ss_sp)
    
93.                                 munmap(task->uc.uc_stack.ss_sp,task->uc.uc_stack.ss_size);
    
94.                         task->uc.uc_stack.ss_sp=NULL;
    
95.                         task->uc.uc_stack.ss_size=0;
    
96.                         do_work(task->sv.TCB_no);
    
97.                         mthr_showid_del(rs->tid);
    
98.                         continue;
    
99.                 }
    
100.                 if(!task) {
     
101.                         ShowLog(1,"%s:aft swapcontext task is NULL",__FUNCTION__);
     
102.                         continue;
     
103.                 }
     
104.                 if(!task->AIO_flg) {//service complate
     
105.                         if(!rs->tc.uc_stack.ss_size) {//回收fiber stack
     
106. //ShowLog(5,"%s:%lx release fiber from TCB_no=%d",__FUNCTION__,rs->tid,task->sv.TCB_no);
     
107.                                 rs->tc.uc_stack.ss_sp=task->uc.uc_stack.ss_sp;
     
108.                                 if(rs->tc.uc_stack.ss_sp)
     
109.                                          rs->tc.uc_stack.ss_size=use_stack_size;
     
110.                                 else rs->tc.uc_stack.ss_size=0;
     
111.                         } else {
     
112. ShowLog(5,"%s:%lx destroy fiber from TCB_no=%d",__FUNCTION__,rs->tid,task->sv.TCB_no);
     
113.                                 if(task->uc.uc_stack.ss_sp)
     
114.                                         munmap(task->uc.uc_stack.ss_sp,task->uc.uc_stack.ss_size);
     
115.                         }
     
116.                         task->uc.uc_stack.ss_sp=NULL;
     
117.                         rs->tc.uc_link=NULL;
     
118.                         task->uc.uc_link=NULL;
     
119.                         task->uc.uc_stack.ss_size=0;//mark fiber cpmplate
     
120. //ShowLog(5,"%s:TCB_no=%d,tid=%lx,timeout=%d,conn.timeout=%d",__FUNCTION__,task->sv.TCB_no,rs->tid,task->timeout,task->conn.timeout);
     
121.                 } else {
     
122.                         pthread_mutex_unlock(&task->lock);
     
123. 
     
124. ShowLog(5,"%s:tid=%lx,fiber yield from TCB_no=%d",
     
125.                         __FUNCTION__,pthread_self(),task->sv.TCB_no);
     
126.                 }
     
127.                 mthr_showid_del(rs->tid);
     
128.         }
     
129.         ShowLog(1,"%s:tid=%lx canceled",__FUNCTION__,pthread_self());
     
130.         mthr_showid_del(rs->tid);
     
131.         rs->timestamp=now_usec();
     
132.         rs->status=0;
     
133.         rs->tid=0;
     
134.         if(rs->tc.uc_stack.ss_sp) {
     
135.                 munmap(rs->tc.uc_stack.ss_sp,rs->tc.uc_stack.ss_size);
     
136.                 rs->tc.uc_stack.ss_sp=NULL;
     
137.                 rs->tc.uc_stack.ss_size=0;
     
138.         }
     
139.         return NULL;
     
140. }
     

复制代码

yulihua49

回复 17# zylthinking 怎么发了个回复没了？

1. static void *thread_work(void *param)
   
2. {
   
3. resource *rs=(resource *)param;
   
4. int ret,fds;
   
5. TCB *task=NULL;
   
6. struct epoll_event event;
   
7. 
   
8.         ShowLog(2,"%s:thread %lx start!",__FUNCTION__,pthread_self());
   
9.         getcontext(&rs->tc);
   
10.         if(task)  pthread_mutex_unlock(&task->lock);
    
11. 
    
12.         while(1) {
    
13. //从就绪队列取一个任务
    
14.                 pthread_mutex_lock(&rpool.mut);
    
15.                 while(!(task=rdy_get())) {
    
16.                         if(rpool.flg >= tpool.rdy_num) break;
    
17.                         rpool.flg++;
    
18.                         ret=pthread_cond_wait(&rpool.cond,&rpool.mut); //没有任务，等待
    
19.                         rpool.flg--;
    
20.                 }
    
21.                 pthread_mutex_unlock(&rpool.mut);
    
22.                 if(task) {
    
23.                         if(!task->AIO_flg && !task->call_back) {
    
24.                                 task->fd=task->conn.Socket;
    
25.                                 ShowLog(5,"%s:tid=%lx,TCB_no=%d from rdy_queue",__FUNCTION__,
    
26.                                         pthread_self(),task->sv.TCB_no);
    
27.                                 if(task->fd>=0) {
    
28.                                         do_epoll(task,0,0);
    
29.                                 }
    
30.                                 continue;
    
31.                         }
    
32.                 } else  {
    
33.                         fds = epoll_wait(g_epoll_fd, &event, 1 , -1);
    
34.                         if(fds < 0){
    
35.                                         ShowLog(1,"%s:epoll_wait err=%d,%s",__FUNCTION__,errno,strerror(errno));
    
36.                                 usleep(30000000);
    
37.                                 continue;
    
38.                                 }
    
39.                          task = (TCB *)event.data.ptr;
    
40.                         if(task->events) {
    
41.                             ShowLog(1,"%s:tid=%lx,TCB_no=%d,task->events=%08X,conflict!",__FUNCTION__,
    
42.                                     pthread_self(),task->sv.TCB_no,task->events);//发现惊群
    
43.                             task=NULL;
    
44.                             continue;//丢掉它
    
45.                         }
    
46.                         task->events=event.events;
    
47.                 }
    
48.                 rs->timestamp=now_usec();
    
49.                 if(task->status>0) set_showid(task->ctx);//Showid 应该在会话上下文结构里
    
50.                
    
51.                 if(task->AIO_flg) {//fiber task
    
52.                     task->uc.uc_link=&rs->tc;
    
53.                     rs->tc.uc_link=(ucontext_t *)task;
    
54. ShowLog(5,"%s:tid=%lx,resume to TCB_no=%d",__FUNCTION__,pthread_self(),task->sv.TCB_no);
    
55.                         pthread_mutex_lock(&task->lock);//防止其他线程提前闯入
    
56.                         setcontext(&task->uc);        //== longjmp()
    
57.                         continue;//no action,logic only
    
58.                 }
    
59.                 if(task->uc.uc_stack.ss_size>0) {//call_back模式，抢入了，进入同步模式
    
60.             rs->tc.uc_link=NULL;
    
61. ShowLog(5,"%s:tid %lx 抢入 SYNC",__FUNCTION__,pthread_self());
    
62.                         do_work(task->sv.TCB_no);
    
63.                         continue;
    
64.                 }
    
65.                 if(!rs->tc.uc_stack.ss_sp) {
    
66. ShowLog(5,"%s:%lx create fiber for TCB_no=%d",__FUNCTION__,rs->tid,task->sv.TCB_no);
    
67.                         task->uc.uc_stack.ss_sp=mmap(0, use_stack_size,
    
68.                                 PROT_READ | PROT_WRITE | PROT_EXEC,
    
69.                                 MAP_PRIVATE | MAP_ANON | MAP_GROWSDOWN, -1, 0);
    
70.                         if(task->uc.uc_stack.ss_sp==MAP_FAILED) {
    
71.                                 task->uc.uc_stack.ss_sp=NULL;
    
72.                                 do_work(task->sv.TCB_no); //进行你的服务,不使用AIO
    
73.                                 continue;
    
74.                         }
    
75.                 } else {
    
76. //ShowLog(5,"%s:%lx reuse fiber for TCB_no=%d",__FUNCTION__,rs->tid,task->sv.TCB_no);
    
77.                         task->uc.uc_stack.ss_sp=rs->tc.uc_stack.ss_sp;
    
78.                         rs->tc.uc_stack.ss_sp=NULL;
    
79.                         rs->tc.uc_stack.ss_size=0;
    
80.                 }
    
81.                 task->uc.uc_stack.ss_size=use_stack_size;
    
82.                 task->uc.uc_link=&rs->tc;
    
83.                 rs->tc.uc_link=(ucontext_t *)task;
    
84.                 makecontext(&task->uc,(void (*)())do_work,1,task->sv.TCB_no);
    
85. 
    
86.                 ret=swapcontext(&rs->tc,&task->uc);
    
87.                 if(ret<0) {
    
88.                         ShowLog(1,"%s:swapcontext fault TCB_NO=%d,tid=%lx,errno=%d,%s",
    
89.                                 __FUNCTION__,task->sv.TCB_no,pthread_self(),ret,strerror(abs(ret)));
    
90.                         rs->tc.uc_link=NULL;
    
91.                         task->uc.uc_link=NULL;
    
92.                         if(task->uc.uc_stack.ss_sp)
    
93.                                 munmap(task->uc.uc_stack.ss_sp,task->uc.uc_stack.ss_size);
    
94.                         task->uc.uc_stack.ss_sp=NULL;
    
95.                         task->uc.uc_stack.ss_size=0;
    
96.                         do_work(task->sv.TCB_no);
    
97.                         mthr_showid_del(rs->tid);
    
98.                         continue;
    
99.                 }
    
100.                 if(!task) {
     
101.                         ShowLog(1,"%s:aft swapcontext task is NULL",__FUNCTION__);
     
102.                         continue;
     
103.                 }
     
104.                 if(!task->AIO_flg) {//service complate
     
105.                         if(!rs->tc.uc_stack.ss_size) {//回收fiber stack
     
106. //ShowLog(5,"%s:%lx release fiber from TCB_no=%d",__FUNCTION__,rs->tid,task->sv.TCB_no);
     
107.                                 rs->tc.uc_stack.ss_sp=task->uc.uc_stack.ss_sp;
     
108.                                 if(rs->tc.uc_stack.ss_sp)
     
109.                                          rs->tc.uc_stack.ss_size=use_stack_size;
     
110.                                 else rs->tc.uc_stack.ss_size=0;
     
111.                         } else {
     
112. ShowLog(5,"%s:%lx destroy fiber from TCB_no=%d",__FUNCTION__,rs->tid,task->sv.TCB_no);
     
113.                                 if(task->uc.uc_stack.ss_sp)
     
114.                                         munmap(task->uc.uc_stack.ss_sp,task->uc.uc_stack.ss_size);
     
115.                         }
     
116.                         task->uc.uc_stack.ss_sp=NULL;
     
117.                         rs->tc.uc_link=NULL;
     
118.                         task->uc.uc_link=NULL;
     
119.                         task->uc.uc_stack.ss_size=0;//mark fiber cpmplate
     
120. //ShowLog(5,"%s:TCB_no=%d,tid=%lx,timeout=%d,conn.timeout=%d",__FUNCTION__,task->sv.TCB_no,rs->tid,task->timeout,task->conn.timeout);
     
121.                 } else {
     
122.                         pthread_mutex_unlock(&task->lock);
     
123. 
     
124. ShowLog(5,"%s:tid=%lx,fiber yield from TCB_no=%d",
     
125.                         __FUNCTION__,pthread_self(),task->sv.TCB_no);
     
126.                 }
     
127.                 mthr_showid_del(rs->tid);
     
128.         }
     
129.         ShowLog(1,"%s:tid=%lx canceled",__FUNCTION__,pthread_self());
     
130.         mthr_showid_del(rs->tid);
     
131.         rs->timestamp=now_usec();
     
132.         rs->status=0;
     
133.         rs->tid=0;
     
134.         if(rs->tc.uc_stack.ss_sp) {
     
135.                 munmap(rs->tc.uc_stack.ss_sp,rs->tc.uc_stack.ss_size);
     
136.                 rs->tc.uc_stack.ss_sp=NULL;
     
137.                 rs->tc.uc_stack.ss_size=0;
     
138.         }
     
139.         return NULL;
     
140. }
     

复制代码

yulihua49

1. static void *thread_work(void *param)
   
2. {
   
3. resource *rs=(resource *)param;
   
4. int ret,fds;
   
5. TCB *task=NULL;
   
6. struct epoll_event event;
   
7. 
   
8.         ShowLog(2,"%s:thread %lx start!",__FUNCTION__,pthread_self());
   
9.         getcontext(&rs->tc);
   
10.         if(task)  pthread_mutex_unlock(&task->lock);
    
11. 
    
12.         while(1) {
    
13. //从就绪队列取一个任务
    
14.                 pthread_mutex_lock(&rpool.mut);
    
15.                 while(!(task=rdy_get())) {
    
16.                         if(rpool.flg >= tpool.rdy_num) break;
    
17.                         rpool.flg++;
    
18.                         ret=pthread_cond_wait(&rpool.cond,&rpool.mut); //没有任务，等待
    
19.                          rpool.flg--;
    
20.                 }
    
21.                 pthread_mutex_unlock(&rpool.mut);
    
22.                 if(task) {
    
23.                         if(!task->AIO_flg && !task->call_back) {
    
24.                                 task->fd=task->conn.Socket;
    
25.                                 ShowLog(5,"%s:tid=%lx,TCB_no=%d from rdy_queue",__FUNCTION__,
    
26.                                         pthread_self(),task->sv.TCB_no);
    
27.                                 if(task->fd>=0) {
    
28.                                         do_epoll(task,0,0);
    
29.                                 }
    
30.                                 continue;
    
31.                         }
    
32.                 } else  {
    
33.                         fds = epoll_wait(g_epoll_fd, &event, 1 , -1);
    
34.                         if(fds < 0){
    
35.                                         ShowLog(1,"%s:epoll_wait err=%d,%s",__FUNCTION__,errno,strerror(errno));
    
36.                                 usleep(30000000);
    
37.                                 continue;
    
38.                                 }
    
39.                          task = (TCB *)event.data.ptr;
    
40.                         if(task->events) {
    
41.                             ShowLog(1,"%s:tid=%lx,TCB_no=%d,task->events=%08X,conflict!",__FUNCTION__,
    
42.                                     pthread_self(),task->sv.TCB_no,task->events);//发现惊群
    
43.                             task=NULL;
    
44.                             continue;//丢掉它
    
45.                         }
    
46.                         task->events=event.events;
    
47.                 }
    
48.                 rs->timestamp=now_usec();
    
49.                 if(task->status>0) set_showid(task->ctx);//Showid 应该在会话上下文结构里
    
50.                
    
51.                 if(task->AIO_flg) {//fiber task
    
52.                     task->uc.uc_link=&rs->tc;
    
53.                     rs->tc.uc_link=(ucontext_t *)task;
    
54. ShowLog(5,"%s:tid=%lx,resume to TCB_no=%d",__FUNCTION__,pthread_self(),task->sv.TCB_no);
    
55.                         pthread_mutex_lock(&task->lock);//防止其他线程提前闯入
    
56.                         setcontext(&task->uc);        //== longjmp()
    
57.                         continue;//no action,logic only
    
58.                 }
    
59.                 if(task->uc.uc_stack.ss_size>0) {//call_back模式，抢入了，进入同步模式
    
60.             rs->tc.uc_link=NULL;
    
61. ShowLog(5,"%s:tid %lx 抢入 SYNC",__FUNCTION__,pthread_self());
    
62.                         do_work(task->sv.TCB_no);
    
63.                         continue;
    
64.                 }
    
65.                 if(!rs->tc.uc_stack.ss_sp) {
    
66. ShowLog(5,"%s:%lx create fiber for TCB_no=%d",__FUNCTION__,rs->tid,task->sv.TCB_no);
    
67.                         task->uc.uc_stack.ss_sp=mmap(0, use_stack_size,
    
68.                                 PROT_READ | PROT_WRITE | PROT_EXEC,
    
69.                                 MAP_PRIVATE | MAP_ANON | MAP_GROWSDOWN, -1, 0);
    
70.                         if(task->uc.uc_stack.ss_sp==MAP_FAILED) {
    
71.                                 task->uc.uc_stack.ss_sp=NULL;
    
72.                                 do_work(task->sv.TCB_no); //进行你的服务,不使用AIO
    
73.                                 continue;
    
74.                         }
    
75.                 } else {
    
76. //ShowLog(5,"%s:%lx reuse fiber for TCB_no=%d",__FUNCTION__,rs->tid,task->sv.TCB_no);
    
77.                         task->uc.uc_stack.ss_sp=rs->tc.uc_stack.ss_sp;
    
78.                         rs->tc.uc_stack.ss_sp=NULL;
    
79.                         rs->tc.uc_stack.ss_size=0;
    
80.                 }
    
81.                 task->uc.uc_stack.ss_size=use_stack_size;
    
82.                 task->uc.uc_link=&rs->tc;
    
83.                 rs->tc.uc_link=(ucontext_t *)task;
    
84.                 makecontext(&task->uc,(void (*)())do_work,1,task->sv.TCB_no);
    
85. 
    
86.                 ret=swapcontext(&rs->tc,&task->uc);
    
87.                 if(ret<0) {
    
88.                         ShowLog(1,"%s:swapcontext fault TCB_NO=%d,tid=%lx,errno=%d,%s",
    
89.                                 __FUNCTION__,task->sv.TCB_no,pthread_self(),ret,strerror(abs(ret)));
    
90.                         rs->tc.uc_link=NULL;
    
91.                         task->uc.uc_link=NULL;
    
92.                         if(task->uc.uc_stack.ss_sp)
    
93.                                 munmap(task->uc.uc_stack.ss_sp,task->uc.uc_stack.ss_size);
    
94.                         task->uc.uc_stack.ss_sp=NULL;
    
95.                         task->uc.uc_stack.ss_size=0;
    
96.                         do_work(task->sv.TCB_no);
    
97.                         mthr_showid_del(rs->tid);
    
98.                         continue;
    
99.                 }
    
100.                 if(!task) {
     
101.                         ShowLog(1,"%s:aft swapcontext task is NULL",__FUNCTION__);
     
102.                         continue;
     
103.                 }
     
104.                 if(!task->AIO_flg) {//service complate
     
105.                         if(!rs->tc.uc_stack.ss_size) {//回收fiber stack
     
106. //ShowLog(5,"%s:%lx release fiber from TCB_no=%d",__FUNCTION__,rs->tid,task->sv.TCB_no);
     
107.                                 rs->tc.uc_stack.ss_sp=task->uc.uc_stack.ss_sp;
     
108.                                 if(rs->tc.uc_stack.ss_sp)
     
109.                                          rs->tc.uc_stack.ss_size=use_stack_size;
     
110.                                 else rs->tc.uc_stack.ss_size=0;
     
111.                         } else {
     
112. ShowLog(5,"%s:%lx destroy fiber from TCB_no=%d",__FUNCTION__,rs->tid,task->sv.TCB_no);
     
113.                                 if(task->uc.uc_stack.ss_sp)
     
114.                                         munmap(task->uc.uc_stack.ss_sp,task->uc.uc_stack.ss_size);
     
115.                         }
     
116.                         task->uc.uc_stack.ss_sp=NULL;
     
117.                         rs->tc.uc_link=NULL;
     
118.                         task->uc.uc_link=NULL;
     
119.                         task->uc.uc_stack.ss_size=0;//mark fiber cpmplate
     
120. //ShowLog(5,"%s:TCB_no=%d,tid=%lx,timeout=%d,conn.timeout=%d",__FUNCTION__,task->sv.TCB_no,rs->tid,task->timeout,task->conn.timeout);
     
121.                 } else {
     
122.                         pthread_mutex_unlock(&task->lock);
     
123. 
     
124. ShowLog(5,"%s:tid=%lx,fiber yield from TCB_no=%d",
     
125.                         __FUNCTION__,pthread_self(),task->sv.TCB_no);
     
126.                 }
     
127.                 mthr_showid_del(rs->tid);
     
128.         }
     
129.         ShowLog(1,"%s:tid=%lx canceled",__FUNCTION__,pthread_self());
     
130.         mthr_showid_del(rs->tid);
     
131.         rs->timestamp=now_usec();
     
132.         rs->status=0;
     
133.         rs->tid=0;
     
134.         if(rs->tc.uc_stack.ss_sp) {
     
135.                 munmap(rs->tc.uc_stack.ss_sp,rs->tc.uc_stack.ss_size);
     
136.                 rs->tc.uc_stack.ss_sp=NULL;
     
137.                 rs->tc.uc_stack.ss_size=0;
     
138.         }
     
139.         return NULL;
     
140. }
     

复制代码