python使用多进程完成文件复制的功能

进程,线程,协程&＃xff0c;这都是在实际项目中常用的东西&＃xff0c;在我的前几篇文章中有讲到过线程&＃xff0c;有兴趣的朋友可以去看看

这篇文章我们主要还是通过案例来讲解一下python中的进程

python中进程的启用方式也有很多种&＃xff0c;
1&＃xff0c;通过定义函数调用
2&＃xff0c;通过类实现
3&＃xff0c;通过进程池实现
以上的几种方法都可以

接下来来看一下我们的案例

import os
from multiprocessing import Pool,current_processdef copy_file(new_file): #先定义进程要执行的任务函数print(&＃39;{}开始复制&＃39;.format(current_process().name)) #打印当前进程的名字if os.path.isfile(new_file): #使用os模块判断当前传入 的是否为文件f &＃61; open(new_file, &＃39;r&＃39;, encoding&＃61;&＃39;gbk&＃39;) #打开文件&＃xff0c;windows下以gbk编码打开t1 &＃61; new_file.rpartition(&＃39;.&＃39;) #以文件名右边第一个点为参考进行切割&＃xff0c;切成三个元组new_file2 &＃61; t1[0] &＃43; &＃39;(附件)&＃39; &＃43; t1[1] &＃43; t1[2] #重新拼接处复制文件的名称f1 &＃61; open(new_file2, &＃39;w&＃39;, encoding&＃61;&＃39;utf-8&＃39;) #读取源文件内容&＃xff0c;打开一个新文件&＃xff0c;并写入内容content &＃61; f.read()f1.write(content)f.close()f1.close()elif os.path.isdir(new_file): #如果不是文件&＃xff0c;而是目录file_list &＃61; os.listdir(new_file) #列出目录内所有的文件或目录名称for file in file_list:new_file2 &＃61; new_file &＃43; &＃39;/&＃39; &＃43; file #重新拼接名称copy_file(new_file2) #递归return new_filedef alert(new_file): #定义回调函数print(&＃39;{}复制完成&＃39;.format(new_file))if __name__ &＃61;&＃61; &＃39;__main__&＃39;:pool &＃61; Pool() #实例化进程池dir_path &＃61; &＃39;D:/copytest&＃39; #选择要进行复制的文件夹的路径file_list &＃61; os.listdir(dir_path) #列出文件夹内所有文件或目录的名称print(file_list)for file in file_list:new_file &＃61; dir_path&＃43;&＃39;/&＃39;&＃43;file #拼接其内文件或目录的名称&＃xff0c;获得绝对路径pool.apply_async(copy_file,args&＃61;(new_file,),callback&＃61;alert) #异步执行任务&＃xff0c;并指定回调函数# pool.apply(copy_file, args&＃61;(new_file,))pool.close()pool.join()


来看一下执行结果


ok&＃xff0c;成功执行&＃xff01;&＃xff01;&＃xff01;

进程池的案例就分享到这里了