class documentation


Method __aenter__ We can be used as an asynchronous context manager.
Method __aexit__ Undocumented
Method __init__ Undocumented
Method acquire Undocumented
Method release Undocumented
Method run Acquire, run, release.
Instance Variable waiting Undocumented
Method _releaseAndReturn Undocumented

We can be used as an asynchronous context manager.

def __aexit__(self, __exc_type: Optional[Type[BaseException]], __exc_value: Optional[BaseException], __traceback: Optional[TracebackType]) -> Deferred[Literal[False]]: (source)


def run(self_319AA2A8B18F4B8EA296D75F279EB07F: _ConcurrencyPrimitiveT, f: Callable[..., _DeferredResultT], *args: object, **kwargs: object) -> Deferred[_DeferredResultT]: (source)

Acquire, run, release.

This method takes a callable as its first argument and any number of other positional and keyword arguments. When the lock or semaphore is acquired, the callable will be invoked with those arguments.

The callable may return a Deferred; if it does, the lock or semaphore won't be released until that Deferred fires.

Deferred[_DeferredResultT]Deferred of function result.
def _releaseAndReturn(self, r: _T) -> _T: (source)