zoukankan      html  css  js  c++  java
  • python并发——进程间同步和通信

    一.进程间同步

    对于一些临界资源,不能使用并发无限消耗,就需要设置专门的临界标示,比如锁或者信号量等

    from multiprocessing import Process, Lock
    import time
    
    def f(l, i):
        l.acquire()
        try:
            print('hello world', i)
            time.sleep(1)
        finally:
            l.release()
    def f2(l, i):
        l.acquire()
        try:
            print('nin hao?', i)
            time.sleep(1)
        finally:
            l.release()
    
    if __name__ == '__main__':
        lock = Lock()
    
        for num in range(10):
            Process(target=f, args=(lock, num)).start()
            Process(target=f2, args=(lock, num)).start()

    二.进程间通信

    有时候需要在进程之间交换对象

    multiprocessing 支持进程之间的两种通信通道:

    (1).队列

    Queue 类是一个近似 queue.Queue 的克隆。 例如:

    from multiprocessing import Process, Queue
    
    def f(q):
        q.put([42, None, 'hello'])
    
    if __name__ == '__main__':
        q = Queue()
        p = Process(target=f, args=(q,))
        p.start()
        print(q.get())    # prints "[42, None, 'hello']"
        p.join()

    队列是线程和进程安全的。

    (2).管道

    Piep 函数返回一个由管道连接的连接对象,默认情况下是双工(双向)。例如:

    from multiprocessing import Process, Pipe
    
    def f(conn):
        conn.send([42, None, 'hello'])
        conn.close()
    
    if __name__ == '__main__':
        parent_conn, child_conn = Pipe()
        p = Process(target=f, args=(child_conn,))
        p.start()
        print(parent_conn.recv())   # prints "[42, None, 'hello']"
        p.join()
  • 相关阅读:
    length()与trim()函数用法
    软件测试面试题集锦
    数据库索引介绍
    sum 函数语法与应用
    报表测试方法与注意事项
    添加、编辑、删除功能测试点
    登陆测试思路总结
    查询功能测试点总结
    case 函数语法与使用
    js获取地址栏上的Id值
  • 原文地址:https://www.cnblogs.com/wangbin2188/p/11936996.html
Copyright © 2011-2022 走看看