consign.worker.wait Module#

Functions#

coroutine([debug, create_callback, ...])

consign的核心，coroutine使得被修饰函数可以以协程的方式被执行

pass_func()

wait(task, *[, time_out])

wait阻塞等待一个Task任务完成，并在期间参与工作

Classes#

AutoCallback(callback, exceptions)

CoroutineWorker([work_area_name, work_area])

CoroutineWorker协程Worker，CoroutineWorker能够以并发的方式执行特定的协程函数，是所有Worker的基石

Empty

Exception raised by Queue.get(block=0)/get_nowait().

Supervisor(task)

wait 的底层实现

Task(order)

TaskResult(value)

An enumeration.

TaskState(value)

An enumeration.

WorkArea([name])

WorkArea是consign的基石，负责规划Worker和协程

Class Inheritance Diagram#

Inheritance diagram of consign.worker.wait.Supervisor