require "drb" require "drb_observer" class ticker include drbobservable def initialize() thread.new { run } end def run loop do price = 10 print "current price: #{price}\n" notify_observers(time.now, price) sleep 1 end end end ticker = ticker.new() drb.start_service('druby://localhost:9001', ticker) puts 'press [return] to exit.' gets
用户登录
还没有账号?立即注册
用户注册
投稿取消
文章分类: |
|
还能输入300字

上传中....