class Sync::Future(T)

• Sync::Future(T)
• Reference
• Object

Overview

An object that will eventually hold a value.

You can for example delegate the computation of a value to another fiber, that can resolve is asynchronously, without blocking the current fiber, that can regularly poll for the value, or explicitly wait until the value is resolved.

For example:

result = Future(Int32).new

spawn do
  result.set(compute_some_value)
rescue exception
  result.fail(exception)
end

loop do
  do_something

  if value = result.get?
    p value
    break
  end
end

Defined in:

future.cr

Constructors

• .new

Instance Method Summary

• #fail(reason : Exception | String | Nil = nil) : Nil

  Sets the future as failed, then wakes up pending fibers.

• #get : T

  Returns the value.

• #get? : T | Nil

  Returns the value if resolved, otherwise returns nil immediately.

• #set(value : T) : T

  Sets the value, then wakes up pending fibers.

Constructor Detail

Instance Method Detail