Python中如何实现基于队列的异步任务处理

import queue
import threading

def worker(task_queue, result_queue):
    while True:
        try:
            task = task_queue.get(block=False)
            # 执行任务
            result = task.upper()
            # 存储任务结果
            result_queue.put(result)
        except queue.Empty:
            break

if __name__ == '__main__':
    # 创建任务队列和结果队列
    task_queue = queue.Queue()
    result_queue = queue.Queue()

    # 创建并启动多个工作线程
    threads = []
    for i in range(4):
        t = threading.Thread(target=worker, args=(task_queue, result_queue))
        t.start()
        threads.append(t)

    # 向任务队列中添加任务
    task_queue.put('pidancode.com')
    task_queue.put('皮蛋编程')

    # 从结果队列中获取已处理的任务结果
    results = []
    while len(results) < 2:
        result = result_queue.get()
        results.append(result)

    # 等待所有工作线程结束
    for t in threads:
        t.join()

    print(results)

import multiprocessing

def worker(task_queue, result_queue):
    while True:
        try:
            task = task_queue.get(block=False)
            # 执行任务
            result = task.upper()
            # 存储任务结果
            result_queue.put(result)
        except queue.Empty:
            break

if __name__ == '__main__':
    # 创建任务队列和结果队列
    task_queue = multiprocessing.Queue()
    result_queue = multiprocessing.Queue()

    # 创建并启动多个进程
    processes = []
    for i in range(4):
        p = multiprocessing.Process(target=worker, args=(task_queue, result_queue))
        p.start()
        processes.append(p)

    # 向任务队列中添加任务
    task_queue.put('pidancode.com')
    task_queue.put('皮蛋编程')

    # 从结果队列中获取已处理的任务结果
    results = []
    while len(results) < 2:
        result = result_queue.get()
        results.append(result)

    # 等待所有进程结束
    for p in processes:
        p.join()

    print(results)