Class: AsyncRequestReply::WorkersEngine::SimpleThreadPool

Inherits:

Object

• Object
• AsyncRequestReply::WorkersEngine::SimpleThreadPool

Defined in:

lib/async_request_reply/workers_engine/simple_thread_pool.rb

Constant Summary

MAX_THREADS =

2

@@jobs =

Queue.new

@@workers =

Array.new(MAX_THREADS) do
	Thread.new do
		loop do
			job = @@jobs.pop
			job.perform
		end
	end
end

Class Method Summary

• .perform_async(async_request_id) ⇒ Object

Class Method Details

.perform_async(async_request_id) ⇒ Object

# File 'lib/async_request_reply/workers_engine/simple_thread_pool.rb', line 15

def self.perform_async(async_request_id)
	@@jobs.push(::AsyncRequestReply::Worker.find(async_request_id))
end