Python 多进程 多线程数据共享

发布时间：2019-08-27 08:02:16编辑：auto阅读（1468）

    #!/usr/bin/env python
# -*- coding:utf-8 -*-
# author: Changhua Gong
from multiprocessing import Process, Queue
import os, time, random
'''
1. 我们平时from queue import Queue是线程对列，用于数据共享的，只能在线程之间进行使用；
2. from multiprocessing import Queue，是进程对列，用于进程间数据交换，实际中是在进程之间进行序列化和反序列化（pickle）
   完成数据交互的；
3. 线程之间修改同一份数据，需加锁，而进程间的数据传递，仅是传递（数据共享）。
'''
# 写数据进程执行的代码:
def write(q):
    print('Process to write: %s' % os.getpid())
    for value in ['A', 'B', 'C']:
        print('Put %s to queue...' % value)
        q.put(value)  # 推送
        time.sleep(random.random())
# 读数据进程执行的代码:
def read(q):
    print('Process to read: %s' % os.getpid())
    while True:
        value = q.get(True)  # 获取
        print('Get %s from queue.' % value)
if __name__=='__main__':
    # 父进程创建Queue，并传给各个子进程：
    q = Queue()
    pw = Process(target=write, args=(q,))
    pr = Process(target=read, args=(q,))
    # 启动子进程pw，写入:
    pw.start()
    # 启动子进程pr，读取:
    pr.start()
    # 等待pw结束:
    pw.join()
    # pr进程里是死循环，无法等待其结束，只能强行终止:
    pr.terminate()
    
    
#!/usr/bin/env python
# -*- coding:utf-8 -*-
# author: Changhua Gong
from multiprocessing import Process, Pipe
from time import sleep
from multiprocessing import freeze_support
'''
def Pipe(duplex=True):
    return Connection(), Connection()
说明个问题：Pipe仅能两个进程间的交互，类似电话线形式收发
'''
def run_A(conn):
    for i in range(3):
        conn.send("I am from run_A: %s" % i)
        sleep(0.3)
    for i in range(5):
        print(conn.recv())
def run_B(conn):
    for i in range(3):
        print(conn.recv())
    for i in range(5):
        conn.send("I am from run_B: %s" %  i)
        sleep(0.3)
if __name__ == "__main__":
    freeze_support()
    conn1, conn2 = Pipe()
    pA = Process(target=run_A, args=(conn1,))
    pB = Process(target=run_B, args=(conn2,))
    pA.start()
    pB.start()
    pA.join()
    pB.join()

关键字：

上一篇： 对Python中装饰器(Decorato

下一篇： python3+selenium框架设计