alphatwirl.concurrently.TaskPackageDropbox

class alphatwirl.concurrently.TaskPackageDropbox(workingArea, dispatcher, sleep=5)

A drop box for task packages.

It puts task packages in a working area and dispatches runners that execute the tasks.

__init__(workingArea, dispatcher, sleep=5)

Initialize self. See help(type(self)) for accurate signature.

Methods

__init__(workingArea, dispatcher[, sleep])	Initialize self.
close()
open()
poll()	Return pairs of package indices and results of finished tasks.
put(package)	Put a package.
put_multiple(packages)	Put multiple packages.
receive()	Return pairs of package indices and results.
receive_one()	Return a pair of a package index and result.
terminate()