class Concurrent::RubyThreadPoolExecutor::Worker

@!visibility private

Public Class Methods

new(pool) click to toggle source

# File lib/concurrent/executor/ruby_thread_pool_executor.rb, line 295
def initialize(pool)
  # instance variables accessed only under pool's lock so no need to sync here again
  @queue  = Queue.new
  @pool   = pool
  @thread = create_worker @queue, pool, pool.idletime
end

Public Instance Methods

<<(message) click to toggle source

# File lib/concurrent/executor/ruby_thread_pool_executor.rb, line 302
def <<(message)
  @queue << message
end

kill() click to toggle source

# File lib/concurrent/executor/ruby_thread_pool_executor.rb, line 310
def kill
  @thread.kill
end

stop() click to toggle source

# File lib/concurrent/executor/ruby_thread_pool_executor.rb, line 306
def stop
  @queue << :stop
end