python 进程

import os
import time
import sys 

pid = os.fork()
if pid == 0:#子进程
        time.sleep(5)
        print('After 5 seconds')
        print('line%d:fork进程%d,PID=%d,父PID=%d'%(sys._getframe().f_lineno,pid,os.getpid(),os.getppid()))
else:#主进程
        print('line%d:fork进程%d,PID=%d,父PID=%d'%(sys._getframe().f_lineno,pid,os.getpid(),os.getppid()))
        pid = os.fork()
        if pid == 0:
                print('line%d:fork进程%d,PID=%d,父PID=%d'%(sys._getframe().f_lineno,pid,os.getpid(),os.getppid()))
        else:
                print('line%d:fork进程%d,PID=%d,父PID=%d'%(sys._getframe().f_lineno,pid,os.getpid(),os.getppid()))
pid = os.fork()
if pid == 0:
        print('line%d:fork进程%d,PID=%d,父PID=%d'%(sys._getframe().f_lineno,pid,os.getpid(),os.getppid()))
else:
        print('line%d:fork进程%d,PID=%d,父PID=%d'%(sys._getframe().f_lineno,pid,os.getpid(),os.getppid()))

from multiprocessing import Process
import time
import os

#子进程
def childProcess(name):
	print("子进程运行中,name=%s,pid=%d"%(name,os.getpid()))
	


if __name__ == '__main__':
	print('父进程%d.'%os.getpid())
	cp = Process(target=childProcess,args=('test',))
	print('子进程将要执行')
	cp.start()#启动进程实例
	#cp.terminate()#终止子进程
	alive = cp.is_alive()#判断进程是否活着
	print('is_alive:%s'%alive)
	cp.join()#阻塞，join([timeout]),join(2)阻塞2秒
	print('子进程结束')
	alive = cp.is_alive()#判断进程是否活着
	print('is_alive:%s'%alive)

from multiprocessing import Pool
import os,time,random

def worker(msg):
	t_start = time.time()
	print('%s开始执行,进程号为%d'%(msg,os.getpid()))
	#random.random() 随机生成0~1之间的浮点数
	time.sleep(random.random()*2)
	t_stop = time.time()
	print(msg,"执行完毕,耗时%0.2f"%(t_stop-t_start))

if __name__ == '__main__':
	po = Pool(3)#定义一个进程池，进程数3
	for i in range(0,10):
		po.apply_async(worker,(i,))#po.apply_async(worker,(i,))非阻塞模式，po.apply(worker,(i,))阻塞模式	
	print("---start---")
	po.close()#关闭进程池
	po.join()#等待po中的所有子进程执行完,放在close之后
	print('---end---')