今日內(nèi)容概述：

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

昨日回顧

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

進(jìn)程：一個(gè)動(dòng)態(tài)的概念，就是程序運(yùn)行起來(lái)的狀態(tài)，用于一定的資源

線程：運(yùn)行在進(jìn)程之內(nèi)，依賴于進(jìn)程，

進(jìn)程和線程區(qū)別：

共同點(diǎn)：都可以完成多任務(wù)區(qū)別：    線程：  threading        依賴于進(jìn)程        多線程之間共享全局的變量        主線程等待子線程結(jié)束，才結(jié)束        系統(tǒng)開(kāi)銷較小    進(jìn)程： multiprocessing        運(yùn)行起來(lái)的應(yīng)用程序，占有一些資源        寫(xiě)時(shí)拷貝，進(jìn)程不共享全局的資源        通過(guò)隊(duì)列實(shí)現(xiàn)進(jìn)程間通信        系統(tǒng)開(kāi)銷比較大

進(jìn)程的創(chuàng)建：

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

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

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

進(jìn)程池：

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

今日內(nèi)容

文件夾復(fù)制：

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

文件夾復(fù)制代碼

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)建的文件中寫(xiě)入文件

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（＂請(qǐng)輸入要下載的文件夾的名字：＂）

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

except：

pass

＃ 獲取目標(biāo)文件夾中的所有的文件　os．listdir（）

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

＃ 添加進(jìn)程池

po ＝ multiprocessing．Pool（3）

＃ 創(chuàng)建隊(duì)列

q ＝ multiprocessing．Manager（）．Queue（）

＃ 從目標(biāo)文件夾中讀取文件

for file＿name in file＿names：
       po．a(chǎn)pply＿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

＃ 顯示進(jìn)度

while True：

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

break

print（）

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

main（）

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