python进程池实现的多进程文件夹copy器完整示例
本文实例讲述了python进程池实现的多进程文件夹copy器。分享给大家供大家参考，具体如下：
应用：文件夹copy器（多进程版）
importmultiprocessing
importos
importtime
importrandom
defcopy_file(queue,file_name,source_folder_name,dest_folder_name):
"""copy文件到指定的路径"""
f_read=open(source_folder_name+"/"+file_name,"rb")
f_write=open(dest_folder_name+"/"+file_name,"wb")
whileTrue:
time.sleep(random.random())
content=f_read.read(1024)
ifcontent:
f_write.write(content)
else:
break
f_read.close()
f_write.close()
#发送已经拷贝完毕的文件名字
queue.put(file_name)
defmain():
#获取要复制的文件夹
source_folder_name=input("请输入要复制文件夹名字:")
#整理目标文件夹
dest_folder_name=source_folder_name+"[副本]"
#创建目标文件夹
try:
os.mkdir(dest_folder_name)
except:
pass#如果文件夹已经存在，那么创建会失败
#获取这个文件夹中所有的普通文件名
file_names=os.listdir(source_folder_name)
#创建Queue
queue=multiprocessing.Manager().Queue()
#创建进程池
pool=multiprocessing.Pool(3)
forfile_nameinfile_names:
#向进程池中添加任务
pool.apply_async(copy_file,args=(queue,file_name,source_folder_name,dest_folder_name))
#主进程显示进度
pool.close()
all_file_num=len(file_names)
whileTrue:
file_name=queue.get()
iffile_nameinfile_names:
file_names.remove(file_name)
copy_rate=(all_file_num-len(file_names))*100/all_file_num
print("\r%.2f...(%s)"%(copy_rate,file_name)+""*50,end="")
ifcopy_rate>=100:
break
print()
if__name__=="__main__":
main()
更多关于Python相关内容感兴趣的读者可查看本站专题：《Python进程与线程操作技巧总结》、《Python数据结构与算法教程》、《Python函数使用技巧总结》、《Python字符串操作技巧汇总》、《Python入门与进阶经典教程》、《Python+MySQL数据库程序设计入门教程》及《Python常见数据库操作技巧汇总》
希望本文所述对大家Python程序设计有所帮助。
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。