sample/drb/rindac.rb

   1 require 'drb/drb'
   2 require 'rinda/rinda'
   3
   4 uri = ARGV.shift || raise("usage: #{$0} <server_uri>")
   5
   6 DRb.start_service
   7 ts = Rinda::TupleSpaceProxy.new(DRbObject.new(nil, uri))
   8
   9 (1..10).each do |n|
  10   ts.write(['sum', DRb.uri, n])
  11 end
  12
  13 (1..10).each do |n|
  14   ans = ts.take(['ans', DRb.uri, n, nil])
  15   p [ans[2], ans[3]]
  16 end
  17