Lua 学习笔记（九）协同程序（线程thread）

 1 --管道与过滤器filter
 2 --生产者与消费者通过过滤器进行值传递
 3 --这种模式通过消费者驱动生产者进行产生。
 4 
 5 --计数器函数
 6 function getCount( x )
 7      return function()
 8           x=x+1
 9           return x
10      end
11 end
12 --创建闭合计数器
13 local count = getCount(0)
14 --发送新值
15 function send(x)
16      coroutine.yield(x)
17 end
18 --启动一个协同程序
19 function receive( pro )
20      local status,value = coroutine.resume( pro )
21      return value
22 end
23 --生产者
24 function producter()
25      while true do
26           send( count() )
27      end
28 end
29 --过滤器，接受一个生产者
30 function filter( pro )
31      local x = 0
32      return function()
33           while true do
34                x = receive( pro )
35                send(x)
36           end
37      end
38 end
39 --消费者，接受一个生产者协同程序及控制条件，控制条件防止死循环
40 --假设有100个消费者，驱动生产者来生产
41 function consumer( pro,num )
42      local x = 0
43      while x < num do
44           x = receive( pro )
45           print( x )
46      end
47 end
48 
49 local pro = coroutine.create( producter )
50 local fil = coroutine.create( filter( pro ) )
51 consumer( fil,100 )
52 
53 print( "消费者协同程序状态：",coroutine.status(pro) )
54 print( "生产者协同程序状态：",coroutine.status(fil) )