consign.worker package

consign.worker Package

Functions

wait(task, *[, time_out])

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

Classes

AsyncWorker([work_area_name, work_area])	AsyncWorker异步协程Worker，AsyncWorker能够创建线程以应对耗时的阻塞IO，基于CoroutineWorker
CoroutineWorker([work_area_name, work_area])	CoroutineWorker协程Worker，CoroutineWorker能够以并发的方式执行特定的协程函数，是所有Worker的基石
Supervisor(task)	wait 的底层实现

Class Inheritance Diagram

Submodules

• consign.worker.asyncworker Module
  • Classes
    • AsyncWorker
      • AsyncWorker
  • Class Inheritance Diagram
• consign.worker.coroutineworker Module
  • Classes
    • CoroutineWorker
      • CoroutineWorker
  • Class Inheritance Diagram
• consign.worker.iterationcontext Module
  • Functions
    • except_and_pass_func
      • except_and_pass_func()
  • Classes
    • AutoCallback
      • AutoCallback
    • AutoClosing
      • AutoClosing
    • AutoReceipts
      • AutoReceipts
    • CheckChainReaction
      • CheckChainReaction
    • NoChainReactionError
      • NoChainReactionError
  • Class Inheritance Diagram
• consign.worker.wait Module
  • Functions
    • pass_func
      • pass_func()
    • wait
      • wait()
  • Classes
    • Supervisor
      • Supervisor
  • Class Inheritance Diagram