只限于當(dāng)前路徑的
import os
from multiprocessing import Pool, Manager
# copy 文件
def work_copy_file(file, olderFileName, newFileName, queue):
# 首先打開一個文件
fread = open(olderFileName + "/" + file, "r", encoding='UTF-8')
fwrite = open(newFileName + "/" + file, "w", encoding='UTF-8')
content = fread.read()
fwrite.write(content)
fread.close()
fwrite.close()
queue.put(file)
pass
def main():
olderFileName = input("請輸入您的文件名字")
newFileName = olderFileName + "-復(fù)制文件"
os.mkdir(newFileName) # 創(chuàng)建新文件
olderFileNames = os.listdir(olderFileName) # 列出文件夾中所有的數(shù)據(jù)
# 在進(jìn)程池中進(jìn)行操作
p = Pool(5)
queue = Manager().Queue()
for file in olderFileNames:
p.apply_async(work_copy_file, (file, olderFileName, newFileName, queue))
num = 0
allNum = len(olderFileNames)
while num != allNum:
queue.get()
num += 1
copyRate = num / allNum
print("進(jìn)度是", copyRate * 100, )
print('完成了')
if __name__ == '__main__':
main()
