def acquire(self):
        with self.mutex:
            assert not self.poisoned
            assert self.nthreads >= 0
            self.nthreads += 1
Indicate that a thread will start putting into this queue.
dataset/ETHPy150Open beetbox/beets/beets/util/pipeline.py/CountedQueue.acquire