今日內(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)，依賴(lài)于進(jìn)程，
進(jìn)程和線程區(qū)別：
共同點(diǎn)：都可以完成多任務(wù)區(qū)別： 線程： threading 依賴(lài)于進(jìn)程 多線程之間共享全局的變量 主線程等待子線程結(jié)束，才結(jié)束 系統(tǒng)開(kāi)銷(xiāo)較小 進(jìn)程： multiprocessing 運(yùn)行起來(lái)的應(yīng)用程序，占有一些資源 寫(xiě)時(shí)拷貝，進(jìn)程不共享全局的資源 通過(guò)隊(duì)列實(shí)現(xiàn)進(jìn)程間通信 系統(tǒng)開(kāi)銷(xiāo)比較大
進(jìn)程的創(chuàng)建：
multiprocessing．Process（target＝函數(shù)名，args＝（參數(shù)））繼承方式創(chuàng)建進(jìn)程class 子類(lèi)名（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（） ＃ 判斷是否滿(mǎn)了q．empty ＃ 判斷是否為空
進(jìn)程池：
一個(gè)特殊的容器，里面創(chuàng)建了很多進(jìn)程，重復(fù)利用進(jìn)程作用：減少了創(chuàng)建，銷(xiāo)毀進(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（）：
＃ 提示用戶(hù)輸入文件夾名
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ì)顯示
12下一頁(yè)>（免責(zé)聲明：本網(wǎng)站內(nèi)容主要來(lái)自原創(chuàng)、合作伙伴供稿和第三方自媒體作者投稿，凡在本網(wǎng)站出現(xiàn)的信息，均僅供參考。本網(wǎng)站將盡力確保所提供信息的準(zhǔn)確性及可靠性，但不保證有關(guān)資料的準(zhǔn)確性及可靠性，讀者在使用前請(qǐng)進(jìn)一步核實(shí)，并對(duì)任何自主決定的行為負(fù)責(zé)。本網(wǎng)站對(duì)有關(guān)資料所引致的錯(cuò)誤、不確或遺漏，概不負(fù)任何法律責(zé)任。
任何單位或個(gè)人認(rèn)為本網(wǎng)站中的網(wǎng)頁(yè)或鏈接內(nèi)容可能涉嫌侵犯其知識(shí)產(chǎn)權(quán)或存在不實(shí)內(nèi)容時(shí)，應(yīng)及時(shí)向本網(wǎng)站提出書(shū)面權(quán)利通知或不實(shí)情況說(shuō)明，并提供身份證明、權(quán)屬證明及詳細(xì)侵權(quán)或不實(shí)情況證明。本網(wǎng)站在收到上述法律文件后，將會(huì)依法盡快聯(lián)系相關(guān)文章源頭核實(shí)，溝通刪除相關(guān)內(nèi)容或斷開(kāi)相關(guān)鏈接。 ）
