coroutine我自己的理解是伪中断。在调用coroutine.yeild时就会自动调用正在wait中的coroutine.resume。并且会把yeild里面的参数按顺序作为resume的第二、三等返回值返回。resume第一返回值是coroutine的状态。
function receive(prod)local status, value &＃61; coroutine.resume(prod)return value
endfunction send(x)coroutine.yield(x)
endfunction producer()local i &＃61; 0return coroutine.create(function()while true dolocal x &＃61; ii &＃61; i &＃43; 1send(x)endend)
endfunction filter(prod)return coroutine.create(function()for line &＃61; 1, math.huge dolocal x &＃61; receive(prod)x &＃61; string.format("%5d %s", line, x)send(x)endend)
endfunction consumer(prod)while true dolocal x &＃61; receive(prod)print("received:" .. x)end
endconsumer(filter(producer()))
抄袭下一个现成的代码&＃xff0c;这个代码打印如下。
1 0
2 1
...
原理就是先执行producer&＃xff0c;filter 创建couroutine&＃xff0c;consumer到receive(A)卡死在resume上&＃xff0c;同时couroutine触发了filter里面的receive(B)&＃xff0c;couroutine触发了producer的send&＃xff08;0&＃xff09;&＃xff0c;yeild这时就执行到了最近的receive&＃xff08;B&＃xff09;中的resume并且把0传给了value。filter继续执行&＃xff0c;将 1 0 传给send&＃xff0c;这时send把值给receive&＃xff08;A&＃xff09;,一个循环结束。
虽然这个看起来是多个函数之间的同步&＃xff0c;但是实际上还是一个线程上的同步。主界面还是会卡死。so需要在线程中做这样的同步。
京公网安备 11010802041100号