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字
上传中....
一生霸气帝王道