twisted.internet.defer._ConcurrencyPrimitive : API documentation

def __init__(self): (source)

overridden in twisted.internet.defer.DeferredSemaphore

Undocumented

waiting = (source)

Undocumented

(type: list)

def _releaseAndReturn(self, r): (source)

Undocumented

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.

Returns Deferred 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)

Undocumented

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