class Concurrent::Runnable::Context

def initialize(runner)

def initialize(runner)
  @runner = runner
  @thread = Thread.new(runner) do |runner|
    Thread.abort_on_exception = false
    runner.run
  end
  @thread.join(0.1) # let the thread start
end