- class cobald.daemon.runners.thread_runner.ThreadRunner(asyncio_loop: AbstractEventLoop)
Runner for subroutines with
Active payloads are not cancelled when the runner is closed. Only program termination forcefully cancels leftover payloads.
- async aclose()
Shut down this runner
- flavour: Any = <module 'threading' from '/home/docs/.asdf/installs/python/3.11.6/lib/python3.11/threading.py'>
- async manage_payloads()
Implementation of managing payloads when
This method must continuously execute payloads sent to the runner. It may only return when
stop()is called or if any orphaned payload return or raise. In the latter case,
OrphanedReturnor the raised exception must re-raised by this method.
payloadfor background execution in a threadsafe manner
payloadas an orphaned background task as soon as possible. It is an error for
payloadto return or raise anything without handling it.
payloadand return its result in a threadsafe manner
payloadas soon as possible, blocking until completion. Should
payloadreturn or raise anything, it is propagated to the caller.