Sha256: 8f4997c6a9a3225c79845253af7fe8cb356cdccd17ebedb872471a07649f2324
Contents?: true
Size: 652 Bytes
Versions: 4
Compression:
Stored size: 652 Bytes
Contents
# # Usage: # drbqs-server server.rb -- 30 50 # drbqs-server server.rb -- 100 500 --step 100 # require_relative 'sum.rb' DRbQS.option_parser do |opt, hash| opt.on('--step NUM', Integer) do |v| hash[:step] = v end end DRbQS.define_server do |server, argv, opts| start_num = (argv[0] || 10).to_i end_num = (argv[1] || 100).to_i step_num = opts[:step] || 10 server.task_generator(:generate => 10) do |tgen| start_num.step(end_num, step_num).with_index do |i, count| create_add(Sum.new(i - 10, i), :exec, group: (count.even? ? :even : :odd)) do |srv, ret| puts "Receive: #{ret.inspect}" end end end end
Version data entries
4 entries across 4 versions & 1 rubygems
Version | Path |
---|---|
drbqs-0.1.1 | examples/group/server.rb |
drbqs-0.1.0 | examples/group/server.rb |
drbqs-0.0.19 | example/group/server.rb |
drbqs-0.0.18 | example/group/server.rb |