def enqueue(self, item):

        with self.lock:
            heapq.heappush(self.items, (item, self.count))
            self.count += 1
Decorator that activates manual transaction control. It just disables
dataset/ETHPy150Open ReactiveX/RxPY/rx/internal/priorityqueue.py/PriorityQueue.enqueue--crossover with--dataset/ETHPy150Open cloudera/hue/desktop/core/ext-py/Django-1.6.10/django/db/transaction.py/commit_manually