Class: Async::WorkerPool

Inherits:

Object

• Object
• Async::WorkerPool

Defined in:

lib/async/worker_pool.rb

Overview

A simple work pool that offloads work to a background thread.

Defined Under Namespace

Modules: BlockingOperationWait Classes: Promise, Worker

Instance Method Summary

• #call(work) ⇒ Object

  Offload work to a thread.

• #close ⇒ Object

  Close the work pool.

• #initialize(size: Etc.nprocessors) ⇒ WorkerPool constructor

  Create a new work pool.

Constructor Details

#initialize(size: Etc.nprocessors) ⇒ WorkerPool

Create a new work pool.

# File 'lib/async/worker_pool.rb', line 145

def initialize(size: Etc.nprocessors)
	@ready = ::Thread::Queue.new
	
	size.times do
		@ready.push(Worker.new)
	end
end

Instance Method Details

#call(work) ⇒ Object

Offload work to a thread.

# File 'lib/async/worker_pool.rb', line 168

def call(work)
	if ready = @ready
		worker = ready.pop
		
		begin
			worker.call(work)
		ensure
			ready.push(worker)
		end
	else
		raise RuntimeError, "No worker available!"
	end
end

#close ⇒ Object

Close the work pool. Kills all outstanding work.

# File 'lib/async/worker_pool.rb', line 154

def close
	if ready = @ready
		@ready = nil
		ready.close
		
		while worker = ready.pop
			worker.close
		end
	end
end