菜鸟笔记
提升您的技术认知

ucontext 简单协程库-ag真人游戏

1.干货写在前面

协程是一种用户态的轻量级线程。本篇主要研究协程的c/c 的实现。
首先我们可以看看有哪些语言已经具备协程语义:

  • 比较重量级的有c#、erlang、golang*
  • 轻量级有python、lua、javascript、ruby
  • 还有函数式的scala、scheme等。

c/c 不直接支持协程语义,但有不少开源的协程库,如:
protothreads:一个“蝇量级” c 语言协程库
libco:来自腾讯的开源协程库libco介绍,ag真人试玩娱乐官网
coroutine:云风的一个c语言同步协程库,详细信息

目前看到大概有四种实现协程的方式:

  • 第一种:利用glibc 的 ucontext组件(云风的库)
  • 第二种:使用汇编代码来切换上下文(实现c协程)
  • 第三种:利用c语言语法switch-case的奇淫技巧来实现(protothreads)
  • 第四种:利用了 c 语言的 setjmp 和 longjmp( 一种协程的 c/c 实现,要求函数里面使用 static local 的变量来保存协程内部的数据)

本篇主要使用ucontext来实现简单的协程库。

2.ucontext初接触

利用ucontext提供的四个函数getcontext(),setcontext(),makecontext(),swapcontext()可以在一个进程中实现用户级的线程切换。

本节我们先来看ucontext实现的一个简单的例子:

[cpp]  

  1. #include   
  2. #include   
  3. #include   
  4.   
  5. int main(int argc, const char *argv[]){  
  6.     ucontext_t context;  
  7.   
  8.     getcontext(&context);  
  9.     puts("hello world");  
  10.     sleep(1);  
  11.     setcontext(&context);  
  12.     return 0;  
  13. }  

注:示例代码来自维基百科.

保存上述代码到example.c,执行编译命令:

gcc example.c -o example

想想程序运行的结果会是什么样?

[plain]  

  1. cxy@ubuntu:~$ ./example   
  2. hello world  
  3. hello world  
  4. hello world  
  5. hello world  
  6. hello world  
  7. hello world  
  8. hello world  
  9. ^c  
  10. cxy@ubuntu:~$  

上面是程序执行的部分输出,不知道是否和你想得一样呢?我们可以看到,程序在输出第一个“hello world"后并没有退出程序,而是持续不断的输出”hello world“。其实是程序通过getcontext先保存了一个上下文,然后输出"hello world",在通过setcontext恢复到getcontext的地方,重新执行代码,所以导致程序不断的输出”hello world“,在我这个菜鸟的眼里,这简直就是一个神奇的跳转。

那么问题来了,ucontext到底是什么?

3.ucontext组件到底是什么

在类system v环境中,在头文件< ucontext.h > 中定义了两个结构类型,mcontext_tucontext_t和四个函数getcontext(),setcontext(),makecontext(),swapcontext().利用它们可以在一个进程中实现用户级的线程切换。

mcontext_t类型与机器相关,并且不透明.ucontext_t结构体则至少拥有以下几个域:

[cpp] 

  1. typedef struct ucontext {  
  2.     struct ucontext *uc_link;  
  3.     sigset_t         uc_sigmask;  
  4.     stack_t          uc_stack;  
  5.     mcontext_t       uc_mcontext;  
  6.     ...  
  7. } ucontext_t;  

当当前上下文(如使用makecontext创建的上下文)运行终止时系统会恢复uc_link指向的上下文;uc_sigmask为该上下文中的阻塞信号集合;uc_stack为该上下文中使用的栈;uc_mcontext保存的上下文的特定机器表示,包括调用线程的特定寄存器等。

下面详细介绍四个函数:

int getcontext(ucontext_t *ucp);

初始化ucp结构体,将当前的上下文保存到ucp中

int setcontext(const ucontext_t *ucp);

设置当前的上下文为ucp,setcontext的上下文ucp应该通过getcontext或者makecontext取得,如果调用成功则不返回。如果上下文是通过调用getcontext()取得,程序会继续执行这个调用。如果上下文是通过调用makecontext取得,程序会调用makecontext函数的第二个参数指向的函数,如果func函数返回,则恢复makecontext第一个参数指向的上下文第一个参数指向的上下文context_t中指向的uc_link.如果uc_link为null,则线程退出。

void makecontext(ucontext_t *ucp, void (*func)(), int argc, ...);

makecontext修改通过getcontext取得的上下文ucp(这意味着调用makecontext前必须先调用getcontext)。然后给该上下文指定一个栈空间ucp->stack,设置后继的上下文ucp->uc_link.

当上下文通过setcontext或者swapcontext激活后,执行func函数,argc为func的参数个数,后面是func的参数序列。当func执行返回后,继承的上下文被激活,如果继承上下文为null时,线程退出。

int swapcontext(ucontext_t *oucp, ucontext_t *ucp);

保存当前上下文到oucp结构体中,然后激活upc上下文。

如果执行成功,getcontext返回0,setcontext和swapcontext不返回;如果执行失败,getcontext,setcontext,swapcontext返回-1,并设置对于的errno.

简单说来,  getcontext获取当前上下文,setcontext设置当前上下文,swapcontext切换上下文,makecontext创建一个新的上下文。

4.小试牛刀-使用ucontext组件实现线程切换

虽然我们称协程是一个用户态的轻量级线程,但实际上多个协程同属一个线程。任意一个时刻,同一个线程不可能同时运行两个协程。如果我们将协程的调度简化为:主函数调用协程1,运行协程1直到协程1返回主函数,主函数在调用协程2,运行协程2直到协程2返回主函数。示意步骤如下:

[cpp] 

  1. 执行主函数  
  2. 切换:主函数 --> 协程1  
  3. 执行协程1  
  4. 切换:协程1  --> 主函数  
  5. 执行主函数  
  6. 切换:主函数 --> 协程2  
  7. 执行协程2  
  8. 切换协程2  --> 主函数  
  9. 执行主函数  
  10. ...  

这种设计的关键在于实现主函数到一个协程的切换,然后从协程返回主函数。这样无论是一个协程还是多个协程都能够完成与主函数的切换,从而实现协程的调度。

实现用户线程的过程是:

  1. 我们首先调用getcontext获得当前上下文
  2. 修改当前上下文ucontext_t来指定新的上下文,如指定栈空间极其大小,设置用户线程执行完后返回的后继上下文(即主函数的上下文)等
  3. 调用makecontext创建上下文,并指定用户线程中要执行的函数
  4. 切换到用户线程上下文去执行用户线程(如果设置的后继上下文为主函数,则用户线程执行完后会自动返回主函数)。

下面代码context_test函数完成了上面的要求。

[cpp]  

  1. #include   
  2. #include   
  3.   
  4. void func1(void * arg)  
  5. {  
  6.     puts("1");  
  7.     puts("11");  
  8.     puts("111");  
  9.     puts("1111");  
  10.   
  11. }  
  12. void context_test()  
  13. {  
  14.     char stack[1024*128];  
  15.     ucontext_t child,main;  
  16.   
  17.     getcontext(&child); //获取当前上下文  
  18.     child.uc_stack.ss_sp = stack;//指定栈空间  
  19.     child.uc_stack.ss_size = sizeof(stack);//指定栈空间大小  
  20.     child.uc_stack.ss_flags = 0;  
  21.     child.uc_link = &main;//设置后继上下文  
  22.   
  23.     makecontext(&child,(void (*)(void))func1,0);//修改上下文指向func1函数  
  24.   
  25.     swapcontext(&main,&child);//切换到child上下文,保存当前上下文到main  
  26.     puts("main");//如果设置了后继上下文,func1函数指向完后会返回此处  
  27. }  
  28.   
  29. int main()  
  30. {  
  31.     context_test();  
  32.   
  33.     return 0;  
  34. }  

在context_test中,创建了一个用户线程child,其运行的函数为func1.指定后继上下文为main
func1返回后激活后继上下文,继续执行主函数。

保存上面代码到example-switch.cpp.运行编译命令:

g   example-switch.cpp -o example-switch

执行程序结果如下

[cpp]  

  1. cxy@ubuntu:~$ ./example-switch  
  2. 1  
  3. 11  
  4. 111  
  5. 1111  
  6. main  
  7. cxy@ubuntu:~$  

你也可以通过修改后继上下文的设置,来观察程序的行为。如修改代码

child.uc_link = &main;

child.uc_link = null;

再重新编译执行,其执行结果为:

[cpp]  

  1. cxy@ubuntu:~$ ./example-switch  
  2. 1  
  3. 11  
  4. 111  
  5. 1111  
  6. cxy@ubuntu:~$  

可以发现程序没有打印"main",执行为func1后直接退出,而没有返回主函数。可见,如果要实现主函数到线程的切换并返回,指定后继上下文是非常重要的。

5.使用ucontext实现自己的线程库

掌握了上一节从主函数到协程的切换的关键,我们就可以开始考虑实现自己的协程了。
定义一个协程的结构体如下:

[cpp]  

  1. typedef void (*fun)(void *arg);  
  2.   
  3. typedef struct uthread_t  
  4. {  
  5.     ucontext_t ctx;  
  6.     fun func;  
  7.     void *arg;  
  8.     enum threadstate state;  
  9.     char stack[default_stack_szie];  
  10. }uthread_t;  

ctx保存协程的上下文,stack为协程的栈,栈大小默认为default_stack_szie=128kb.你可以根据自己的需求更改栈的大小。func为协程执行的用户函数,arg为func的参数,state表示协程的运行状态,包括free,runnable,runing,suspend,分别表示空闲,就绪,正在执行和挂起四种状态。

在定义一个调度器的结构体

[cpp]  

  1. typedef std::vector thread_vector;  
  2.   
  3. typedef struct schedule_t  
  4. {  
  5.     ucontext_t main;  
  6.     int running_thread;  
  7.     thread_vector threads;  
  8.   
  9.     schedule_t():running_thread(-1){}  
  10. }schedule_t;  

调度器包括主函数的上下文main,包含当前调度器拥有的所有协程的vector类型的threads,以及指向当前正在执行的协程的编号running_thread.如果当前没有正在执行的协程时,running_thread=-1.

接下来,在定义几个使用函数uthread_create,uthread_yield,uthread_resume函数已经辅助函数schedule_finished.就可以了。

int  uthread_create(schedule_t &schedule,fun func,void *arg);

创建一个协程,该协程的会加入到schedule的协程序列中,func为其执行的函数,arg为func的执行函数。返回创建的线程在schedule中的编号。

void uthread_yield(schedule_t &schedule);

挂起调度器schedule中当前正在执行的协程,切换到主函数。

void uthread_resume(schedule_t &schedule,int id);

恢复运行调度器schedule中编号为id的协程

int  schedule_finished(const schedule_t &schedule);

判断schedule中所有的协程是否都执行完毕,是返回1,否则返回0.注意:如果有协程处于挂起状态时算作未全部执行完毕,返回0.

代码就不全贴出来了,我们来看看两个关键的函数的具体实现。首先是uthread_resume函数:

[cpp]  

  1. void uthread_resume(schedule_t &schedule , int id)  
  2. {  
  3.     if(id < 0 || id >= schedule.threads.size()){  
  4.         return;  
  5.     }  
  6.   
  7.     uthread_t *t = &(schedule.threads[id]);  
  8.   
  9.     switch(t->state){  
  10.         case runnable:  
  11.             getcontext(&(t->ctx));  
  12.   
  13.             t->ctx.uc_stack.ss_sp = t->stack;  
  14.             t->ctx.uc_stack.ss_size = default_stack_szie;  
  15.             t->ctx.uc_stack.ss_flags = 0;  
  16.             t->ctx.uc_link = &(schedule.main);  
  17.             t->state = running;  
  18.   
  19.             schedule.running_thread = id;  
  20.   
  21.             makecontext(&(t->ctx),(void (*)(void))(uthread_body),1,&schedule);  
  22.   
  23.             /* !! note : here does not need to break */  
  24.   
  25.         case suspend:  
  26.   
  27.             swapcontext(&(schedule.main),&(t->ctx));  
  28.   
  29.             break;  
  30.         default: ;  
  31.     }  
  32. }  

如果指定的协程是首次运行,处于runnable状态,则创建一个上下文,然后切换到该上下文。如果指定的协程已经运行过,处于suspend状态,则直接切换到该上下文即可。代码中需要注意runnbale状态的地方不需要break.

[cpp]  

  1. void uthread_yield(schedule_t &schedule)  
  2. {  
  3.     if(schedule.running_thread != -1 ){  
  4.         uthread_t *t = &(schedule.threads[schedule.running_thread]);  
  5.         t->state = suspend;  
  6.         schedule.running_thread = -1;  
  7.   
  8.         swapcontext(&(t->ctx),&(schedule.main));  
  9.     }  
  10. }  

uthread_yield挂起当前正在运行的协程。首先是将running_thread置为-1,将正在运行的协程的状态置为suspend,最后切换到主函数上下文。

更具体的代码我已经放到github上,点击这里。

6.最后一步-使用我们自己的协程库

保存下面代码到example-uthread.cpp.

[cpp] 

  1. #include "uthread.h"  
  2. #include   
  3.   
  4. void func2(void * arg)  
  5. {  
  6.     puts("22");  
  7.     puts("22");  
  8.     uthread_yield(*(schedule_t *)arg);  
  9.     puts("22");  
  10.     puts("22");  
  11. }  
  12.   
  13. void func3(void *arg)  
  14. {  
  15.     puts("3333");  
  16.     puts("3333");  
  17.     uthread_yield(*(schedule_t *)arg);  
  18.     puts("3333");  
  19.     puts("3333");  
  20.   
  21. }  
  22.   
  23. void schedule_test()  
  24. {  
  25.     schedule_t s;  
  26.   
  27.     int id1 = uthread_create(s,func3,&s);  
  28.     int id2 = uthread_create(s,func2,&s);  
  29.   
  30.     while(!schedule_finished(s)){  
  31.         uthread_resume(s,id2);  
  32.         uthread_resume(s,id1);  
  33.     }  
  34.     puts("main over");  
  35.   
  36. }  
  37. int main()  
  38. {  
  39.     schedule_test();  
  40.   
  41.     return 0;  
  42. }  

执行编译命令并运行:

g   example-uthread.cpp -o example-uthread
./example-uthread

运行结果如下:

[cpp]  

  1. cxy@ubuntu:~/mythread$./example-uthread  
  2. 22  
  3. 22  
  4. 3333  
  5. 3333  
  6. 22  
  7. 22  
  8. 3333  
  9. 3333  
  10. main over  
  11. cxy@ubuntu:~/mythread$  

可以看到,程序协程func2,然后切换到主函数,在执行协程func3,再切换到主函数,又切换到func2,在切换到主函数,再切换到func3,最后切换到主函数结束。

总结一下,我们利用getcontext和makecontext创建上下文,设置后继的上下文到主函数,设置每个协程的栈空间。在利用swapcontext在主函数和协程之间进行切换。

到此,使用ucontext做一个自己的协程库就到此结束了。相信你也可以自己完成自己的协程库了。

最后,代码我已经放到github上,点击这里。

/**
* @file  uthread.cpp
* @author chenxueyou
* @version 0.1
* @brief   :a asymmetric coroutine library for c  
* history
*      1. date: 2014-12-12 
*          author: chenxueyou
*          modification: this file was created 
*/
#ifndef my_uthread_cpp
#define my_uthread_cpp
#include "uthread.h"
//#include 
void uthread_resume(schedule_t &schedule , int id)
{
    if(id < 0 || id >= schedule.threads.size()){
        return;
    }
    uthread_t *t = &(schedule.threads[id]);
    switch(t->state){
        case runnable:
            getcontext(&(t->ctx));
    
            t->ctx.uc_stack.ss_sp = t->stack;
            t->ctx.uc_stack.ss_size = default_stack_szie;
            t->ctx.uc_stack.ss_flags = 0;
            t->ctx.uc_link = &(schedule.main);
            t->state = running;
            schedule.running_thread = id;
            makecontext(&(t->ctx),(void (*)(void))(uthread_body),1,&schedule);
            
            /* !! note : here does not need to break */
        case suspend:
            
            swapcontext(&(schedule.main),&(t->ctx));
            break;
        default: ;
    }
}
void uthread_yield(schedule_t &schedule)
{
    if(schedule.running_thread != -1 ){
        uthread_t *t = &(schedule.threads[schedule.running_thread]);
        t->state = suspend;
        schedule.running_thread = -1;
        swapcontext(&(t->ctx),&(schedule.main));
    }
}
void uthread_body(schedule_t *ps)
{
    int id = ps->running_thread;
    if(id != -1){
        uthread_t *t = &(ps->threads[id]);
        t->func(t->arg);
        t->state = free;
        
        ps->running_thread = -1;
    }
}
int uthread_create(schedule_t &schedule,fun func,void *arg)
{
    int id = 0;
    int threadnum = schedule.threads.size();
    
    for(id = 0; id < threadnum;   id ){
        if(schedule.threads[id].state == free){
            break;
        }
    }
    
    if(id == threadnum){
        uthread_t thread;
        schedule.threads.push_back(thread);
    }
    uthread_t *t = &(schedule.threads[id]);
    t->state = runnable;
    t->func = func;
    t->arg = arg;
/*
//    这段代码以迁移到uthread_resume,初次使用在多个协程时会出现段错误
    getcontext(&(t->ctx));
    
    t->ctx.uc_stack.ss_sp = t->stack;
    t->ctx.uc_stack.ss_size = default_stack_szie;
    t->ctx.uc_stack.ss_flags = 0;
    t->ctx.uc_link = &(schedule.main);
    makecontext(&(t->ctx),(void (*)(void))(uthread_body),1,&schedule);
*/    
    return id;
}
int schedule_finished(const schedule_t &schedule)
{
    if (schedule.running_thread != -1){
        return 0;
    }else{
        for(int i = 0; i < schedule.threads.size();   i){
            if(schedule.threads[i].state != free){
                return 0;
            }
        }
    }
    return 1;
}
#endif
网站地图