python進程池實現(xiàn)的多進程文件夾copy器完整示例

更新時間：2019年11月27日 09:19:26 作者：lislislislislis

這篇文章主要介紹了python進程池實現(xiàn)的多進程文件夾copy器,結(jié)合完整實例形式分析了Python基于多進程與進程池的文件操作相關(guān)實現(xiàn)技巧,需要的朋友可以參考下

本文實例講述了python進程池實現(xiàn)的多進程文件夾copy器。分享給大家供大家參考，具體如下：

應(yīng)用：文件夾copy器（多進程版）

import multiprocessing
import os
import time
import random
def copy_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")
  while True:
    time.sleep(random.random())
    content = f_read.read(1024)
    if content:
      f_write.write(content)
    else:
      break
  f_read.close()
  f_write.close()
  # 發(fā)送已經(jīng)拷貝完畢的文件名字
  queue.put(file_name)
def main():
  # 獲取要復(fù)制的文件夾
  source_folder_name = input("請輸入要復(fù)制文件夾名字:")
  # 整理目標文件夾
  dest_folder_name = source_folder_name + "[副本]"
  # 創(chuàng)建目標文件夾
  try:
    os.mkdir(dest_folder_name)
  except:
    pass # 如果文件夾已經(jīng)存在，那么創(chuàng)建會失敗
  # 獲取這個文件夾中所有的普通文件名
  file_names = os.listdir(source_folder_name)
  # 創(chuàng)建Queue
  queue = multiprocessing.Manager().Queue()
  # 創(chuàng)建進程池
  pool = multiprocessing.Pool(3)
  for file_name in file_names:
    # 向進程池中添加任務(wù)
    pool.apply_async(copy_file, args=(queue, file_name, source_folder_name, dest_folder_name))
  # 主進程顯示進度
  pool.close()
  all_file_num = len(file_names)
  while True:
    file_name = queue.get()
    if file_name in file_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="")
    if copy_rate >= 100:
      break
  print()
if __name__ == "__main__":
  main()

更多關(guān)于Python相關(guān)內(nèi)容感興趣的讀者可查看本站專題：《Python進程與線程操作技巧總結(jié)》、《Python數(shù)據(jù)結(jié)構(gòu)與算法教程》、《Python函數(shù)使用技巧總結(jié)》、《Python字符串操作技巧匯總》、《Python入門與進階經(jīng)典教程》、《Python+MySQL數(shù)據(jù)庫程序設(shè)計入門教程》及《Python常見數(shù)據(jù)庫操作技巧匯總》

希望本文所述對大家Python程序設(shè)計有所幫助。

您可能感興趣的文章: