twisted.internet.defer._ConcurrencyPrimitive : API documentation

def __init__(self): (source)

overridden in twisted.internet.defer.DeferredSemaphore

Undocumented

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.

Method	__init__	Undocumented
Method	run	Acquire, run, release.
Method	_releaseAndReturn	Undocumented

twisted.internet.defer._ConcurrencyPrimitive(object) class documentation

`twisted.internet.defer._ConcurrencyPrimitive(object)` class documentation