asyncio_taskpool package

Top-level convenience imports.

Subpackages

• asyncio_taskpool.control package
  • Submodules
    • asyncio_taskpool.control.client module
      • ControlClient
      • TCPControlClient
      • UnixControlClient
    • asyncio_taskpool.control.server module
      • ControlServer
      • TCPControlServer
      • UnixControlServer

Submodules

• asyncio_taskpool.exceptions module
  • AlreadyCancelled
  • AlreadyEnded
  • CommandError
  • HelpRequested
  • InvalidGroupName
  • InvalidTaskID
  • NotCoroutine
  • NotCoroutineFunction
  • ParserError
  • ParserNotInitialized
  • PoolException
  • PoolIsClosed
  • PoolIsLocked
  • ServerException
  • ServerNotInitialized
  • SubParsersNotInitialized
  • TaskEnded
  • TaskGroupAlreadyExists
  • TaskGroupNotFound
  • TaskNotFound
• asyncio_taskpool.pool module
  • BaseTaskPool
    • BaseTaskPool.cancel()
    • BaseTaskPool.cancel_all()
    • BaseTaskPool.cancel_group()
    • BaseTaskPool.flush()
    • BaseTaskPool.gather_and_close()
    • BaseTaskPool.get_group_ids()
    • BaseTaskPool.is_full
    • BaseTaskPool.is_locked
    • BaseTaskPool.lock()
    • BaseTaskPool.num_cancelled
    • BaseTaskPool.num_ended
    • BaseTaskPool.num_running
    • BaseTaskPool.pool_size
    • BaseTaskPool.unlock()
    • BaseTaskPool.until_closed()
  • SimpleTaskPool
    • SimpleTaskPool.func_name
    • SimpleTaskPool.start()
    • SimpleTaskPool.stop()
    • SimpleTaskPool.stop_all()
  • TaskPool
    • TaskPool.apply()
    • TaskPool.doublestarmap()
    • TaskPool.map()
    • TaskPool.starmap()
• asyncio_taskpool.queue_context module
  • Queue
    • Queue.item_processed()