threads

Keep synchronous workers owned until their execution actually finishes.

class bedrock_server_manager.utils.threads.WorkerSnapshot

bedrock_server_manager.utils.threads.check_cancellation(cancellation_event: Event | None) → None

Stop a cooperative worker before its next unit of filesystem work.

bedrock_server_manager.utils.threads.copy_stream(source: IO[bytes], target: IO[bytes], cancellation_event: Event | None = None, *, on_chunk: Callable[[bytes], None] | None = None) → None

Copy in bounded chunks and check cancellation between reads and writes.

bedrock_server_manager.utils.threads.worker_snapshot() → WorkerSnapshot

Return metadata-only pressure for workers owned by the current loop.