AsyncSourceAsyncWorkerPoolWorker

class Worker

A handle to the work being done.

Definitions

def call(work)

Call the work and notify the scheduler when it is done.

Implementation

def call(work)
	promise = Promise.new(work)
	
	@work.push(promise)
	
	begin
		return promise.wait
	ensure
		promise.cancel
	end
end

Discussion