ruby脚本示例代码

if __FILE__ == $0 $:.unshift File.join(File.dirname(__FILE__), '..') require 'eventmachine' # TODO: real tests # TODO: pass in one object instead of two? .each{ |iter| puts iter.current; iter.next } # TODO: support iter.pause/resume/stop/break/continue? # TODO: create some exceptions instead of using RuntimeError # TODO: support proc instead of enumerable? EM::Iterator.new(proc{ return queue.pop }) EM.run{ EM::Iterator.new(1..50).each{ |num,iter| p num; iter.next } EM::Iterator.new([1,2,3], 10).each{ |num,iter| p num; iter.next } i = EM::Iterator.new(1..100, 5) i.each(proc{|num,iter| p num.to_s iter.next }, proc{ p :done }) EM.add_timer(0.03){ i.concurrency = 1 } EM.add_timer(0.04){ i.concurrency = 3 } EM::Iterator.new(100..150).map(proc{ |num,iter| EM.add_timer(0.01){ iter.return(num) } }, proc{ |results| p results }) EM::Iterator.new(%w[ pwd uptime uname date ], 2).inject({}, proc{ |hash,cmd,iter| EM.system(cmd){ |output,status| hash[cmd] = status.exitstatus == 0 ? output.strip : nil iter.return(hash) } }, proc{ |results| p results }) }end