Python多线程使用总结
程序员文章站
2022-04-02 11:09:33
一、当多个进程运行的时,可能会出现的问题即解决方案通过进程模块执行的函数无法获取返回值--进程之间如何通信:通过队列多个进程同时修改文件可能会出现错误--进程之间如何如何避免资源抢占:进程数量太多可能会造成资源不足,甚至死机等情况--如何避免创建进程数量太多:二、什么是队列队列是一种数据存储结构,它的数据存储特点类似于排队,先进入队列的会先出来,后进入队列的后出来,因此它的数据只要通过put()放入,get()取出即可,不需要安排取哪些数据进程的数据可放入队列,哪些进程需要,从队列中通过...
一、当多个进程运行的时,可能会出现的问题即解决方案
- 通过进程模块执行的函数无法获取返回值--进程之间如何通信:通过队列
- 多个进程同时修改文件可能会出现错误--进程之间如何如何避免资源抢占:
- 进程数量太多可能会造成资源不足,甚至死机等情况--如何避免创建进程数量太多:
二、什么是队列
队列是一种数据存储结构,它的数据存储特点类似于排队,先进入队列的会先出来,后进入队列的后出来,因此它的数据只要通过put()放入,get()取出即可,不需要安排取哪些数据进程的数据可放入队列,哪些进程需要,从队列中通过取出,即可使用。
三、如何创建队列
- 使用的模块:queue
- 创建的方法:queue、Queue(...)
代码如下:
# coding:utf-8
import multiprocessing,time,random
def sender(q):
while True:
x = random.randint(1,10)
print("send done:",x)
q.put(x)
time.sleep(1)
def recvder(q):
while True:
x = q.get()
print("recv done:",x*3.14)
time.sleep(1)
if __name__ == "__main__":
q = multiprocessing.Queue()
t1 = multiprocessing.Process(target=sender,args=(q,))
t2 = multiprocessing.Process(target=recvder,args=(q,))
t1.start()
t2.start()
t1.join()
t2.join()
本文地址:https://blog.csdn.net/qq_38570633/article/details/108243657
上一篇: layui表格实现多选表格行批量删除
下一篇: r2p2之DPDK学习记录(2)