class Concurrent::Promises::BlockedTaskPromise

@abstract

def executor 

def executor
  @Executor
end

def initialize(delayed, blockers_count, default_executor, executor, args, &task) 

def initialize(delayed, blockers_count, default_executor, executor, args, &task)
  raise ArgumentError, 'no block given' unless block_given?
  super delayed, 1, Future.new(self, default_executor)
  @Executor = executor
  @Task     = task
  @Args     = args
end