大米CMS官网论坛,大米站长联盟,大米站长之家,大米开发者社区
标题:
python多线程处理队列实例
[打印本页]
作者:
追影
时间:
2022-7-21 15:22
标题:
python多线程处理队列实例
import queue
import threading
import time
# 线程思路:
# 创建任务队列workQueue,和创建多条线程,然后将任务队列传入多线程中,
# 在线程运行中,使用线程锁循环将任务读出,再执行任务,使用join函数等待所有线程完成任务。
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()
queueLock.release()
print("%s processing %s" % (threadName, data))
else:
queueLock.release()
time.sleep(2)
threadList = ["Thread-1", "Thread-2", "Thread-3"]
nameList = ["One-queue", "Two-queue", "Three-queue", "Four-queue", "Five-queue"]
# 线程锁
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()
print("等待队列清空")
# 分配任务到每个线程,等待队列清空
while not workQueue.empty():
pass
# 所有任务分配完成,通知线程是时候退出,即通知线程已经没有任务了,可以退出了
exitFlag = 1
# 等待所有线程完成
for t in threads:
t.join()
print("退出主线程")
复制代码
欢迎光临 大米CMS官网论坛,大米站长联盟,大米站长之家,大米开发者社区 (https://www.damicms.com/bbs/)
Powered by Discuz! X3.1