Method: Concurrent::Future#initialize

Defined in:

lib/concurrent-ruby/concurrent/future.rb

#initialize(opts = {}) { ... } ⇒ Future

Create a new Future in the :unscheduled state.

Parameters:

• opts (Hash) (defaults to: {}) —

  the options used to define the behavior at update and deref and to specify the executor on which to perform actions

Options Hash (opts):

• :executor (Executor) —

  when set use the given Executor instance. Three special values are also supported: :io returns the global pool for long, blocking (IO) tasks, :fast returns the global pool for short, fast operations, and :immediate returns the global ImmediateExecutor object.

• :dup_on_deref (Boolean) — default: false —

  Call #dup before returning the data from Concern::Obligation#value

• :freeze_on_deref (Boolean) — default: false —

  Call #freeze before returning the data from Concern::Obligation#value

• :copy_on_deref (Proc) — default: nil —

  When calling the Concern::Obligation#value method, call the given proc passing the internal value as the sole argument then return the new value returned from the proc.

• :args (object, Array) —

  zero or more arguments to be passed the task block on execution

Yields:

• the asynchronous operation to perform

Raises:

• (ArgumentError) —

  if no block is given

# File 'lib/concurrent-ruby/concurrent/future.rb', line 33

def initialize(opts = {}, &block)
  raise ArgumentError.new('no block given') unless block_given?
  super(NULL, opts.merge(__task_from_block__: block), &nil)
end