from multiprocessing import Process, Queue
# 定义一个函数,作为子进程要执行的任务
def task(queue, name):
# 模拟任务处理
result = f"Hello, {name}!"
# 将结果放入队列中
queue.put(result)
if __name__ == "__main__":
# 创建一个队列用于进程间通信
q = Queue()
# 创建多个子进程
p1 = Process(target=task, args=(q, "Alice"))
p2 = Process(target=task, args=(q, "Bob"))
# 启动子进程
p1.start()
p2.start()
# 等待子进程结束
p1.join()
p2.join()
# 从队列中获取子进程的结果
print(q.get())
print(q.get())
multiprocessing 是 Python 的多进程库,Process 类用于创建和管理子进程,Queue 类用于进程间通信。task 函数是每个子进程要执行的任务,它接收一个 Queue 对象和一个名字作为参数,模拟任务处理后将结果放入队列中。Queue 对象用于进程间通信。Process 类创建两个子进程 p1 和 p2,分别传入不同的参数。start() 方法启动子进程。join() 方法等待子进程完成。上一篇:python break
下一篇:python threading
Laravel PHP 深圳智简公司。版权所有©2023-2043 LaravelPHP 粤ICP备2021048745号-3
Laravel 中文站