python修煉day32!
今日內(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)開銷較小 進(jìn)程: multiprocessing 運(yùn)行起來(lái)的應(yīng)用程序,占有一些資源 寫時(shí)拷貝,進(jìn)程不共享全局的資源 通過(guò)隊(duì)列實(shí)現(xiàn)進(jìn)程間通信 系統(tǒng)開銷比較大
進(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() # 寫
文件夾復(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)建的文件中寫入文件
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ì)顯示

發(fā)表評(píng)論
請(qǐng)輸入評(píng)論內(nèi)容...
請(qǐng)輸入評(píng)論/評(píng)論長(zhǎng)度6~500個(gè)字
最新活動(dòng)更多
-
3月27日立即報(bào)名>> 【工程師系列】汽車電子技術(shù)在線大會(huì)
-
4月30日立即下載>> 【村田汽車】汽車E/E架構(gòu)革新中,新智能座艙挑戰(zhàn)的解決方案
-
5月15-17日立即預(yù)約>> 【線下巡回】2025年STM32峰會(huì)
-
即日-5.15立即報(bào)名>>> 【在線會(huì)議】安森美Hyperlux™ ID系列引領(lǐng)iToF技術(shù)革新
-
5月15日立即下載>> 【白皮書】精確和高效地表征3000V/20A功率器件應(yīng)用指南
-
5月16日立即參評(píng) >> 【評(píng)選啟動(dòng)】維科杯·OFweek 2025(第十屆)人工智能行業(yè)年度評(píng)選
推薦專題
- 1 UALink規(guī)范發(fā)布:挑戰(zhàn)英偉達(dá)AI統(tǒng)治的開始
- 2 北電數(shù)智主辦酒仙橋論壇,探索AI產(chǎn)業(yè)發(fā)展新路徑
- 3 降薪、加班、裁員三重暴擊,“AI四小龍”已折戟兩家
- 4 “AI寒武紀(jì)”爆發(fā)至今,五類新物種登上歷史舞臺(tái)
- 5 國(guó)產(chǎn)智駕迎戰(zhàn)特斯拉FSD,AI含量差幾何?
- 6 光計(jì)算迎來(lái)商業(yè)化突破,但落地仍需時(shí)間
- 7 東陽(yáng)光:2024年扭虧、一季度凈利大增,液冷疊加具身智能打開成長(zhǎng)空間
- 8 地平線自動(dòng)駕駛方案解讀
- 9 封殺AI“照騙”,“淘寶們”終于不忍了?
- 10 優(yōu)必選:營(yíng)收大增主靠小件,虧損繼續(xù)又逢關(guān)稅,能否乘機(jī)器人東風(fēng)翻身?