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
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