Lua 协程 coroutine

协程是协同程序的简称,顾名思义,就是协同工作的程序。协程拥有自己独立的桟、局部变量和PC计数器,同时又与其他协同程序共享全局变量和其他大部分东西;

协程与线程的主要区别在于,一个多线程程序可以同时运行几个线程(并发执行、抢占),而协同程序却需要彼此协作地运行,即一个多协程程序在任意时刻只能运行一个协程,并且正在执行的协程只会在其显式地要求挂起(suspend)时,它的执行才会暂停(无抢占、无并发)。

Lua中所有与协程相关的函数都在coroutine(一个table)中; 函数create用于创建新的协程,只有一个参数——要执行的函数,返回一个thread类型的值。

thread的状态:suspend、running、dead、normal,可以通过coroutine.status(co)来检查co的状态。

创建一个thread时,它处于挂起状态。coroutine.resume函数用于启动或再次启动一个协程的执行,并可以向coroutine传递参数。当一个协程结束时,主函数返回的值将作为resume的返回值。

coroutine.yield用于一个运行中的协程挂起(suspend),之后可以再恢复(resume)。yield的返回值就是resume传入的参数。

Lua的协程模型可以类比Python的generator

一个简单的示例:

> co = coroutine.create(function(a) while a > 0 do print(coroutine.yield(a)); a = a - 1; end
return -1 end)

> return coroutine.resume(co, 3) --- 3是传递给主函数的

true        3

> return coroutine.resume(co, 4)

4

true        2

> return coroutine.resume(co, 5)

5

true        1

> return coroutine.resume(co, 6)

6

true        -1
---主函数已经返回

> return coroutine.resume(co, 7)

false        cannot resume dead coroutine

>

协程的应用 —— 生产者/消费者

需求:输入一行,打印一行

function send(x)

coroutine.yield(x)

end

function receive(co)

local s, v = coroutine.resume(co)

return v

end

function producer()

return coroutine.create(function()

while true do

local x = io.read()

send(x)

end

end)

end

function filter(prod)

return coroutine.create(function()

for line = 1, math.huge do

local x = receive(prod)

x = string.format(‘%5d %s‘, line, x)

send(x)

end

end)

end

function consumer(prod)

while true do

local x = receive(prod)

io.write(x, ‘\n‘)

end

end

prod = producer()

fil = filter(prod)

con = consumer(fil)

协程的应用 —— 迭代器(类比Python Generator)

function seq_generator(n)

local i = 1

while i <= n do

coroutine.yield(i)

i = i + 1

end

return nil

end

function seq(n)

local co = coroutine.create(function() seq_generator(n) end)

return function()

local s,v = coroutine.resume(co)

return v

end

end

for i in seq(4) do

print(i)

end

执行

lua seq_generator.lua

1

2

3

4

时间: 2024-11-04 20:58:47

Lua 协程 coroutine的相关文章

Lua 协程coroutine

协程和一般多线程的区别是,一般多线程由系统决定该哪个线程执行,是抢占式的,而协程是由每个线程自己决定自己什么时候不执行,并把执行权主动交给下一个线程. 协程是用户空间线程,操作系统其存在一无所知,所以需要用户自己去做调度,用来执行协作式多任务非常合适. 线程和协同程序的主要不同在于:在多处理器情况下,多线程程序同时运行多个线程:而协同程序是通过协作来完成,在任一指定时刻只有一个协同程序在运行,并且这个正在运行的协同程序只在必要时才会被挂起.这样Lua的协程就不能利用现在多核技术了. (一)Cor

(zt)Lua的多任务机制——协程(coroutine)

原帖:http://blog.csdn.net/soloist/article/details/329381 并发是现实世界的本质特征,而聪明的计算机科学家用来模拟并发的技术手段便是多任务机制.大致上有这么两种多任务技术,一种是抢占式多任务(preemptive multitasking),它让操作系统来决定何时执行哪个任务.另外一种就是协作式多任务(cooperative multitasking),它把决定权交给任务,让它们在自己认为合适的时候自愿放弃执行.这两种多任务方式各有优缺点,前者固

LUA协程

一  LUA 协程函数 1 resume local  status, returnvs = coroutine.resume(co, params) co 为 所要启动的协程. 第一次调用resume时,参数是协程函数入口的参数,协程函数调用coroutine.yield之后交出控制权 后面继续调用resume恢复该协程时, 参数是作为上次调用coroutine.yield处的返回值 status表明此次调用co是否有运行,co的状态. 若resume返回时co未结束,returnvs为cor

[转]-Lua协程的实现

协程是个很好的东西,它能做的事情与线程相似,区别在于:协程是使用者可控的,有API给使用者来暂停和继续执行,而线程由操作系统内核控制:另 外,协程也更加轻量级.这样,在遇到某些可能阻塞的操作时,可以使用暂停协程让出CPU:而当条件满足时,可以继续执行这个协程.目前在网络服务器领域, 使用Lua协程最好的范例就是ngx_lua了,我自己的项目qnode也是借助Lua协程的概念:每一个qnode中的微进程底层对应一个Lua协程, 这样底层的异步操作可以在使用者使用同步的方式写出来.Coool. 来看

lua协程实现

协程是个很好的东西,它能做的事情与线程相似,区别在于:协程是使用者可控的,有API给使用者来暂停和继续执行,而线程由操作系统内核控制:另外,协程也更加轻量级.这样,在遇到某些可能阻塞的操作时,可以使用暂停协程让出CPU:而当条件满足时,可以继续执行这个协程.目前在网络服务器领域,使用Lua协程最好的范例就是ngx_lua了 来看看Lua协程内部是如何实现的. 本质上,每个Lua协程其实也是对应一个LuaState指针,所以其实它内部也是一个完整的Lua虚拟机-有完整的Lua堆栈结构,函数调用栈等

Unity协程(Coroutine)管理类——TaskManager工具分享

Unity协程(Coroutine)管理类--TaskManager工具分享 By D.S.Qiu 尊重他人的劳动,支持原创,转载请注明出处:http.dsqiu.iteye.com 在分享vp_Timer 中提到,没有继承的MonoBehaviour,没有Update,InVoke 和StartCoroutine的机制,vp_Timer就是提供了InVoke的机制,而且还可以统一管理.本篇D.S.Qiu要分享的TaskManager就是一个协程 管理类. TaskManager -- Unit

并发编程协程(Coroutine)之Gevent

Gevent官网文档地址:http://www.gevent.org/contents.html 基本概念 我们通常所说的协程Coroutine其实是corporate routine的缩写,直接翻译为协同的例程,一般我们都简称为协程. 在linux系统中,线程就是轻量级的进程,而我们通常也把协程称为轻量级的线程即微线程. 进程和协程 下面对比一下进程和协程的相同点和不同点: 相同点:我们都可以把他们看做是一种执行流,执行流可以挂起,并且后面可以在你挂起的地方恢复执行,这实际上都可以看做是con

lua的协程(coroutine)

协程和多线程下的线程类似:有自己的堆栈,自己的局部变量,有自己的指令指针,但是和其他协程程序共享全局变量等信息.线程和协程的主要不同在于:多处理器的情况下,概念上来说多线程是同时运行多个线程,而协程是通过协作来完成,任何时刻只有一个协程程序在运行.并且这个在运行的协程只有明确被要求挂起时才会被挂起 你可以使用coroutine.create来创建协程: co = coroutine.create(function () print("hi") end) 协程有三种状态:挂起,运行,停止

lua协程----ngx-lua线程学习笔记

--[[ - @desc lua数据输出 - @param string 字符串 - return string --]] function dump(v) if not __dump then function __dump(v, t, p) local k = p or ""; if type(v) ~= "table" then table.insert(t, k .. " : " .. tostring(v)); else for key