#coding=utf-8
from multiprocessing import Pool,Queue
import os,time

filename = os.listdir("./test1")
#創(chuàng)建Queue隊(duì)列
queue = Queue(len(filename))


def copyFile(i):
#實(shí)現(xiàn)文件復(fù)制
oldFileName = "./test1/" + i
newFileName = "./test2/" + i
oldfile = open(oldFileName,'r')
newfile = open(newFileName,'w')
for lineContent in oldfile.readlines():
newfile.write(lineContent)

oldfile.close()
newfile.close()

if __name__ == '__main__':

pool = Pool(4)

for i in filename:
pool.apply_async(copyFile,(i,))
#隊(duì)列中將copy完成的文件放入隊(duì)列中并打印進(jìn)度
queue.put(i)
price = str(int((queue.qsize()/len(filename))*100))
print('\r'+' '*60,end='')
print('\r'+price+'%'+'=======>%s'%i,end='')
time.sleep(0.07)
print('')

pool.close()
pool.join()