协同进程实现生产者消费者

本文主要是介绍协同进程实现生产者消费者，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

代码及注释如下，使用print函数打印值和行号，可以看到代码的运行路径

--[[
resume协程，如果协程执行的过程中调用yield函数，则resume函数返回yield的参数
]]
function receive(prod)local status, value = coroutine.resume(prod)print(value,  debug.getinfo(1).currentline)return value
end--[[
若是在一个协程里调用yield函数，则会挂起当前协程
]]
function send(x)print(x,  debug.getinfo(1).currentline)coroutine.yield(x)
end--[[
创建一个协程；生产、停止生产、将生产的东西发给消费者
]]
function producer()return coroutine.create(function ()while true dolocal x = io.read() -- 生产商品print(x,  debug.getinfo(1).currentline)send(x) --停止生产、返回商品endend)
end--[[
消费者是一个循环，当需要消费的时候，就唤醒生产者
然后将商品打印出来
]]
function consumer(prod)while true dolocal x = receive(prod) -- 从生产者那里获得商品print(x,  debug.getinfo(1).currentline)io.write(x, "\n")end
endconsumer(producer())--[[
运行结果：
hello -- 输入
hello	27
hello	16
hello	7
hello	41
hello -- io.write输出
]]

这篇关于协同进程实现生产者消费者的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---