# (1) 进程的基本使用
def func():
    print("1.子进程id>>{},2父进程id>>{}".format(os.getpid(),os.getppid()))

# 为了解决windows 和 linux 系统的兼容问题,下面这句话必须加上,否则报错
if __name__ == "__main__":
    # 创建子进程,返回进程对象,执行func这个任务
    p = Process(target=func)
    # 调用子进程
    p.start()

def func(n):
    for i in range(1,n+1):
        print("1.子进程id>>{},2父进程id>>{}".format(os.getpid(),os.getppid()))

if __name__ == "__main__":
    n = 5
    #创建子进程
    p = Process(target=func,args=(n,))
    #调用子进程
    p.start()

    for i in range(1,n+1):
        print("*" * i)

count = 10
def func():
    global count
    count += 1
    print("我是子进程count={}".format(count))

if __name__ == "__main__":
    p=Process(target=func)
    p.start()
    time.sleep(1)
    print(count)

def func(n):
    time.sleep(random.randrange(3))
    print("数字{}<=>1.子进程id>>{},2父进程id>>{}".format(n,os.getpid(),os.getppid()))

if __name__ == "__main__":
    for i in range(1,11):
        Process(target=func,args=(i,)).start()
        
    print("主进程执行结束了....")
    print(os.getpid())

def func():
    print("发送第一封邮箱,要求涨工资")


if __name__ == "__main__":
    p = Process(target=func)
    p.start()

    # 必须等待子进程全部执行结束之后,在执行主进程中的代码,用join来同步子父进程.
    p.join()
    # time.sleep(1)
    print("发送第二封邮箱,涨到一个月6万")

def func(i):
    time.sleep(1)
    print("发送第%s封邮箱,要求升职加薪" % (i))


if __name__ == "__main__":
    lst = []
    for i in range(10):
        p = Process(target=func, args=(i,))
        p.start()
        lst.append(p) # 把创建的十个子进程对象方放到列表中，现在他们处于就绪态

    for i in lst:
        i.join() # 十个子进程对象同时join

    print("主进程发最后一封邮件:此致敬礼~")

def func():
    print("start当前子进程")
    time.sleep(1)
    print("end当前子进程")


if __name__ == "__main__":
    p = Process(target=func)
    p.daemon = True
    p.start()

    print("主进程执行结束 ... ")

def func1():
    count = 1
    while True:
        print("*" * count)
        time.sleep(0.5)
        count += 1


def func2():
    print("start func2 当前子进程任务")
    time.sleep(3)
    print("end   func2 当前子进程任务")


if __name__ == "__main__":
    p1 = Process(target=func1)
    p2 = Process(target=func2)

    # 设置p1这个进程对象为守护进程
    p1.daemon = True

    p1.start()
    p2.start()

    time.sleep(1)

    print("主进程执行结束 ... ")

# 守护进行
def alive():
    while True:
        print("给监控的总服务器发消息,报告自己的存活状态, i am alive~")
        time.sleep(1)


# 执行任务
def func():
    while True:
        try:
            time.sleep(1)
            raise RuntimeError
            print("当前5号服务器功能:对日志进行数据分析.... ")
        except:
            break
        # pass


if __name__ == "__main__":
    # 创建2个子进程
    p1 = Process(target=alive)
    p2 = Process(target=func)
    # 设置p1为守护进程
    p1.daemon = True

    p1.start()
    p2.start()

    # 必须等到p2任务执行结束之后,在向下执行.
    p2.join()

    print("当前服务器状态异常 ... ")