Python 3基础教程40-队列-Queue
2017-05-09 14:59
555 查看
本文来介绍下队列的基本使用,队列是Python线程中最常用的数据交换方法。Queue是queue模块下的对象,Queue是python标准库中的线程安全的队列(FIFO)实现,提供了一个适用于多线程编程的先进先出的数据结构。本文会用到Queue的put和get方法,put()就是把一个值放入到队列,get()就是从队列取出一个值,看看下面的例子。
import threading
import time
from queue import Queue
def job(data,q):
for i in range(len(data)):
data[i] = data[i]**2
# put方法把结果放入队列,这里不能使用return语句
q.put(data)
def exampleFuc():
# 新建一个队列
q = Queue()
# 新建一个空的多线程列表
threads = []
# 给出一个数据,到job去计算
data = [[1,2,3],[2,3,4],[3,4,5],[4,5,6]]
# for 循环创建一个多线程,大小根据data[]的大小
for x in range(4):
t = threading.Thread(target=job, args=(data[x], q))
# 启动线程
t.start()
# 把创建线程添加到多线程threads这个列表
threads.append(t)
for each_thread in threads:
each_thread.join()
# 定义一个计算结果列表
results = []
# 把结果分别从队列取出,这里需要取4次
for y in range(4):
# q.get()就是从队列取出结果
results.append(q.get())
# 等所以事情完成,就打印结果列表
print(results)
exampleFuc()
运行计算结果:
============= RESTART: C:\Users\Anthony\Desktop\thread_queue.py =============
[[1, 4, 9], [4, 9, 16], [9, 16, 25], [16, 25, 36]]
>>>
import threading
import time
from queue import Queue
def job(data,q):
for i in range(len(data)):
data[i] = data[i]**2
# put方法把结果放入队列,这里不能使用return语句
q.put(data)
def exampleFuc():
# 新建一个队列
q = Queue()
# 新建一个空的多线程列表
threads = []
# 给出一个数据,到job去计算
data = [[1,2,3],[2,3,4],[3,4,5],[4,5,6]]
# for 循环创建一个多线程,大小根据data[]的大小
for x in range(4):
t = threading.Thread(target=job, args=(data[x], q))
# 启动线程
t.start()
# 把创建线程添加到多线程threads这个列表
threads.append(t)
for each_thread in threads:
each_thread.join()
# 定义一个计算结果列表
results = []
# 把结果分别从队列取出,这里需要取4次
for y in range(4):
# q.get()就是从队列取出结果
results.append(q.get())
# 等所以事情完成,就打印结果列表
print(results)
exampleFuc()
运行计算结果:
============= RESTART: C:\Users\Anthony\Desktop\thread_queue.py =============
[[1, 4, 9], [4, 9, 16], [9, 16, 25], [16, 25, 36]]
>>>
相关文章推荐
- 【Python】:拓展Queue实现有序不重复队列
- Python中的多线程threading和线程间消息队列queue学习笔记
- Python Tricks(七)—— 使用 list 仿真先入先出的队列(FIFOQueue)
- Python线程优先级队列(Queue)
- python队列Queue
- python实现简单的redis 队列 SIMPLE PYTHON QUEUE WITH REDIS
- Python之队列queue模块使用 常见问题与用法
- Python环境下安装使用异步任务队列包Celery的基础教程
- jQuery中队列queue()函数的实例教程
- Python 标准库 —— 队列(Queue,优先队列 PriorityQueue)
- python Queue队列例子
- RabbitMQ(python实现)学习之二:Producer发送消息至多个消息队列queue(广播消息)
- RabbitMQ(python实现)学习之二:Producer发送消息至多个消息队列queue(广播消息)
- Python环境下安装使用异步任务队列包Celery的基础教程
- python threading模块使用 以及python多线程操作的实践(使用Queue队列模块)
- Python3.2 官方文档教程---列表当做栈、队列和递推式列表
- python多线程--优先级队列(Queue)
- Queue同步队列类在python中的应用
- 队列(Queue)的python实现及其应用
- Python_Day_05 计数器(counter),有序字典(OrderDict),默认字典(defaultdict),可命名元祖(namedtuple),双向队列(deque),单项队列(deuqe.Queue)