python--multiprocessing-下面的queue消息队列

今天接触的东西还挺多的哈。。。线程进程队列一起整了。。 消息队列的话理解起来也是挺简单的 主要是解决进程之间不能访问公用资源的问题,既保证了安全,有能去修改公用资源, queue.put()入队列 queue.get()出队列 put_nowait() get_nowait() # 出入队列不等待。 empty()# 判断队列是否已空 full() # 判断队列是否为已满 multiprocessing.Queue(5)->括号内写的值就是队列的长度。 可以通多下面的例子来实现进程和进程之间的通信, a=multiprocessing.Queue(5) 创建一个长度为5的队列 work1=multiprocessing.Process(target=n1,args=a) 创建一个work1进程 work2=multiprocessing.Process(target=21,args=a)创建一个work2进程 work1.start() # 进程启动 work1.join()# 进程优先执行 work2.start() # 进程启动
搜索