Below is a simple skeleton for a python queue that is both fed by and consumed by multiple different threads.<\/p>\n
We run five threads, each of which populate a queue with random integers. <\/p>\n
Lastly, we sleep a couple of seconds between each put, to simulate an ongoing workload. <\/p>\n
Our popper thread, which reads items off the queue, will wait for an item in the queue for ten seconds before throwing an Queue Empty exception. We also print the thread name to prove each thread is doing its fair share of the workload.
\nIt will then loop until all the pusher threads have exited (as defined by our running count variable).<\/p>\n
\r\nimport Queue, random, time, thread, sys\r\nfrom threading import Thread\r\n\r\nplock = thread.allocate_lock()\r\nrlock = thread.allocate_lock()\r\n\r\nq = Queue.Queue()\r\nrunning = 0\r\n\r\n#-----------------------------------------\r\n\r\nclass pusher(Thread):\r\n def __init__(self):\r\n global q\r\n self.num = i\r\n Thread.__init__(self)\r\n self.q = q\r\n def run(self):\r\n global running\r\n rlock.acquire()\r\n running = running + 1\r\n rlock.release()\r\n for i in range(3):\r\n l = random.randint(1,100)\r\n plock.acquire()\r\n print \"pusher \" + str(l) + \" \" + self.getName()\r\n plock.release()\r\n self.q.put(l);\r\n time.sleep(2)\r\n rlock.acquire()\r\n running = running - 1\r\n rlock.release()\r\n\r\n#-----------------------------------------\r\n\r\nclass popper(Thread):\r\n def __init__(self):\r\n global q\r\n self.num = i\r\n Thread.__init__(self)\r\n self.q = q\r\n def run(self):\r\n global running\r\n while running > 0:\r\n try:\r\n l = self.q.get(True,10);\r\n plock.acquire()\r\n print \"popper \" + str(l) + \" \" + self.getName()\r\n plock.release()\r\n except:\r\n print str(sys.exc_info()[1])\r\n\r\n#-----------------------------------------\r\n\r\nfor i in range(5):\r\n c = pusher()\r\n c.start()\r\n\r\ntime.sleep(2)\r\n\r\nfor i in range(5):\r\n c = popper()\r\n c.start()\r\n <\/pre>\n","protected":false},"excerpt":{"rendered":"Below is a simple skeleton for a python queue that is both fed by and consumed by multiple different threads. We run five threads, each of which populate a queue with random integers. Lastly, we sleep a couple of seconds…<\/p>\n