Python并发编程-信号量

2021-06-20 17:06

阅读:328

标签:code   获取   定义   RoCE   rand   map   imp   random   proc   

信号量保证同一资源同一时间只能有限定的进程去访问

  • 一套资源,同一时间,只能被n个人访问
  • 某一段代码,同一时间,只能被n个进程执行
from multiprocessing import  Process
import random
import time
from multiprocessing import Semaphore

def ktv(i,sem):
    sem.acquire() #获取钥匙
    print('%s走进ktv'%i)
    time.sleep(random.randint(1,5))
    print('%s走出ktv'%i)
    sem.release() #还钥匙
if __name__ == '__main__':
    sem = Semaphore(4) #定义同一时间允许进入房间的人数
    for i in range(20):
        p = Process(target=ktv, args=(i,sem)) #传入信号量参数
        p.start()

Python并发编程-信号量

标签:code   获取   定义   RoCE   rand   map   imp   random   proc   

原文地址:https://www.cnblogs.com/konglinqingfeng/p/9688525.html


评论


亲,登录后才可以留言!