python queue队列服务演示

zhanghe06 · zhanghe06 · commit 0d968a3c615c · 2015-04-24T00:11:15.000+08:00
diff --git a/queue.py b/queue.py
@@ -0,0 +1,73 @@
+# encoding: utf-8
+__author__ = 'zhanghe'
+
+from Queue import Queue
+import random
+import threading
+import time
+
+
+class Producer(threading.Thread):
+    """
+    Producer thread
+    """
+    def __init__(self, t_name, queue):
+        threading.Thread.__init__(self, name=t_name)
+        self.data = queue
+
+    def run(self):
+        for i in range(5):
+            print "%s: %s is producing %d to the queue!" % (time.ctime(), self.getName(), i)
+            self.data.put(i)
+            time.sleep(random.randrange(10) / 5)
+        print "%s: %s finished!" % (time.ctime(), self.getName())
+
+
+class Consumer(threading.Thread):
+    """
+    Consumer thread
+    """
+    def __init__(self, t_name, queue):
+        threading.Thread.__init__(self, name=t_name)
+        self.data = queue
+
+    def run(self):
+        for i in range(5):
+            val = self.data.get()
+            print "%s: %s is consuming. %d in the queue is consumed!" % (time.ctime(), self.getName(), val)
+            time.sleep(random.randrange(10))
+        print "%s: %s finished!" % (time.ctime(), self.getName())
+
+
+def main():
+    """
+    Main thread
+    :return:
+    """
+    queue = Queue()
+    producer = Producer('Pro.', queue)
+    consumer = Consumer('Con.', queue)
+    producer.start()
+    consumer.start()
+    producer.join()
+    consumer.join()
+    print 'All threads terminate!'
+
+
+if __name__ == '__main__':
+    main()
+
+# &#26412;&#31243;&#24207;&#26159;&#27604;&#36739;&#32463;&#20856;&#30340;&#29983;&#20135;&#32773;&#21644;&#28040;&#36153;&#32773;&#27169;&#22411;&#65292;&#36816;&#34892;&#32467;&#26524;&#65306;
+# Fri Apr 24 00:05:42 2015: Pro. is producing 0 to the queue!
+# Fri Apr 24 00:05:42 2015: Con. is consuming. 0 in the queue is consumed!
+# Fri Apr 24 00:05:43 2015: Pro. is producing 1 to the queue!
+# Fri Apr 24 00:05:43 2015: Con. is consuming. 1 in the queue is consumed!
+# Fri Apr 24 00:05:44 2015: Pro. is producing 2 to the queue!
+# Fri Apr 24 00:05:45 2015: Pro. is producing 3 to the queue!
+# Fri Apr 24 00:05:46 2015: Pro. is producing 4 to the queue!
+# Fri Apr 24 00:05:47 2015: Pro. finished!
+# Fri Apr 24 00:05:51 2015: Con. is consuming. 2 in the queue is consumed!
+# Fri Apr 24 00:05:53 2015: Con. is consuming. 3 in the queue is consumed!
+# Fri Apr 24 00:05:53 2015: Con. is consuming. 4 in the queue is consumed!
+# Fri Apr 24 00:06:02 2015: Con. finished!
+# All threads terminate!
