alphatwirl.concurrently.CommunicationChannel0

class alphatwirl.concurrently.CommunicationChannel0(**kwargs)[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.

__init__(**kwargs)

Methods

__init__(**kwargs)
begin()
end()
put(task, *args, **kwargs)
put_multiple(task_args_kwargs_list)
receive()
receive_all()
receive_finished()
receive_one()
terminate()