tbox协程使用之切换与等待

tbox的协程实现,是stackfull模式的,需要指定独立堆栈和协程函数,目前暂时还不能像golang那样实现堆栈的动态增长,之后会对其进行支持。

目前提供下面一些功能特性:

1. 提供yield切换调度支持,这个是必须的哈
2. 提供suspend(挂起)/resume(恢复)协程接口,不同于yield的是,被suspend后,如果不显示调用resume恢复它,是永远不会被调度到的
3. 提供sleep等待接口支持
4. 提供io调度支持,支持socket等io等待(内部使用epoll, poll, kqueue, select, poll等接口调度)
5. 原生支持stream,socket,http等模块的协程支持,可与线程进行无缝切换
6. 提供channel同道,进行协程间交互通信
7. 提供lock,semaphore等接口

这里主要讲讲,基础的切换调度如何使用。。

yield切换

这个的使用非常简单,直接上代码吧,嘿嘿。。

static tb_void_t switchfunc(tb_cpointer_t priv)
{
    // 获取传入的参数
    tb_size_t count = (tb_size_t)priv;
    while (count--)
    {
        // 打印当前协程id
        tb_trace_i("[coroutine: %p]: %lu", tb_coroutine_self(), count);

        // 让出当前协程,进行切换
        tb_coroutine_yield();
    }
}
tb_int_t main(tb_int_t argc, tb_char_t** argv)
{
    // 初始化tbox
    if (!tb_init(tb_null, tb_null)) return -1;

    // 初始化一个调度器实例
    tb_co_scheduler_ref_t scheduler = tb_co_scheduler_init();
    if (scheduler)
    {
        // 开启一个协程,传递switchfunc切换函数和参数10,最后一个参数指定栈大小,传0使用默认值
        tb_coroutine_start(scheduler, switchfunc, (tb_cpointer_t)10, 0);

        // 开启协程,使用指定的栈大小:8192
        tb_coroutine_start(scheduler, switchfunc, (tb_cpointer_t)10, 8192);

        /* 运行调用,开始运行里面的所有协程
         *
         * 第二个参数指定是否启用独占模式,这个稍后细讲
         */
        tb_co_scheduler_loop(scheduler, tb_true);

        // 退出调度器
        tb_co_scheduler_exit(scheduler);
    }

    // 退出tbox
    tb_exit();
}

所有协程执行完后,就会从loop调用处返回,当然在协程函数内部也是可以嵌套开启新协程的

这个时候第一个参数就不需要显示指定scheduler了,传tb_null表示在当前调度器环境中开新协程,例如:

static tb_void_t switchfunc2(tb_cpointer_t priv)
{
    // ..
}
static tb_void_t switchfunc(tb_cpointer_t priv)
{
    // 在当前协程函数内,开启一个新协程    
    tb_coroutine_start(tb_null, switchfunc2, tb_null, 0);

    // 获取传入的参数
    tb_size_t count = (tb_size_t)priv;
    while (count--)
    {
        // 让出当前协程,进行切换
        tb_coroutine_yield();
    }
}

独占模式

上面的代码中提到的独占模式,需要特殊说明下,一般情况下,传tb_false到loop()中,不启用此模式是最为稳妥的。

因为这样每个scheduler对应的线程都会在Tls中维护自己的scheduler引用,使得协程中所有操作,都回去访问当前线程tls对应的独立scheduler,互不干涉。

这个在存在多个scheduler的情况,尤为重要,当时这样多少会有些tls操作上的性能损耗,像server端一般只有一个scheduler的情况下,就没必要放到独立tls中去了

可以传入tb_true启用独占模式,告诉tb_co_scheduler_loop(),我当前不需要tls维护,只需要一个全局scheduler变量来维护就行了

这样的话,性能会提升一些,因此在只有一个scheduler存在的情况下,启用独占效率会高些。。

sleep等待

tbox的tb_sleeptb_msleep()接口,是可以原生支持协程的,在协程外就是线程等待,在协程内就是协程等待。

当然也可以直接使用协程的接口:tb_coroutine_sleep()

例如:

static tb_void_t sleepfunc(tb_cpointer_t priv)
{
    while (1)
    {
        // 等待10ms,切换到其他协程,直到10ms后才会切换回来继续执行
        tb_msleep(10);
    }
}

resume/suspend接口

挂起域恢复,跟yield的区别就是,被suspend挂起的协程,默认是不会被切换调度回来的,除非执行resume恢复它。

因此这两个接口是成对使用的,像sleep,lock和semaphore的内部实现,也是基于此套接口。

这两个接口还有个功能,就是可以在两个协程间,更加快速方便的传递一些参数数据,进行交互,而不需要channel支持。。

例如:

static tb_void_t resumefunc(tb_cpointer_t priv)
{
    // 获取suspend协程引用 
    tb_coroutine_ref_t coroutine = (tb_coroutine_ref_t)priv;

    /* 恢复suspend协程,传递参数"hello suspend!"给suspend()作为其返回值
     *
     * retval为suspend()中传入的参数:"hello resume!"
     */
    tb_char_t const* retval = tb_coroutine_resume(coroutine, "hello suspend!");
}
static tb_void_t suspendfunc(tb_cpointer_t priv)
{
    // 开启一个恢复协程,传入当前协程引用
    tb_coroutine_start(tb_null, resumefunc, tb_coroutine_self(), 0);

    /* 挂起当前协程,传递参数"hello resume!"给resume()作为其返回值
     *
     * retval为resume()中传入的参数:"hello suspend!"
     */
    tb_char_t const* retval = tb_coroutine_suspend("hello resume!");
}

当然,如果不需要交互数据,那么只需要传tb_null就行了。。


个人主页:TBOOX开源工程
原文出处:http://tboox.org/cn/2016/10/29/coroutine-switch/

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 227,367评论 6 532
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 98,001评论 3 413
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 175,213评论 0 373
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 62,535评论 1 308
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 71,317评论 6 405
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 54,868评论 1 321
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 42,963评论 3 440
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 42,090评论 0 285
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 48,599评论 1 331
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 40,549评论 3 354
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 42,712评论 1 367
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 38,233评论 5 356
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 43,961评论 3 346
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 34,353评论 0 25
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 35,607评论 1 281
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 51,321评论 3 389
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 47,686评论 2 370

推荐阅读更多精彩内容