dbxs.adapters.dbapi_twisted.ExclusiveWorkQueue

class documentation

class ExclusiveWorkQueue: (source)

View In Hierarchy

Undocumented

Method __del__ When garbage collected make sure we kill off our underlying thread.
Method perform Perform the given work on the underlying thread, delivering the result back to the main thread with ExclusiveWorkQueue._deliver.
Method quit Allow this thread to stop, and invalidate this ExclusiveWorkQueue by removing its _worker attribute.
Method worker Assert that the worker should still be present, then return it (invalidating it if the flag is passed).
Class Variable _deliver Undocumented
Instance Variable _worker Undocumented
def __del__(self): (source)

When garbage collected make sure we kill off our underlying thread.

def perform(self, work: Callable[[], _T]) -> Deferred[_T]: (source)

Perform the given work on the underlying thread, delivering the result back to the main thread with ExclusiveWorkQueue._deliver.

def quit(self): (source)

Allow this thread to stop, and invalidate this ExclusiveWorkQueue by removing its _worker attribute.

def worker(self, invalidate: bool = False) -> IExclusiveWorker: (source)

Assert that the worker should still be present, then return it (invalidating it if the flag is passed).

_deliver: Callable[[F], None] = (source)

Undocumented

_worker: IExclusiveWorker | None = (source)

Undocumented