实现代码演示:
import threading
import time
import queue
def work(q):
while True:
if q.empty():
return
else:
t = q.get()
print("当前线程sleep {} 秒".format(t))
time.sleep(t)
def main():
q = queue.Queue()
for i in range(5):
q.put(i)
thread_num = 5
threads = []
for i in range(thread_num):
t = threading.Thread(target=work, args=(q,))这是给大家准备的一个简单队列模式,可以清晰的看到是由队列转化成多线程的一个过程,好啦,大家可以根据上述内容,输出以下信息。
当前线程sleep 0 秒 当前线程sleep 1 秒