class documentation

class twisted.internet.defer._ConcurrencyPrimitive: (source)

Known subclasses: twisted.internet.defer.DeferredLock, twisted.internet.defer.DeferredSemaphore

View In Hierarchy


Method __init__ Undocumented
Instance Variable waiting Undocumented
Method run Acquire, run, release.
Method __aenter__ We can be used as an asynchronous context manager.
Method __aexit__ Undocumented
Method _releaseAndReturn Undocumented
def __init__(self): (source)


waiting = (source)


(type: list)
def _releaseAndReturn(self, r): (source)


def run(*args, **kwargs): (source)

Acquire, run, release.

This function 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.

ReturnsDeferred of function result.
def __aenter__(self): (source)

We can be used as an asynchronous context manager.

def __aexit__(self, exc_type, exc_val, exc_tb): (source)


API Documentation for Twisted, generated by pydoctor 20.12.1 at 2021-02-28 19:53:36.