Sha256: 565548614745af95012b82fb754cd225207453fff063154069a8d89ca2dde8f5
Contents?: true
Size: 1.33 KB
Versions: 69
Compression:
Stored size: 1.33 KB
Contents
require 'thread'
module Celluloid
# Celluloid::Future objects allow methods and blocks to run in the
# background, their values requested later
class Future
# Create a new Celluloid::Future object, allowing a block to be computed in
# the background and its return value obtained later
def initialize(*args, &block)
@lock = Mutex.new
@value_obtained = false
@runner = Runner.new(*args, &block)
@runner.run!
end
# Obtain the value for this Future
def value
@lock.synchronize do
unless @value_obtained
@value = @runner.value
@runner.terminate
@value_obtained = true
end
@value
end
end
alias_method :call, :value
# Inspect this Celluloid::Future
alias_method :inspect, :to_s
# Runner is an internal class which executes the given block/method
class Runner
include Celluloid
def initialize(*args, &block)
@args, @block = args, block
@called = nil
@error = nil
end
def run
@value = @block.call(*@args)
rescue Exception => error
@error = error
ensure
@called = true
signal :finished
end
def value
wait :finished unless @called
abort @error if @error
@value
end
end
end
end
Version data entries
69 entries across 69 versions & 2 rubygems