Method task_done

src/inventory.py:50–56

(self, hashId)

        self.lock = RLock()

    def task_done(self, hashId):
        Queue.Queue.task_done(self)
        try:
            with self.lock:
                del self.pending[hashId]
        except KeyError:
            pass

    def get(self, block=True, timeout=None):
        retval = Queue.Queue.get(self, block, timeout)