Python中如何使用队列实现多线程编程

2023-04-11 00:00:00 队列 多线程 如何使用

在Python中，可以使用内置模块queue实现队列，并结合多线程编程实现任务的异步执行。具体实现步骤如下：

  1. 导入queue模块：
import queue
  1. 创建一个队列对象：
q = queue.Queue(maxsize=10)

其中maxsize参数指定队列的最大容量，如果不指定，则队列容量为无限大。

  1. 往队列中添加任务：
q.put("pidancode.com")
  1. 从队列中取出任务：
q.get()

如果队列为空，则get()方法会一直阻塞，直到队列中有新的任务被添加。

  1. 创建线程函数，实现任务的异步执行：
import threading

def worker():
    while True:
        task = q.get()
        print("处理任务：", task)
        q.task_done()

for i in range(5):
    t = threading.Thread(target=worker)
    t.daemon = True
    t.start()

在线程函数中，通过调用queue的get()方法获取任务，并执行相应的操作。在处理完任务后，需要调用q.task_done()来通知队列任务已经完成。

注意：在多线程编程中，要使用daemon线程（即守护线程），以确保主线程退出时所有子线程都已经退出。

完整代码如下：

import queue
import threading

q = queue.Queue(maxsize=10)

def worker():
    while True:
        task = q.get()
        print("处理任务：", task)
        q.task_done()

for i in range(5):
    t = threading.Thread(target=worker)
    t.daemon = True
    t.start()

q.put("pidancode.com")
q.put("皮蛋编程")
q.join()

运行结果：

处理任务： pidancode.com
处理任务： 皮蛋编程

相关文章