-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy paththread_queue.py
More file actions
90 lines (55 loc) · 1.54 KB
/
Copy paththread_queue.py
File metadata and controls
90 lines (55 loc) · 1.54 KB
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
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
#!/usr/bin/python3
# coding=UTF-8
#================================================================
# Copyright (C) 2018 HALO Ltd. All rights reserved.
#
# 文件名称：thread_queue.py
# 创 建 者：Zhangdunfeng
# 创建日期：2018-11-23 10:49:11
# 描 述：多线程使用优先级队列
#
#================================================================
import queue
import threading
import time
exitFlag=0
class myThread(threading.Thread):
def __init__(self, threadID, name, q):
threading.Thread.__init__(self)
self.threadID=threadID
self.name=name
self.q=q
def run(self):
print("开启线程：" + self.name)
process_data(self.name, self.q)
print("退出线程：" + self.name)
def process_data(threadName, q):
while not exitFlag:
queueLock.acquire()
if not workQueue.empty():
data=q.get()
print("%s processing %s" % (threadName, data))
queueLock.release()
time.sleep(1)
threadList=["Thread-1", "Thread-2", "Thread-3"]
nameList=["One", "Two", "Three", "Four", "Five"]
queueLock=threading.Lock()
workQueue=queue.Queue(10)
threads=[]
threadID=1
for tName in threadList:
thread=myThread(threadID, tName, workQueue)
thread.start()
threads.append(thread)
threadID+=1
queueLock.acquire()
for word in nameList:
workQueue.put(word)
queueLock.release()
while not workQueue.empty():
pass
#通知线程退出
exitFlag=1
for t in threads:
t.join()
print("退出主线程")