Method acquire

fastthreadpool/fastthreadpool.py:102–119

(self, blocking=True)

    #c cpdef bint acquire(self, bint blocking=True):
    def acquire(self, blocking=True):  #p
        #c cdef int wait
        if self._value >= 0:
            self._value -= 1
        if self._value >= 0:
            return False
        #c with nogil:
        if True:  #p
            #c wait = pythread.WAIT_LOCK if blocking else pythread.NOWAIT_LOCK
            wait = blocking  #p
            while True:
                #c if pythread.PyThread_acquire_lock(self._lock, wait):
                if self._lock.acquire(wait):  #p
                    break
                #c if wait == pythread.NOWAIT_LOCK:
                if not wait:  #p
                    return False
        return True

    #c cpdef void release(self):
    def release(self):  #p