demo/ThreadQueue.py

   1 #!/usr/bin/python
   2
   3 import threading
   4 from threading import Lock
   5
   6 class ThreadQueue:
   7
   8     def __init__(self):
   9         self.items = []
  10         self.items_lock = Lock()
  11
  12     def append(self, new_item):
  13         self.items_lock.acquire()
  14         self.items.append(new_item)
  15         self.items_lock.release()
  16
  17     def pop(self):
  18         self.items_lock.acquire()
  19         if len(self.items):
  20             the_item = self.items.pop(0)
  21         else:
  22             the_item = None
  23         self.items_lock.release()
  24
  25         return the_item
  26
  27     def __len__(self):
  28         return len(self.items)