今日內容概述：

多進程實現(xiàn)文件夾下載、迭代器、生成器、協(xié)程

昨日回顧

程序：一個靜態(tài)的概念

進程：一個動態(tài)的概念，就是程序運行起來的狀態(tài)，用于一定的資源

線程：運行在進程之內，依賴于進程，

進程和線程區(qū)別：

共同點：都可以完成多任務區(qū)別：    線程：  threading        依賴于進程        多線程之間共享全局的變量        主線程等待子線程結束，才結束        系統(tǒng)開銷較小    進程： multiprocessing        運行起來的應用程序，占有一些資源        寫時拷貝，進程不共享全局的資源        通過隊列實現(xiàn)進程間通信        系統(tǒng)開銷比較大

進程的創(chuàng)建：

multiprocessing．Process（target＝函數(shù)名，args＝（參數(shù)））繼承方式創(chuàng)建進程class 子類名（multiprocessing．Proces）：    def run（self）：        pass

進程間通信（傳遞數(shù)據 ）：

q ＝ multiprocessing．Queue（3）      ＃ 創(chuàng)建一個隊列，可以指定可傳遞幾個數(shù)據q．put （）   ＃ 存    q．get（）     ＃ 取     q．qsize（）  ＃ 取消息數(shù)量   q．full（）  ＃ 判斷是否滿了q．empty  ＃ 判斷是否為空

進程池：

一個特殊的容器，里面創(chuàng)建了很多進程，重復利用進程作用：減少了創(chuàng)建，銷毀進程的過程，提高了效率po ＝  multiprocessing．Pool（3）  ＃ 定義一個進程池，最大進程數(shù)2po．apply＿async（要調用的目標，（要傳遞的參數(shù)））  ＃ async 異步po．close（）   ＃ 關閉進程池po．join（）   ＃ 等待所有的子進程執(zhí)行完畢

今日內容

文件夾復制：

os．listdir（）  ＃ 列出文件夾中所有的文件名os．path．getsize（）  ＃ 獲取文件的大小os．mkdir（）  ＃ 新建文件夾Pool（）  ＃ 創(chuàng)建進程池Manger（）．Queue（）  ＃ 有進程池的時候，隊列需要 Manger（）中的Queue（）    with open（＂文件名＂， “rw”） as f：    f．read（）  ＃ 讀    f．write（）  ＃ 寫

文件夾復制代碼

import multiprocessing

import os， time

def save＿folder（q， dw＿folder＿name， save＿folder＿name， file＿name）：

with open（dw＿folder＿name ＋ ＂／＂ ＋ file＿name， ＂rb＂） as f：

content ＝ f．read（）

＃ 在新創(chuàng)建的文件中寫入文件

with open（save＿folder＿name ＋ ＂／＂ ＋ file＿name， ＂wb＂） as f2：

f2．write（content）

new＿file＿size ＝ os．path．getsize（save＿folder＿name ＋ ＂／＂ ＋ file＿name）

q．put（new＿file＿size）

def main（）：

＃ 提示用戶輸入文件夾名

dw＿folder＿name ＝ input（＂請輸入要下載的文件夾的名字：＂）

try：
       ＃ 創(chuàng)建一個新文件夾
       save＿folder＿name ＝ dw＿folder＿name ＋ ＂［嘿嘿嘿］＂
       os．mkdir（save＿folder＿name）

except：

pass

＃ 獲取目標文件夾中的所有的文件　os．listdir（）

file＿names ＝ os．listdir（dw＿folder＿name）

＃ 添加進程池

po ＝ multiprocessing．Pool（3）

＃ 創(chuàng)建隊列

q ＝ multiprocessing．Manager（）．Queue（）

＃ 從目標文件夾中讀取文件

for file＿name in file＿names：
       po．apply＿async（save＿folder， （q， dw＿folder＿name， save＿folder＿name， file＿name））

po．close（）

＃ po．join（）

＃ 獲取文件夾的大小

folder＿size ＝ 0

for old＿file in file＿names：

old＿file＿s ＝ os．path．getsize（dw＿folder＿name ＋ ＂／＂ ＋ old＿file）

folder＿size ＋＝ old＿file＿s

print（＂文件夾總大小為：�。�d＂ ％ folder＿size）

new＿file＿size ＝ 0

＃ 顯示進度

while True：

s ＝ q．get（）
       new＿file＿size ＋＝ s
       time．sleep（0．1）
       print（＂拷貝的進度為： ％．2f ％％＂ ％ （new＿file＿size ／ folder＿size ＊ 100）， end＝＂＂）
       if new＿file＿size ＞＝ folder＿size：

break

print（）

if ＿＿name＿＿ ＝＝ ＂＿＿main＿＿＂：

main（）

進程池中的進程出現(xiàn)異常不會顯示