Class ThreadScheduler (1.0.2)

ThreadScheduler(executor=None)

A thread pool-based scheduler.

This scheduler is useful in typical I/O-bound message processing.

Parameter
Name	Description
`executor`	`concurrent.futures.ThreadPoolExecutor` An optional executor to use. If not specified, a default one will be created.

Properties

Queue: A thread-safe queue used for communication between callbacks and the scheduling thread.

schedule(callback, *args, **kwargs)

Schedule the callback to be called asynchronously in a thread pool.

Parameter
Name	Description
`callback`	`Callable` The function to call.

shutdown()

Shuts down the scheduler and immediately end all pending callbacks.