zoukankan      html  css  js  c++  java
  • 多进程之间的通信

     1 from multiprocessing import*
     2 from time import sleep
     3 #定义写入的方法
     4 def write(q):
     5     a = ['a','b','c','d']
     6     for i in a:
     7         print('开始写入的值:%s'%i)
     8         q.put(i)
     9         sleep(1)
    10 
    11 def reader(q):
    12     for i in range(q.qsize()):
    13         print('读取到的值:%s'%q.get())
    14         sleep(1)
    15 
    16 if __name__ == '__main__':
    17     #创建队列
    18     q = Queue()
    19     #创建进程
    20     pw = Process(target=write,args=(q,))
    21     pr = Process(target=reader,args=(q,))
    22     pw.start()
    23     pw.join()
    24     pr.start()
    25     pr.join()
    1 开始写入的值:a
    2 开始写入的值:b
    3 开始写入的值:c
    4 开始写入的值:d
    5 读取到的值:a
    6 读取到的值:b
    7 读取到的值:c
    8 读取到的值:d
    正是江南好风景
  • 相关阅读:
    java-oop集合map
    IDEA启动Tomcat报错
    1.IDEM的快捷键
    1.idea快捷键
    14.
    13.级联一对多
    12.动态SQL
    11.动态参数
    10.主键回填
    9.参数的传递
  • 原文地址:https://www.cnblogs.com/monsterhy123/p/12676631.html
Copyright © 2011-2022 走看看