buildgrid.server.threading module

class buildgrid.server.threading.ContextThreadPoolExecutor(max_workers: int | None = None, thread_name_prefix: str = '', initializer: Callable[[], Any] | None = None, initargs: tuple[Any, ...] = (), immediate_copy: bool = False)

Bases: ThreadPoolExecutor

submit(fn: ~typing.Callable[[~_P], ~buildgrid.server.threading._T], /, *args: ~typing.~_P, **kwargs: ~typing.~_P) → Future[_T]

Submits a callable to be executed with the given arguments.

Schedules the callable to be executed as fn(*args, **kwargs) and returns a Future instance representing the execution of the callable.

Returns:

A Future representing the given call.

class buildgrid.server.threading.ContextThread(target: Callable[[_P], _T], name: str | None = None, args: Iterable[Any] = (), kwargs: dict[str, Any] | None = None, *, daemon: bool | None = None)

Bases: Thread

class buildgrid.server.threading.ContextWorker(target: Callable[[Event], None], name: str | None = None, *, on_shutdown_requested: Callable[[], None] | None = None)

Bases: object

is_alive() → bool

start() → None

stop() → None

wait(timeout: float | None = None) → None