class Concurrent::Future

def ns_initialize(value, opts)
  super
  @state = :unscheduled
  @task = opts[:__task_from_block__]
  @executor = Options.executor_from_options(opts) || Concurrent.global_io_executor
  @args = get_arguments_from(opts)
end