Contents

require_relative "../lib/worker"

async_adder = Worker.new do |a,b|
  sleep 0.25
  a+b
end

async_adder_puts = Worker.new do |a,b|
  sleep 0.25
  puts a+b
end

defer = async_adder.perform_async 1, 2
print "result is: "
puts defer.value

puts "random order putsing:"
5.times do |i|
  async_adder_puts.perform_async(i, 1)
end
async_adder_puts.join


no_value = Worker.new do
  sleep 0.1
  1
end

begin
  defer = no_value.perform_async
  defer.value!
rescue Worker::Defer::ValueError
  puts "no value"
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
worker-0.6.0	examples/async.rb