python类库32[多进程同步Lock+Semaphore+Event]

同步的方法基本与多线程相同。

1) Lock

当多个进程需要访问共享资源的时候，Lock可以用来避免访问的冲突。

import multiprocessing
import sys

def worker_with(lock, f):
    with lock:
        fs = open(f,"a+")
        fs.write('Lock acquired via with\n')
        fs.close()

def worker_no_with(lock, f):
    lock.acquire()
    try:
        fs = open(f,"a+")
        fs.write('Lock acquired directly\n')
        fs.close()
    finally:
        lock.release()

if __name__ == "__main__":

f = "file.txt"

    lock = multiprocessing.Lock()
    w = multiprocessing.Process(target=worker_with, args=(lock, f))
    nw = multiprocessing.Process(target=worker_no_with, args=(lock, f))

w.start()
nw.start()

w.join()
nw.join()

在上面的例子中，如果两个进程没有使用lock来同步,则他们对同一个文件的写操作可能会出现混乱。

2）Semaphore

Semaphore用来控制对共享资源的访问数量，例如池的最大连接数。

import multiprocessing
import time

def worker(s,i):
    s.acquire()
    print(multiprocessing.current_process().name + " acquire")
    time.sleep(i)
    print(multiprocessing.current_process().name + " release")
    s.release()

if __name__ == "__main__":

    s = multiprocessing.Semaphore(2)
    for i in range(5):
        p = multiprocessing.Process(target=worker, args=(s,i*2))
p.start()

上面的实例中使用semaphore限制了最多有2个进程同时执行。

3）Event

Event用来实现进程间同步通信。

import multiprocessing
import time

def wait_for_event(e):
    """Wait for the event to be set before doing anything"""
    print ('wait_for_event: starting')
    e.wait()
    print ('wait_for_event: e.is_set()->' + str(e.is_set()))

def wait_for_event_timeout(e, t):
    """Wait t seconds and then timeout"""
    print ('wait_for_event_timeout: starting')
    e.wait(t)
    print ('wait_for_event_timeout: e.is_set()->' + str(e.is_set()))

if __name__ == '__main__':
    e = multiprocessing.Event()
    w1 = multiprocessing.Process(name='block',
                                 target=wait_for_event,
                                 args=(e,))
    w1.start()

w2 = multiprocessing.Process(name='non-block',
                                 target=wait_for_event_timeout,
                                 args=(e, 2))
    w2.start()

time.sleep(3)
    e.set()
    print ('main: event is set')

#the output is:
#wait_for_event_timeout: starting
#wait_for_event: starting
#wait_for_event_timeout: e.is_set()->False
#main: event is set
#wait_for_event: e.is_set()->True

参考：http://www.doughellmann.com/PyMOTW/multiprocessing/communication.html

完！

python类库32[多进程同步Lock+Semaphore+Event]相关推荐

python类库32[多线程同步Lock+RLock+Semaphore+Event]
2019独角兽企业重金招聘Python工程师标准>>> 一多线程同步由于CPython的python解释器在单线程模式下执行,所以导致python的多线程在很多的时候并不能很好地 ...
python 线程的类库_python类库32[多线程同步Lock+RLock+Semaphore+Event]
多线程基础:python类库32[多线程同步] 一多线程同步由于CPython的python解释器在单线程模式下执行,所以导致python的多线程在很多的时候并不能很好地发挥多核cpu的资源.大部 ...
进程同步控制 Lock Semaphore Event
一.Lock 当多个进程使用同一份数据资源的时候,就会引发数据安全或顺序混乱问题加锁可以保证多个进程修改同一块数据时,同一时间只能有一个任务可以进行修改,即串行的修改 lock=Lock() loc ...
0818Python总结-lock,Semaphore,event,Queue,生产者和消费者模型,JoinableQueue
一.锁 Lock from multiprocessing import Process,Lock 1.Lock基本用法上锁和解锁是一对,只上锁不解锁会发生死锁现象(代码阻塞,不往下执行了) 互斥锁 ...
32 多线程同步值Semaphore(信号量)
互斥锁是只允许一个线程访问共享数据,而信号量是同时允许一定数量的线程访问共享数据,比如银行柜台有5个窗口,允许同时有5个人办理业务,后面的人只能等待,待柜台有人办理完业务后才可以进行相应的柜台办理. ...
python线程安全的计数器_Python多线程同步Lock、RLock、Semaphore、Event实例
一.多线程同步由于CPython的python解释器在单线程模式下执行,所以导致python的多线程在很多的时候并不能很好地发挥多核cpu的资源.大部分情况都推荐使用多进程. python的多线程的 ...
Python多线程、多进程最全整理
线程与进程的区别进程(process)和线程(thread)是操作系统的基本概念,但是它们比较抽象,不容易掌握.关于多进程和多线程,教科书上最经典的一句话是"进程是资源分配的最小单位,线程 ...
太好了, 终于梳理清楚Python多线程与多进程
在学习Python的过程中,有接触到多线程编程相关的知识点,先前一直都没有彻底的搞明白.今天准备花一些时间,把里面的细节尽可能的梳理清楚. 线程与进程的区别进程(process)和线程(thread ...
一篇文章梳理清楚 Python 多线程与多进程
在学习Python的过程中,有接触到多线程编程相关的知识点,先前一直都没有彻底的搞明白.今天准备花一些时间,把里面的细节尽可能的梳理清楚. 线程与进程的区别进程(process)和线程(thread ...

python类库32[多进程同步Lock+Semaphore+Event]

python类库32[多进程同步Lock+Semaphore+Event]相关推荐

最新文章

热门文章