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