consign package#

consign Package#

Functions#

asleep(secs)

协程的sleep函数,休眠一定时间

chain_reaction(func)

chain_reaction使得嵌套协程函数可以以链式的方式运行.

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

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

repeated_call(debug)

repeated_call函数/修饰器可以将一个函数修饰成闭包,使得函数以有参形式调用后可以再一次被无参调用

wait(task, *[, time_out])

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

Classes#

AsyncWorker([work_area_name, work_area])

AsyncWorker异步协程Worker,AsyncWorker能够创建线程以应对耗时的阻塞IO,基于CoroutineWorker

ContextVar

CoroutineWorker([work_area_name, work_area])

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

Supervisor(task)

wait 的底层实现

WorkArea([name])

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

Class Inheritance Diagram#

Inheritance diagram of consign.worker.asyncworker.AsyncWorker, consign.worker.coroutineworker.CoroutineWorker, consign.worker.wait.Supervisor, consign.workarea.workarea.WorkArea

Subpackages#