betty.job.executor.threading module

Job execution using thread pools.

final class betty.job.executor.threading.ThreadPoolExecutor

Bases: Executor

A job executor using a thread pool.

__init__(scheduler: Scheduler, *, async_concurrency: int = 1, threading_concurrency: int = 1)

async cancel() → None

Stop the executor and cancel any pending jobs.

async complete() → None

Wait for any pending jobs to complete and stop the executor.

async start() → None

Start working on jobs.