threadpriorityqueue.py

import Queue
import thread
from threading import Lock
class ThreadPriorityQueue:
	"""A Queue like class where in the get function the thread 
	with lowest thread id from where get is being called gets priority.
	Not the one who called get first"""
	def __init__(self):
		self.dataqueue=Queue.Queue()
		self.itemlock=Lock()
		self.requestqueue=Queue.PriorityQueue()
	def put(self,item):
		self.itemlock.acquire()
		while True:
			try:
				id,q=self.requestqueue.get_nowait()
				q.put_nowait(item)
				break
			except Queue.Empty:
				self.dataqueue.put(item)
				break
			except:
				pass
		self.itemlock.release()
	def get(self,timeout=None):
		self.itemlock.acquire()
		try:
			v=self.dataqueue.get_nowait()
			self.itemlock.release()
			return v
		except:
			pass
		v=Queue.Queue(1)
		self.requestqueue.put((thread.get_ident(),v))
		self.itemlock.release()
		try:
			m=v.get(timeout=timeout)
			return m
		except:
			try:
				v.put_nowait(1)
			except Queue.Full:
				return v.get_nowait()