Lua编程示例(八):生产者-消费者问题

 更新时间:2015年07月09日 10:51:36   投稿:junjie  
这篇文章主要介绍了Lua编程示例(八):生产者-消费者问题,本文直接给出实例代码,需要的朋友可以参考下

这个问题是比较经典的啦,基本所有语言的多线程都会涉及到,但是没想到Lua的这个这么复杂 抓狂
  看了好长时间才算看明白,先上个逻辑图:

   开始时调用消费者,当消费者需要值时,再调用生产者生产值,生产者生产值后停止,直到消费者再次请求。设计为消费者驱动的设计。
   图画的不太好,可以先将Filter遮住,它是过滤器对两个程序之间传递的信息进行处理。去掉Filter逻辑就更清晰些了,就是两个“线程”(其实是两个协同程序)互相调用。resume回到yield处开始,支持嵌套,返回到栈顶的yield位置。yield是非阻塞的“线程同步”。这到有点像linux里的管道通信。


 

 function receive(prod)
 print("receive is called")
 local status,value = coroutine.resume(prod)
 return value
end

function send(x,prod)
 print("send is called")
 return coroutine.yield(x)
end

function producer()
 return coroutine.create(function ()
 print("producer is called")
 while true do
 print("producer run again")
  local x = io.read()
  send(x)
 end
 end)
end

function filter(prod)
 return coroutine.create(function ()
 for line = 1,1000 do
  print("enter fliter "..line)
  local x = receive(prod)
  print("receive in filter finished")
  x= string.format("%5d %s",line,x)
  send(x,prod)
 end
 end)
end

function consumer(prod)
 print("consumer is called")
 while true do
 print("consumer run again")
 local x = receive(prod)
 print("retrun customer")
 io.write(x,"\n")
 end
end

p = producer()
f=filter(p)
consumer(f)


运行结果:

consumer is called
consumer run again
receive is called
enter fliter 1
receive is called
producer is called
producer run again
fsy
send is called
receive in filter finished
send is called
retrun customer
  1 fsy
consumer run again
receive is called
enter fliter 2
receive is called
producer run again
gaga
send is called
receive in filter finished
send is called
retrun customer
  2 gaga
consumer run again
receive is called
enter fliter 3
receive is called
producer run again
......

相关文章

  • Lua判断一个目录或文件是否存在的方法

    Lua判断一个目录或文件是否存在的方法

    这篇文章主要介绍了Lua判断一个目录或文件是否存在的方法,Lua中可以使用io.open判断文件或目录是否存在,本文总结了判断方法,并给出了一个自定义函数,需要的朋友可以参考下
    2015-04-04
  • 基于 aLi Lua Web Server 的一个简单例子

    基于 aLi Lua Web Server 的一个简单例子

    这篇文章主要介绍了基于 aLi Lua Web Server 的一个简单例子的代码,非常简单,推荐给大家。
    2015-03-03
  • Lua和C语言的交互详解

    Lua和C语言的交互详解

    这篇文章主要介绍了Lua和C语言的交互详解,Lua和C语言通过栈完成交互,本文结合代码实例详细讲解了交互的方法,需要的朋友可以参考下
    2014-09-09
  • Lua中的源代码预编译浅析

    Lua中的源代码预编译浅析

    这篇文章主要介绍了Lua中的源代码预编译浅析,Lua确实允许在运行源代码之前,将源代码预编译成一种中间形式(类比Python的.pyc),需要的朋友可以参考下
    2014-09-09
  • Lua学习笔记之函数、变长参数、closure(闭包)、select等

    Lua学习笔记之函数、变长参数、closure(闭包)、select等

    这篇文章主要介绍了Lua学习笔记之函数、变长参数、closure(闭包)、select等,本文着重讲解了这些特性的用法,并给出代码实例,需要的朋友可以参考下
    2015-04-04
  • Lua脚本自动生成APK包

    Lua脚本自动生成APK包

    这篇文章主要介绍了Lua脚本自动生成APK包,本文脚本适用于cocos2dx+lua的项目,需要的朋友可以参考下
    2015-04-04
  • Lua中的loadfile、dofile、loadstring、require用法实例

    Lua中的loadfile、dofile、loadstring、require用法实例

    这篇文章主要介绍了Lua中的loadfile、dofile、loadstring、require用法实例,需要的朋友可以参考下
    2015-04-04
  • Lua中的迭代器浅析

    Lua中的迭代器浅析

    这篇文章主要介绍了Lua中的迭代器浅析,本文先是讲解了什么是迭代器,然后给出了自己写一个迭代器的示例,最后介绍了迭代器的调用方法,需要的朋友可以参考下
    2014-09-09
  • 详解Lua中的变量相关知识点

    详解Lua中的变量相关知识点

    这篇文章主要介绍了Lua中的变量相关知识点,是Lua入门中的基础知识,需要的朋友可以参考下
    2015-05-05
  • Lua中获取table长度问题探讨

    Lua中获取table长度问题探讨

    这篇文章主要介绍了Lua中获取table长度问题探讨,本文非常深入的研究了Lua中table长度的获取问题,分析了各种各样的情况,需要的朋友可以参考下
    2015-04-04

最新评论