訂閱
糾錯(cuò)
加入自媒體

python修煉day32!

2019-02-22 10:49
QYFabc
關(guān)注

今日內(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ì)顯示

1  2  下一頁(yè)>  
聲明: 本文由入駐維科號(hào)的作者撰寫(xiě),觀點(diǎn)僅代表作者本人,不代表OFweek立場(chǎng)。如有侵權(quán)或其他問(wèn)題,請(qǐng)聯(lián)系舉報(bào)。

發(fā)表評(píng)論

0條評(píng)論,0人參與

請(qǐng)輸入評(píng)論內(nèi)容...

請(qǐng)輸入評(píng)論/評(píng)論長(zhǎng)度6~500個(gè)字

您提交的評(píng)論過(guò)于頻繁,請(qǐng)輸入驗(yàn)證碼繼續(xù)

  • 看不清,點(diǎn)擊換一張  刷新

暫無(wú)評(píng)論

暫無(wú)評(píng)論

人工智能 獵頭職位 更多
掃碼關(guān)注公眾號(hào)
OFweek人工智能網(wǎng)
獲取更多精彩內(nèi)容
文章糾錯(cuò)
x
*文字標(biāo)題:
*糾錯(cuò)內(nèi)容:
聯(lián)系郵箱:
*驗(yàn) 證 碼:

粵公網(wǎng)安備 44030502002758號(hào)