python创建进程的方式

灰太狼 2022-05-11 11:36 196阅读 0赞

# 第一种方式 #

import os
    
    pid = os.fork()
    
    if(pid == 0):
        print("我是子进程，进程号是%s"%(os.getpid()))
        print("我是子进程，我的父进程号是%s"%(os.getppid()))
    else:
        print("我是父进程，进程号是%s"%(os.getpid()))
    
    print("over")

# 第二种方式 #

from multiprocessing import Process
    import os
    
    def test(name):
        print(name)
        print("我是子进程，进程号是%s"%(os.getpid()))
    
    if __name__ == '__main__':
        print("我是父进程，进程号是%s"%(os.getpid()))
        
        p=Process(target=test,args=("test1",))
        p.start()
        p.join() #父进程阻塞，等待子进程执行完毕

# 第三种方式 #

import os
    from multiprocessing import Process
    
    class MyProcess(Process):
        # 创建一个类继承Process
        def __init__(self,name):
            Process.__init__(self)
            self.__name = name
    
        # 重写run方法，调用start时，如果没有给Process的target
        # 传参，那么会默认调用run
    
        def run(self):
            print(self.name)
            print("我是子进程，进程号是%s,进程名是%s"%(os.getpid(),self.name))
            
    
    if __name__ == "__main__":
        print("我是父进程，进程号是%s"%(os.getpid()))
        p = MyProcess("进程1")
        p.start()
        p.join()

# 第四种方式 #

from multiprocessing import Pool
    import os
    import time
    
    def test():
        print("我是子进程，进程号是%s"%(os.getpid()))
        time.sleep(2)
    
    p = Pool(3)
    
    for i in range(0,20):
        p.apply_async(test)
    
    print("----start---")
    p.close()
    p.join()
    print("----start---")