from multiprocessing import Process
import osdef func1(num):print(num)if __name__ == '__main__':print('主进程id为：', os.getpid()) #获取主进程idfor i in range(10):p = Process(target=func1,args=(i,)) #创建子进程p.start() #调起子进程print('子进程名称为：', p.name)  #获取子进程名称print('子进程id为', p.pid)  #获取子进程id

a = 1
def func2():global aa +=1print('子进程中的a:', a)  #子进程中的a: 2
if __name__ == '__main__':p = Process(target=func2)p.start()p.join()print('主进程中的a:', a) #主进程中的a: 1

from multiprocessing import Process, Queue
import os, time, randomdef write_queue(q):   #写数据到队列for value in range(10):print('Put %s to queue...'%value)q.put(value)time.sleep(2) #每隔2秒写入数据def read_queue(q):    #从队列读取数据while True:value = q.get(True)print('Get %s from queue.' %value)time.sleep(3) #每隔3秒读取数据if q.empty(): #若队列为空，退出循环print('队列为空，请输入数据后再读')breakif __name__=='__main__':q = Queue()    #父进程创建Queue，传给子进程pw = Process(target=write_queue, args=(q,))pr = Process(target=read_queue, args=(q,))start = time.time()pw.start()     #启动子进程pw，写数据pr.start()     #启动子进程pr，读数据
    pw.join()end_pw = time.time()run_pw = end_pw - start #计算写数据的时间pr.join()               #terminate()可强行终止进程end_pr = time.time()run_pr = end_pr - start #计算读数据的时间print('写数据花费时间：', run_pw, '读数据花费时间', run_pr)

from multiprocessing import Process, Manager
import timedef func(p_dict, p_list): #入参：p_dict为字典，p_list为listfor i in range(10):time.sleep(2)k = str(i) + '*' + str(i)p_dict[k] = i * ifor i in range(10):time.sleep(1)p_list.append(i)if __name__ == "__main__":manager = Manager()dt = manager.dict() #创建dict实例lt = manager.list() #创建list实例start = time.time()p = Process(target=func, args=(dt, lt))p.start()p.join()end = time.time()run_time = end - startprint(dt, '\n', lt)print('运行时间为：',run_time) #运行时间大约为30s

from multiprocessing import Pool
import time
def func2(num):time.sleep(2)print(num)
if __name__ == '__main__':start = time.time()pool = Pool(5)  #创建进程池，最多可同时运行5个子进程for i in range(5):pool.apply_async(func=func2,args=(i,)) #apply_async()调用子进程print('执行主程序')pool.close()pool.join()    #等待子进程结束再结束主进程end = time.time()run_time = end - startprint(run_time)