Class: Rubee::ThreadPool

Inherits:

Object

• Object
• Rubee::ThreadPool

Includes:

Singleton

Defined in:

lib/rubee/async/thread_pool.rb

Constant Summary

THREADS_LIMIT =

Rubee::Configuration.get_threads_limit || 4

FIBERS_LIMIT =

Rubee::Configuration.get_fibers_limit || 4

Instance Method Summary

• #enqueue(task, args = {}) ⇒ Object
• #initialize ⇒ ThreadPool constructor

  A new instance of ThreadPool.

• #shutdown ⇒ Object

Constructor Details

#initialize ⇒ ThreadPool

Returns a new instance of ThreadPool.

# File 'lib/rubee/async/thread_pool.rb', line 9

def initialize
  @tasks = Queue.new
  @threads = []
  @running = true
  @mutex = Mutex.new

  spawn_workers
end

Instance Method Details

#enqueue(task, args = {}) ⇒ Object

# File 'lib/rubee/async/thread_pool.rb', line 18

def enqueue(task, args = {})
  @tasks << [task, args]
end

#shutdown ⇒ Object

# File 'lib/rubee/async/thread_pool.rb', line 22

def shutdown
  @running = false
  THREADS_LIMIT.times { @tasks << :shutdown } # Unblock threads
  @threads.each(&:join)
end