7.16 进程 信号量

01.复习内容

子进程里面不能用 input  明天认真看 ,天热有点浮躁!

#!/usr/bin/env python
#!--*--coding:utf-8 --*--
#!@Time    :2018/7/16 18:46
#!@Author   TrueNewBee

"""
    我把之前的项目误删了,重新建个项目,
    还好以前部分代码用sublime编写的还有存档
"""
#多进程代码

# from multiprocessing import Process
#方法
    #进程对象.start()       开启一个子进程
    #进程对象.join()        感知一个子进程的结束
    #进程对象.terminate()   结束一个子进程
    #进程对象.is_alive()    查看某个子进程是否还在运行
#属性
    #进程对象.name      进程名
    #进程对象.pid       进程号
    #进程对象.daemob    值为True的时候,表现新的子进程是一个守护进程
        #守护进程   随着主进程代码的执行结束而结束
        #一定在start之前设置

#from  multiprocessing import Lock

#l = Lock()
#l.acquire()    #拿钥匙
#会造成数据不安全的操作
#l.release()    #换钥匙

# 信号量   pep8的标准还得适应,,真难

# !/usr/bin/env python
# !--*--coding:utf-8 --*--
# !@Time    :2018/7/16 19:01
# !@Author   TrueNewBee


# 多进程中的组件
# 一套资源  同一时间 只能被n个人访问
# 某一段代码 同一时间 只能被n个进程执行
import time
import random
from multiprocessing import Process
from multiprocessing import Semaphore


def ktv(arg, sem1):
    sem1.acquire()   # 获取钥匙
    """模拟唱歌"""
    print("%s走进ktv"%arg)
    time.sleep(random.randint(1, 5))
    print("%s走出ktv"%arg)
    sem.release()


if __name__ == '__main__':
    sem = Semaphore(4)
    for i in range(20):
        p = Process(target=ktv, args=(i, sem))
        p.start()