本文来介绍下队列的基本使用，队列是Python线程中最常用的数据交换方法。Queue是queue模块下的对象，Queue是python标准库中的线程安全的队列（FIFO）实现,提供了一个适用于多线程编程的先进先出的数据结构。本文会用到Queue的put和get方法，put()就是把一个值放入到队列，get()就是从队列取出一个值，看看下面的例子。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
| 1import threading
2import time
3from queue import Queue
4
5
6def job(data,q):
7 for i in range(len(data)):
8 data[i] = data[i]**2
9
10 # put方法把结果放入队列，这里不能使用return语句
11 q.put(data)
12
13
14def exampleFuc():
15
16 # 新建一个队列
17 q = Queue()
18
19 # 新建一个空的多线程列表
20 threads = []
21
22 # 给出一个数据，到job去计算
23 data = [[1,2,3],[2,3,4],[3,4,5],[4,5,6]]
24
25 # for 循环创建一个多线程，大小根据data[]的大小
26 for x in range(4):
27 t = threading.Thread(target=job, args=(data[x], q))
28 # 启动线程
29 t.start()
30 # 把创建线程添加到多线程threads这个列表
31 threads.append(t)
32
33 for each_thread in threads:
34 each_thread.join()
35
36 # 定义一个计算结果列表
37 results = []
38
39 # 把结果分别从队列取出，这里需要取4次
40 for y in range(4):
41 # q.get()就是从队列取出结果
42 results.append(q.get())
43
44 # 等所以事情完成，就打印结果列表
45 print(results)
46
47exampleFuc()
48
49 |
1
2
3
4
| 1============= RESTART: C:\Users\Anthony\Desktop\thread_queue.py =============
2[[1, 4, 9], [4, 9, 16], [9, 16, 25], [16, 25, 36]]
3>>>
4 |
