Python多进程实现文件夹复制与进度监控

巷口听风

发布时间：2026-10-13 | 2人浏览过

原创

本文介绍利用Python的multiprocessing模块实现文件夹内所有文件的并行复制功能。通过创建子进程处理单个文件读写，并使用Queue队列统计已完成任务数，实时计算并打印复制进度百分比，最终实现高效且可视化的文件传输过程。

本文分享了一个使用Python多进程技术实现文件下载与传输功能的具体代码示例，供读者参考学习。

具体需求如下：

实现文件夹的完整拷贝功能，包括处理文件夹内的子文件，并在执行过程中实时打印拷贝进度。

主要使用的模块包括：

os模块用于文件和目录操作，multiprocessing模块用于多进程管理。

具体实现代码如下：

import multiprocessing
import os


def deal_file(old_dir,new_dir,file_name,queue):
  # 打开以存在文件
  old_file = open(os.path.join(old_dir,file_name),"rb")
  # 创建新文件
  new_file = open(os.path.join(new_dir,file_name),"wb")
  # 循环将内容写入新文件
  while True:
    # 单行读取
    data = old_file.readline()
    # 如果有内容写入否则退出
    if data:

      new_file.write(data) 
    else:
      break

  # 关闭文件
  old_file.close()
  new_file.close()
  # 向队列中添加值用以计数,参数可填任意值
  queue.put(file_name)

def main():
  # 创建用户输入文件的备份
  old_dir = input("请输入文件名:")

  new_dir = "备份"+old_dir

  os.mkdir(new_dir)
  # 列出文件夹内的文件列表
  file_list = os.listdir(old_dir)

  queue = multiprocessing.Queue(128)
  for file_name in file_list:

    pro = multiprocessing.Process(target=deal_file,args=(old_dir,new_dir,file_name,queue))
    # 创建子进程
    pro.start()
  # 定义变量用以计数
  num = 0
  while True:
    # 取出队列中的值
    queue.get()
    # 计数器+1
    num += 1
    # 打印下载进度
    print("\r文件已下载%.2f %%" % (num/len(file_list)*100),end="")
    # 如果计数等于文件长度提示完成退出
    if num == len(file_list):
      print("文件下载完成")
      break
if __name__ == "__main__":

  main()

以上为本文的全部内容，希望这些代码能对读者的学习有所帮助，同时也欢迎大家继续支持本站获取更多技术资源。