当前位置: 首页 > 后端技术 > Python

【Python基础】python并发实例

时间:2023-03-26 12:51:00 Python

创建少量并发进程importmultiprocessingimporttimedeffunc(msg):foriinxrange(3):printmsgtime.sleep(1)ifname=="__main__":p=multiprocessing.Process(target=func,args=("hello",))p.start()p.join()print"子进程完成。"进程池使用apply_async,没有async它是一个阻塞版本processes=4)foriinxrange(10):msg="hello%d"%(i)pool.apply_async(func,(msg,))pool.close()pool.join()print"Sub-process(es)完成。”使用池并关注结果=4)result=[]foriinxrange(10):msg="hello%d"%(i)result.append(pool.apply_async(func,(msg,)))pool.close()pool.join()forresinresult:printres.get()打印“子进程完成。”总结Python比较好的并行方式是使用多进程,可以非常有效的利用CPU资源,实现真正的并发。线程共享相同的地址空间和内存,线程之间的通信非常容易,但进程之间的通信就比较复杂了。进程间通信包括管道、消息队列、Socket接口等。