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. 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
()