lua学习之协程

lua中的另一个高级功能是coroutine(协程),协同式多线程的意思,不同于线程和进程,协程仅在显示的调用一个让出(yield)函数时才会挂起当前的执行,同一时间内只有一个协程正在运行,非抢占式的。

api介绍

  • coroutine.create( fun ) *** 参数: *** 是一个函数,是这个协程的主体函数。*** 返回值: *** 返回一个新的协程,类型为"thread"。*** 作用: *** 创建一个新的协程。
  • coroutine.yield( ... ) *** 参数: *** 任意变长参数。*** 返回值: *** 状态true或者false表示这个协程有没有挂起成功,然后返回传递的变长参数,全部返回给上次的coroutine.resume()调用。*** 作用: *** 挂起一个正在运行的协程,这个是有限制的,比如在调用C函数中和一些迭代器中是不能yield的。
  • coroutine.resume( co, ... ) *** 参数: *** 一个协程,通过coroutine.create()创建的,加上自定义参数,这些自定义参数都会传递给协程的主函数。***
    返回值: *** 一个boolean型的值表示有没有正确执行,之后的返回值都是coroutine.yield()中的参数。如果第一个值是false,后面的是错误信息。*** 作用: *** 运行一个协程直到函数执行完或者函数调用coroutine.yield()主动退出。
  • coroutine.wrap( fun ),*** 参数: *** 一个函数。*** 返回值: *** 和coroutinue.resume()相同,只不过没有boolean变量。*** 作用: *** 和coroutine.create()相似,只不过返回的是一个函数,每次调用这个函数就继续执行这个协程。传递给这个函数的参数都将作为coroutine.resume()额外的参数。
  • coroutine.running( ) *** 参数: *** 无。*** 返回值: *** 返回正在运行的协程否则返回nil。
  • coroutine.status( co ) *** 参数: *** 一个协程。*** 返回值: *** 返回这个协程当前的状态,主要有,* running * 表示正在运行;* suspended * 表示没有运行或者yield让出的状态;* normal * 表示协程是活的,但是并不在运行(正在延续其它的协程);* dead * 表示协程执行完毕或者因错误停止。

代码

local function test(a)
    print("test : ", a)
    return coroutine.yield(2 * a)
end
local co = coroutine.create( function(b, c) 
    print("running : ", coroutine.running())
    print("co-body 1 : ", b, c)
    local r = test(b + 1)
    print("co-body 2 : ", r)
    local n, m = coroutine.yield(b - c, b + c)
    print("co-body 3 : ", n, m)
    return "begin", "end"
end)
print("test status 1 : ", coroutine.status(co))
print("main 1 : ", coroutine.resume(co, 1, 9))
print("main 2 : ", coroutine.resume(co, "r"))
print("main 3 : ", coroutine.resume(co, "n", "m"))
print("main 4 : ", coroutine.resume(co, "x", "y"))
print("test status 3 : ", coroutine.status(co))

结果如下

test status 1 :         suspended
running :       thread: 0x1e64df0
co-body 1 :     1       9
test :  2
main 1 :        true    4
co-body 2 :     r
main 2 :        true    -8      10
co-body 3 :     n       m
main 3 :        true    begin   end
main 4 :        false   cannot resume dead coroutine
test status 3 :         dead

结合上面的介绍和代码可以简单的理解各个函数的作用,并且对lua的协程有一个感性的认知。

示例

经典的生产者消费者问题,我们用lua协程的方式来实现一遍

local function send(p)
    print("product send : ", p)
    coroutine.yield(p)
end
local product = coroutine.create(function()
    while(true) do
        local p = io.read()
        send(p)
    end
end)
local function receive(co)
    local ok, res = coroutine.resume(co)
    if ok then
        print("consumer received : ", res)
    else
        print("consumer receive failed : ", res)
    end
end
local function consumer(co)
    while (true) do
        receive(co)
    end
end
consumer(product)

运行结果

hello world
product send :  hello world
consumer received :     hello world
1234567890
product send :  1234567890
consumer received :     1234567890
1 + 1 = 2
product send :  1 + 1 = 2
consumer received :     1 + 1 = 2

大致的解释一遍,程序会创建一个product协程,然后consumer函数调用recieve的时候会唤醒生产者协程主函数,主函数会把得到的值yield出去,这一步做了两个事情,一个是把得到的值返回给消费者,另一个是挂起自己,等待下次被激活。

后记

  • 通过lua的协程我们可以用同步的方式写出异步的程序。
  • 当然本文只是简单的介绍lua的协程机制,具体到实际应用的话,还是会有很多变化的,lua-resty-http是使用ngx_lua socket实现的一个http客户端,其中就有用到协程相关,有兴趣可以看看具体的实现。

*** 如有疑问欢迎批评指正,谢谢! ***

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

推荐阅读更多精彩内容

  • 我们首先介绍一下什么是协程、然后详细介绍一下coroutine库,然后介绍一下协程的简单用法,最后介绍一下协程的复...
    17269780ceda阅读 721评论 0 6
  • 1.1程序块:Lua执行的每段代码,例如一个源代码文件或者交互模式中输入的一行代码,都称为一个程序块 1.2注释:...
    c_xiaoqiang阅读 2,594评论 0 9
  • “协程(coroutine)”于我而言还是比较新的概念,Lua 也是刚接触不久。不过碰巧这段时间我又在看 ES6 ...
    NARUTO_86阅读 1,714评论 0 3
  • 原文链接:https://github.com/EasyKotlin 在常用的并发模型中,多进程、多线程、分布式是...
    JackChen1024阅读 10,738评论 3 23
  • 什么是线程 线程 是操作系统能够运行的最小执行单元,被包含在进程之中,而进程,可以广泛的理解为一个 applica...
    mrwangyong阅读 498评论 0 3