import multiprocessing 
def process(index):
print(f'Process: {index}')
if __name__ == '__main__':
for i in range(5):
p = multiprocessing.Process(target=process, args=(i,))p.start

Process: 0 
Process: 1
Process: 2
Process: 3
Process: 4

from multiprocessing import Process
import timeclass MyProcess(Process):
def __init__(self,loop):
Process.__init__(self)
self.loop = loop
def run(self):
for count in range(self.loop):
time.sleep(1)
print(f'Pid:{self.pid} LoopCount: {count}')
if __name__ == '__main__':
for i in range(2,5):
p = MyProcess(i)
p.start

Pid:12976 LoopCount: 0
Pid:15012 LoopCount: 0
Pid:11976 LoopCount: 0
Pid:12976 LoopCount: 1
Pid:15012 LoopCount: 1
Pid:11976 LoopCount: 1
Pid:15012 LoopCount: 2
Pid:11976 LoopCount: 2
Pid:11976 LoopCount: 3

from multiprocessing import Queue
import multiprocessing
def download(p): # 下載數(shù)據(jù)
lst = [11,22,33,44]
for item in lst:
p.put(item)print('數(shù)據(jù)已經(jīng)下載成功....')
def savedata(p):
lst = 
while True:
data = p.getlst.append(data)if p.empty:
breakprint(lst)def main:p1 = Queuet1 = multiprocessing.Process(target=download,args=(p1,))t2 = multiprocessing.Process(target=savedata,args=(p1,))t1.startt2.startif __name__ == '__main__':
main

數(shù)據(jù)已經(jīng)下載成功....
[11, 22, 33, 44]

import multiprocessing
a = 1
def demo1:
global a
a += 1
def demo2:
print(a)def main:
t1 = multiprocessing.Process(target=demo1)t2 = multiprocessing.Process(target=demo2)t1.startt2.startif __name__ == '__main__':
main

from multiprocessing import Pool
import os,time,random
def worker(a):t_start = time.time
print('%s開始執(zhí)行,進(jìn)程號為%d'%(a,os.getpid))
time.sleep(random.random*2)
t_stop = time.time
print(a,"執(zhí)行完成,耗時(shí)%0.2f"%(t_stop-t_start))
if __name__ == '__main__':
po = Pool(3) # 定義一個(gè)進(jìn)程池
for i in range(0,10):
po.apply_async(worker,(i,)) # 向進(jìn)程池中添加worker的任務(wù)print("--start--")
po.closepo.joinprint("--end--")

--start--
0開始執(zhí)行,進(jìn)程號為6664
1開始執(zhí)行,進(jìn)程號為47722開始執(zhí)行,進(jìn)程號為132560 執(zhí)行完成,耗時(shí)0.18
3開始執(zhí)行,進(jìn)程號為6664
2 執(zhí)行完成,耗時(shí)0.16
4開始執(zhí)行,進(jìn)程號為13256
1 執(zhí)行完成,耗時(shí)0.67
5開始執(zhí)行,進(jìn)程號為4772
4 執(zhí)行完成,耗時(shí)0.87
6開始執(zhí)行,進(jìn)程號為13256
3 執(zhí)行完成,耗時(shí)1.59
7開始執(zhí)行,進(jìn)程號為6664
5 執(zhí)行完成,耗時(shí)1.15
8開始執(zhí)行,進(jìn)程號為4772
7 執(zhí)行完成,耗時(shí)0.40
9開始執(zhí)行,進(jìn)程號為6664
6 執(zhí)行完成,耗時(shí)1.80
8 執(zhí)行完成,耗時(shí)1.49
9 執(zhí)行完成,耗時(shí)1.36
--end--

import multiprocessing
import osimport time

def copy_file(Q,oldfolderName,newfolderName,file_name):
# 文件復(fù)制,不需要返回time.sleep(0.5)
# print('\r從%s文件夾復(fù)制到%s文件夾的%s文件'%(oldfolderName,newfolderName,file_name),end='')
old_file = open(oldfolderName + '/' + file_name,'rb') # 待復(fù)制文件
content = old_file.readold_file.closenew_file = open(newfolderName + '/' + file_name,'wb') # 復(fù)制出的新文件
new_file.write(content)
new_file.closeQ.put(file_name) # 向Q隊(duì)列中添加文件

def main:
oldfolderName = input('請輸入要復(fù)制的文件夾名字:') # 步驟1獲取要復(fù)制文件夾的名字(可以手動(dòng)創(chuàng)建,也可以通過代碼創(chuàng)建,這里我們手動(dòng)創(chuàng)建)
newfolderName = oldfolderName + '復(fù)件'
# 步驟二 創(chuàng)建一個(gè)新的文件夾if not os.path.exists(newfolderName):
os.mkdir(newfolderName)
filenames = os.listdir(oldfolderName) # 3.獲取文件夾里面所有待復(fù)制的文件名
# print(filenames)
pool = multiprocessing.Pool(5) # 4.創(chuàng)建進(jìn)程池
Q = multiprocessing.Manager.Queue # 創(chuàng)建隊(duì)列,進(jìn)行通信for file_name in filenames:
pool.apply_async(copy_file,args=(Q,oldfolderName,newfolderName,file_name)) # 5.向進(jìn)程池添加任務(wù)
po.closecopy_file_num = 0
file_count = len(filenames)
# 不知道什么時(shí)候完成,所以定義一個(gè)死循環(huán)while True:
file_name = Q.getcopy_file_num += 1
time.sleep(0.2)
print('\r拷貝進(jìn)度%.2f %%'%(copy_file_num * 100/file_count),end='') # 做一個(gè)拷貝進(jìn)度條
if copy_file_num >= file_count:
break

if __name__ == '__main__':
main