Parent

Methods

Included Modules

Files

Class/Module Index [+]

Quicksearch

Concurrent::RubyThreadPoolExecutor::Worker

@!visibility private

Public Class Methods

new(pool) click to toggle source
# File lib/concurrent/executor/ruby_thread_pool_executor.rb, line 278
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 285
def <<(message)
  @queue << message
end
kill() click to toggle source
# File lib/concurrent/executor/ruby_thread_pool_executor.rb, line 293
def kill
  @thread.kill
end
stop() click to toggle source
# File lib/concurrent/executor/ruby_thread_pool_executor.rb, line 289
def stop
  @queue << :stop
end

[Validate]

Generated with the Darkfish Rdoc Generator 2.