diff options
Diffstat (limited to 'kombu/async/semaphore.py')
| -rw-r--r-- | kombu/async/semaphore.py | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/kombu/async/semaphore.py b/kombu/async/semaphore.py index 66015dc3..af40cc03 100644 --- a/kombu/async/semaphore.py +++ b/kombu/async/semaphore.py @@ -43,8 +43,11 @@ class LaxBoundedSemaphore(object): self._pop_waiter = self._waiting.popleft def acquire(self, callback, *partial_args, **partial_kwargs): - """Acquire semaphore, applying ``callback`` if - the resource is available. + """Acquire semaphore. + + This will immediately apply ``callback`` if + the resource is available, otherwise the callback is suspended + until the semaphore is released. Arguments: callback (Callable): The callback to apply. |