

def acquire(self, _concoord_command):
    with self.__atomic:
        self.__count -= 1
        if (self.__count < 0):
            self.__queue.append(_concoord_command)
            raise BlockingReturn()
        else:
            return True

dataset/ETHPy150Open denizalti/concoord/concoord/threadingobject/dsemaphore.py DSemaphore.acquire/original