Python中线程的MQ消息队列实现以及消息队列的优点解析(2)

当前位置:

首页 > Python基础教程 >

Python中线程的MQ消息队列实现以及消息队列的优点解析(2)

运行结果：

						i'm num 0

						i'm num 1

						i'm num 2

						i'm num 3

						i'm num 4

						i'm num 5

						i'm num 6

						i'm num 7

						i'm num 8

						i'm num 9

						Elapsed Time: 1.01399993896

解读：

具体工作步骤描述如下：

1，创建一个 Queue.Queue() 的实例，然后使用数据对它进行填充。

2，将经过填充数据的实例传递给线程类，后者是通过继承 threading.Thread 的方式创建的。

3，生成守护线程池。

4，每次从队列中取出一个项目，并使用该线程中的数据和 run 方法以执行相应的工作。

5，在完成这项工作之后，使用 queue.task_done() 函数向任务已经完成的队列发送一个信号。

6，对队列执行 join 操作，实际上意味着等到队列为空，再退出主程序。

在使用这个模式时需要注意一点：通过将守护线程设置为 true，程序运行完自动退出。好处是在退出之前，可以对队列执行 join 操作、或者等到队列为空。

2.多个队列

所谓多个队列，一个队列的输出可以作为另一个队列的输入

						#!/usr/bin/env python

						import Queue

						import threading

						import time

						queue = Queue.Queue()

						out_queue = Queue.Queue()

						class ThreadNum(threading.Thread):

						  def __init__(self, queue, out_queue):

						    threading.Thread.__init__(self)

						    self.queue = queue

						    self.out_queue = out_queue

						  def run(self):

						    whileTrue:

						      #从队列中取消息

						      num = self.queue.get()

						      bkeep = num

						      #将bkeep放入队列中

						      self.out_queue.put(bkeep)

						      #signals to queue job is done

						      self.queue.task_done()

						class PrintLove(threading.Thread):

						  def __init__(self, out_queue):

						    threading.Thread.__init__(self)

						    self.out_queue = out_queue

						  def run(self):

						    whileTrue:

						      #从队列中获取消息并赋值给bkeep

						      bkeep = self.out_queue.get()  

						      keke = "I love " + str(bkeep)

						      print keke,

						      print self.getName()

						      time.sleep(1)

						      #signals to queue job is done

						      self.out_queue.task_done()

						start = time.time()

						def main():

						  #populate queue with data

						  for num in range(10):

						    queue.put(num)

						  #spawn a pool of threads, and pass them queue instance

						  for i in range(5):

						    t = ThreadNum(queue, out_queue)

						    t.setDaemon(True)

						    t.start()

						  for i in range(5):

						    pl = PrintLove(out_queue)

						    pl.setDaemon(True)

						    pl.start()

						  #wait on the queue until everything has been processed

						  queue.join()

						  out_queue.join()

						main()

						print "Elapsed Time: %s" % (time.time() - start)

栏目列表