angelos.lib.worker

Asynchronous multithreaded worker.

class angelos.lib.worker.Worker(name, ioc, executor=None, new=True)

Bases: angelos.lib.ioc.ContainerAware

Worker with a private thread, loop and executor.

call_soon(callback, *args, context=None)

Threadsafe version of call_soon.

property loop

Access to the loop object.

run_coroutine(coro)

Threadsafe version of run_coroutine.

run_in_executor(callback, *args, **kwargs)

Add a function/method/coroutine to the event loop.

property thread

Accress to the thread object.

property workers

Access to all workers.