-
Notifications
You must be signed in to change notification settings - Fork 1
/
test_thread.py
63 lines (49 loc) · 1.23 KB
/
test_thread.py
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
#!/usr/bin/python
#coding=utf-8
import threading
import time
from queue import Queue
q = Queue(10)
threadLock = threading.Lock()
class myThread(threading.Thread):
def __init__(self,threadID,name):
threading.Thread.__init__(self)
self.threadID = threadID
self.name = name
self.exitFlag = 0
def run(self):
while not self.exitFlag:
threadLock.acquire()
if not q.empty():
id = q.get()
print_time(self.name,id)
threadLock.release()
else:
threadLock.release()
def print_time(threadName,id):
# pass
print("%s:%s:%s"%(threadName,time.ctime(time.time()),id))
# 创建3个线程
threads = []
for i in range(3):
name = "Thread-%d"%i
t = myThread(i,name)
t.start()
threads.append(t)
for i in range(10000):
q_name = "Queue:%d"%i
print("================")
print(q_name)
q.put(q_name)
# 等待队列清空
while not q.empty():
pass
# 也可以join方法,与上同效
# q.join()
# 通知线程,处理完之后关闭
for t in threads:
t.exitFlag = 1
# 等待所有线程结束之后才退出
for t in threads:
t.join()
print("Exiting Main Thread")