traits_futures.multithreading_context module

Context providing multithreading-friendly worker pools, events, and routers.

class traits_futures.multithreading_context.MultithreadingContext

Bases: traits_futures.i_parallel_context.IParallelContext

Context for multithreading, suitable for use with the TraitsExecutor.

close()

Do any cleanup necessary before disposal of the context.

property closed

True if this context is closed, else False.

event()

Return a shareable event suitable for this context.

Returns

event – An event that can be shared safely with workers.

Return type

event-like

message_router()

Return a message router suitable for use in this context.

Returns

message_router

Return type

MessageRouter

worker_pool(*, max_workers=None)

Provide a new worker pool suitable for this context.

Parameters

max_workers (int, optional) – Maximum number of workers to use. If not given, the choice is delegated to the ThreadPoolExecutor.

Returns

executor

Return type

concurrent.futures.Executor