python多进程+协程实现并发示例

好的，关于python多进程协程实现并发的示例，可以参考以下代码：

import asyncio
import multiprocessing

async def worker():
    print(f"Process id: {multiprocessing.current_process().pid} is working.")
    await asyncio.sleep(1)
    print(f"Process id: {multiprocessing.current_process().pid} is done.")

async def main():
    tasks = [asyncio.create_task(worker()) for _ in range(5)]
    await asyncio.gather(*tasks)

if __name__ == "__main__":
    loop = asyncio.get_event_loop()
    processes = [multiprocessing.Process(target=loop.run_until_complete, args=(main(),)) for _ in range(3)]
    for p in processes:
        p.start()
    for p in processes:
        p.join()

这个示例中，我们定义了一个异步 worker 函数，它会在执行前等待 1 秒钟，然后打印出进程的 ID，最后再打印出完成的信息。我们通过 asyncio 的 create_task 函数将其封装成了一个协程任务（Task）。

在主函数 main 中，我们首先创建了 5 个 worker 任务，然后通过 async.gather 函数将它们全部加入到异步事件循环中。接下来，我们又使用了 multiprocessing 模块，创建了 3 个子进程。每个子进程都会在独立的事件循环中执行 main 函数的异步任务。

通过这种方式，我们就实现了多进程协程的并发。由于每个进程都拥有独立的 Python 解释器和内存空间，所以它们之间互不干扰，可以同时进行计算，从而提高了程序的运行效率。