class Newque::Future

Attributes

thread[R]

Public Class Methods

new(thread, timeout) click to toggle source
# File lib/newque/future.rb, line 7
def initialize thread, timeout
  @thread = thread
  @timeout = timeout
end

Public Instance Methods

get(limit=@timeout) click to toggle source
# File lib/newque/future.rb, line 12
def get limit=@timeout
  result = @thread.join(limit)
  if result.nil?
    # Timeout exceeded
    @thread.kill
    raise Timeout::Error
  end
  result.value
end
inspect() click to toggle source
# File lib/newque/future.rb, line 27
def inspect
  to_s
end
to_s() click to toggle source
# File lib/newque/future.rb, line 23
def to_s
  "<NewqueFuture timeout: #{@timeout} status: #{@thread.status}>"
end