- 要知道需要copy的文件夹名字,这个需要用户输入
- 创建新文件夹,存放复制后的文件
- 编写复制文件的函数
- 创建线程池,执行函数
- 加入通道,实现进度显示
代码如下:
import os
from multiprocessing import Pool, Manager
def copyFileTask(fileName, oldDir, newDir, queue):
#当前进程id
print("当前进程id : %d" % os.getpid())
#读取文件与写入文件
fr = open(oldDir + '/' + fileName)
fw = open(newDir + '/' + fileName, "w")
content = fr.read()
fw.write(content)
fr.close()
fw.close()
#当复制完一个文件,就把文件名扔进队列去
queue.put(fileName)
def main():
#0. 获取用户要copy的文件夹的名字
oldFolderName = input("请输入文件夹的名字 :")
#1. 创建一个文件夹
newFolderName = oldFolderName + "-附件"
os.mkdir(newFolderName)
#2. 获取old文件夹中的所有文件名字
nameList = os.listdir("test")
#3. 使用多线程方式copy所有文件到新文件夹中
pool = Pool(5)
#4. 创建个队列,实现进程间通信,主线程来计算进度
queue = Manager().Queue()
for item in nameList:
print("开始 进行 --%s-- 的复制"%item)
pool.apply_async(copyFileTask, (item, oldFolderName, newFolderName, queue))
#在程序的最后,做个死循环,一直从queue中取数据,只要有数据就拿出来
num = 0
allNum = len(nameList)
while True:
name = queue.get()
num += 1
copyRate = num/allNum
print("目前进度是 : %.2f%%" % (copyRate*100))
if num == allNum:
break
print("------copy 完毕-------")
if __name__ == "__main__":
main()
执行结果:
请输入文件夹的名字 :test
开始 进行 --01-不定长参数.py-- 的复制
开始 进行 --01-不定长参数的副本 2.py-- 的复制
开始 进行 --01-不定长参数的副本.py-- 的复制
开始 进行 --02-带返回值的.py-- 的复制
开始 进行 --02-带返回值的的副本 2.py-- 的复制
开始 进行 --02-带返回值的的副本.py-- 的复制
开始 进行 --03-通用装饰器.py-- 的复制
开始 进行 --03-通用装饰器的副本 2.py-- 的复制
开始 进行 --03-通用装饰器的副本.py-- 的复制
开始 进行 --04-带有参数的装饰器.py-- 的复制
开始 进行 --04-带有参数的装饰器的副本 2.py-- 的复制
开始 进行 --04-带有参数的装饰器的副本.py-- 的复制
开始 进行 --05-生成器1.py-- 的复制
开始 进行 --05-生成器1的副本 2.py-- 的复制
开始 进行 --05-生成器1的副本.py-- 的复制
开始 进行 --06-生成器2.py-- 的复制
开始 进行 --06-生成器2的副本 2.py-- 的复制
开始 进行 --06-生成器2的副本.py-- 的复制
开始 进行 --07-for循环执行生成器.py-- 的复制
开始 进行 --07-for循环执行生成器的副本 2.py-- 的复制
开始 进行 --07-for循环执行生成器的副本.py-- 的复制
开始 进行 --08-send方法.py-- 的复制
开始 进行 --08-send方法的副本 2.py-- 的复制
开始 进行 --08-send方法的副本.py-- 的复制
开始 进行 --09-类装饰器.py-- 的复制
开始 进行 --09-类装饰器的副本 2.py-- 的复制
开始 进行 --09-类装饰器的副本.py-- 的复制
开始 进行 --10-属性拦截器.py-- 的复制
开始 进行 --10-属性拦截器的副本 2.py-- 的复制
开�当前进程id : 86953
当前进程id : 86955
�� 进行 --10-属性拦截器的副本.py-- 的复制
当前进程id : 86956
当前进程id : 86957
当前进程id : 86954
开始 进行 --11-warps函数.py-- 的复制
开始 进行 --11-warps函数的副本 2.py-- 的复制
开始 进行 --11-warps函数的副本.py-- 的复制
开始 进行 --12-多进程.py-- 的复制
开始 进行 --12-多进程的副本 2.py-- 的复制
开始 进行 --12-多进程的副本.py-- 的复制
开始 进行 --13-process进程.py-- 的复制
开始 进行 --13-process进程的副本 2.py-- 的复制
开始 进行 --13-process进程的副本.py-- 的复制
开始 进行 --14-多进程copy.py-- 的复制
开始 进行 --14-多进程copy的副本 2.py-- 的复制
开始 进行 --14-多进程copy的副本.py-- 的复制
目前进度是 : 2.38%
目前进度是 : 4.76%
目前进度是 : 7.14%
目前进度是 : 9.52%
目前进度是 : 11.90%
当前进程id : 86953
当前进程id : 86956
当前进程id : 86957
当前进程id : 86955
当前进程id : 86954
目前进度是 : 14.29%
目前进度是 : 16.67%
目前进度是 : 19.05%
目前进度是 : 21.43%
目前进度是 : 23.81%
当前进程id : 86953
当前进程id : 86956
当前进程id : 86957
当前进程id : 86955
当前进程id : 86954
目前进度是 : 26.19%
目前进度是 : 28.57%
目前进度是 : 30.95%
目前进度是 : 33.33%
目前进度是 : 35.71%
当前进程id : 86953
当前进程id : 86956
当前进程id : 86955
当前进程id : 86957
当前进程id : 86954
目前进度是 : 38.10%
目前进度是 : 40.48%
目前进度是 : 42.86%
目前进度是 : 45.24%
目前进度是 : 47.62%
当前进程id : 86953
当前进程id : 86956
当前进程id : 86955
当前进程id : 86954
当前进程id : 86957
目前进度是 : 50.00%
目前进度是 : 52.38%
目前进度是 : 54.76%
目前进度是 : 57.14%
目前进度是 : 59.52%
当前进程id : 86953
当前进程id : 86956
当前进程id : 86957
当前进程id : 86954
当前进程id : 86955
目前进度是 : 61.90%
目前进度是 : 64.29%
目前进度是 : 66.67%
目前进度是 : 69.05%
目前进度是 : 71.43%
当前进程id : 86956
当前进程id : 86953
当前进程id : 86954
当前进程id : 86957
目前进度是 : 73.81%
当前进程id : 86955
目前进度是 : 76.19%
目前进度是 : 78.57%
目前进度是 : 80.95%
目前进度是 : 83.33%
当前进程id : 86956
当前进程id : 86953
目前进度是 : 85.71%
当前进程id : 86954
当前进程id : 86957
当前进程id : 86955
目前进度是 : 88.10%
目前进度是 : 90.48%
目前进度是 : 92.86%
当前进程id : 86956
当前进程id : 86953
目前进度是 : 95.24%
目前进度是 : 97.62%
目前进度是 : 100.00%
------copy 完毕-------
