ThreadedExecutor

class chancy.executors.thread.ThreadedExecutor(worker, queue)

Bases: ConcurrentExecutor

An Executor which uses a thread pool to run its jobs.

This executor is useful for running I/O-bound jobs concurrently without the overhead of separate processes. It’s not suitable for CPU-bound tasks due to Python’s Global SubInterpreter Lock (GIL).

When working with existing asyncio code, it’s often easier and more efficient to use the AsyncExecutor instead, as it can run a very large number of jobs concurrently.

To use this executor, simply pass the import path to this class in the executor field of your queue configuration or use the Executor shortcut:

async with Chancy("postgresql://localhost/postgres") as chancy:
    await chancy.declare(
        Queue(
            name="default",
            executor=Chancy.Executor.Threaded,
        )
    )

Parameters:

• worker – The worker instance associated with this executor.

• queue – The queue that this executor is associated with.

job_wrapper(job: QueuedJob) → tuple[QueuedJob, Any]

This is the function that is actually started by the thread pool executor. It’s responsible for setting up necessary limits, running the job, and returning the result.

async push(job: QueuedJob) → Future

Push a job onto the job pool.

async stop()

Stop the executor, giving it a chance to clean up any resources it may have allocated to running jobs.

It is not safe to use the executor after this method has been called.