alphatwirl.concurrently.CommunicationChannel0

class alphatwirl.concurrently.CommunicationChannel0(progressbar=True)[source]

A communication channel for the single process mode

An alternative to CommunicationChannel. However, unlike CommunicationChannel, this class does not send tasks to workers. Instead, it directly executes tasks.

This class has the same interface as the class CommunicationChannel. When this class is used as a substitute for CommunicationChannel, the tasks will be sequentially executed in the foreground.

Parameters:progressbar (bool) – Progress bars from atpbar will be turned off if False.
__init__(progressbar=True)[source]

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

Methods

__init__([progressbar]) Initialize self.
begin()
end()
put(task, *args, **kwargs)
put_multiple(task_args_kwargs_list)
receive()
receive_all()
receive_finished()
receive_one()
terminate()