juturna.transport.threads package

Module contents

class juturna.transport.threads.ThreadingTransport

Bases: object

Default transport backend, based on real OS threads.

This backend preserves the current concurrency model of Node: every worker runs on its own threading.Thread, and queues are backed by queue.Queue.

capabilities: ClassVar[frozenset[str]] = frozenset({'shared_fs'})

is_current(handle: WorkerHandle) → bool

new_condition() → _ThreadCondition

new_event() → _ThreadEvent

new_lock() → _ThreadLock

new_queue(maxsize: int = 0, local: bool = False) → _ThreadQueue

node_scope(shared: bool) → AbstractContextManager

remote_destination(node_name: str) → Any

spawn(target: Callable[[], None], name: str, daemon: bool = True) → _ThreadWorker