提前设定好，一个房间只有4个床（计数器现在为4），那么同时只能四个人进来，谁先来的谁先占一个床（acquire，计数器减1），4个床满了之后（计数器为0了），第五个人就要等着，等其中一个人出来（release，计数器加1），他就去占用那个床了。
互斥锁同时只允许一个线程更改数据，而信号量Semaphore是同时允许一定数量的线程更改数据 。 假设商场里有4个迷你唱吧，所以同时可以进去4个人，如果来了第五个人就要在外面等待，等到有人出来才能再进去玩。 实现： 信号量同步基于内部计数器，每调用一次acquire()，计数器减1；每调用一次release()，计数器加1.当计数器为0时，acquire()调用被阻塞。这是迪科斯彻（Dijkstra）信号量概念P()和V()的Python实现。信号量同步机制适用于访问像服务器这样的有限资源。 信号量与进程池的概念很像，但是要区分开，信号量涉及到加锁的概念
# -*- coding: utf-8 -*- import os import time from multiprocessing import Process def go_ktv(i): print("user%s正在....ktv.子进程(%s)" % (i, os.getpid())) time.sleep(2) if __name__ == '__main__': '''开启20个进程,操作系统可以调度4个cpu去执行,进程的调用比线程的开销大些''' start_time = time.time() p_lst = [] for i in range(20): p = Process(target=go_ktv, args=(i,)) p.start() p_lst.append(p) [pp.join() for pp in p_lst] print("运行时间: %s.主进程<%s>" % ((time.time() - start_time), os.getpid())) # user0正在....ktv.子进程(5496) # user1正在....ktv.子进程(6996) # user3正在....ktv.子进程(6328) # user2正在....ktv.子进程(1064) # user4正在....ktv.子进程(4844) # user7正在....ktv.子进程(7804) # user5正在....ktv.子进程(7688) # user8正在....ktv.子进程(7136) # user6正在....ktv.子进程(7824) # user9正在....ktv.子进程(7812) # user10正在....ktv.子进程(8148) # user11正在....ktv.子进程(2556) # user13正在....ktv.子进程(4744) # user15正在....ktv.子进程(6232) # user14正在....ktv.子进程(5168) # user16正在....ktv.子进程(6444) # user12正在....ktv.子进程(2616) # user17正在....ktv.子进程(5188) # user18正在....ktv.子进程(8088) # user19正在....ktv.子进程(7224) # 运行时间: 3.2611865997314453.主进程<6936>
# -*- coding: utf-8 -*- import os import time from multiprocessing import Pool def go_ktv(i): print("user%s正在....ktv.子进程(%s)" % (i, os.getpid())) time.sleep(2) if __name__ == '__main__': '''创建进程池,进程的容量默认是4,
如果总进程的数量超过4,就会自动排队等待,一次可执行4个进程,进程池内的进程结束一个,就会自动进来一个新的进程,重用原来的进程号,节省开销''' start_time = time.time() pool = Pool() p_lst = [] for i in range(20): pool.apply_async(go_ktv, args=(i,)) pool.close() pool.join() print("运行时间: %s.主进程<%s>" % ((time.time() - start_time), os.getpid())) # user0正在....ktv.子进程(7396) # user1正在....ktv.子进程(1760) # user2正在....ktv.子进程(8000) # user3正在....ktv.子进程(4120) # user4正在....ktv.子进程(7396) # user5正在....ktv.子进程(1760) # user6正在....ktv.子进程(8000) # user7正在....ktv.子进程(4120) # user8正在....ktv.子进程(7396) # user9正在....ktv.子进程(1760) # user10正在....ktv.子进程(8000) # user11正在....ktv.子进程(4120) # user12正在....ktv.子进程(7396) # user13正在....ktv.子进程(1760) # user14正在....ktv.子进程(8000) # user15正在....ktv.子进程(4120) # user16正在....ktv.子进程(7396) # user17正在....ktv.子进程(1760) # user18正在....ktv.子进程(8000) # user19正在....ktv.子进程(4120) # 运行时间: 10.851620435714722.主进程<7428>
# -*- coding: utf-8 -*- import os import time from multiprocessing import Process, Semaphore def go_ktv(i, sem): with sem: print("user%s正在....ktv.子进程(%s)" % (i, os.getpid())) time.sleep(2) if __name__ == '__main__': '''开启20个进程,一次可执行4(信号量容量)个进程,相当于添加另一个互斥锁''' start_time = time.time() sem = Semaphore(4) p_lst = [] for i in range(20): p = Process(target=go_ktv, args=(i, sem)) p.start() p_lst.append(p) [pp.join() for pp in p_lst] print("运行时间: %s.主进程<%s>" % ((time.time() - start_time), os.getpid())) # user0正在....ktv.子进程(3660) # user1正在....ktv.子进程(7188) # user3正在....ktv.子进程(7268) # user2正在....ktv.子进程(7568) # user5正在....ktv.子进程(2896) # user6正在....ktv.子进程(2852) # user7正在....ktv.子进程(376) # user4正在....ktv.子进程(7532) # user9正在....ktv.子进程(8188) # user10正在....ktv.子进程(1444) # user12正在....ktv.子进程(6304) # user11正在....ktv.子进程(6776) # user14正在....ktv.子进程(6992) # user13正在....ktv.子进程(7248) # user8正在....ktv.子进程(6820) # user17正在....ktv.子进程(6308) # user15正在....ktv.子进程(8020) # user18正在....ktv.子进程(4312) # user16正在....ktv.子进程(2724) # user19正在....ktv.子进程(7516) # 运行时间: 10.443597078323364.主进程<2560>