Package ganeti :: Module workerpool
[hide private]
[frames] | no frames]

Module workerpool

source code

Base classes for worker pools.

Classes [hide private]
  DeferTask
Special exception class to defer a task.
  NoSuchTask
Exception raised when a task can't be found.
  BaseWorker
Base worker class for worker pools.
  WorkerPool
Worker pool with a queue.
Variables [hide private]
  _TERMINATE = object()
  _DEFAULT_PRIORITY = 0

Imports: logging, threading, heapq, itertools, compat, errors