一加Ace2 Pro官宣：普及16G內(nèi)存 引領(lǐng)24G
一加官方今天繼續(xù)為本月發(fā)布的新機(jī)一加Ace2 Pro帶來預(yù)熱，公布了內(nèi)存方面的信息。“淘汰 8GB ，12GB 起步，16GB 普及，24GB 引領(lǐng)，還有呢？#一加Ace2Pro#，2023 年 8 月，敬請(qǐng)期待。”同時(shí)
今天我們要一起探索的是Python編程中的一個(gè)超炫酷領(lǐng)域——多線程！想象一下，你的程序能像超人一樣同時(shí)處理多個(gè)任務(wù)，是不是很激動(dòng)人心？讓我們以輕松愉快的方式，一步步揭開它的神秘面紗。
想象你是個(gè)廚房大廚，一邊炒菜一邊洗菜，這就是多線程的日常。在Python里，threading模塊就是我們的廚房神器。
import threadingdef cook(): # 炒菜線程 print("炒菜中...") def wash(): # 洗菜線程 print("洗菜中...")# 創(chuàng)建線程對(duì)象thread1 = threading.Thread(target=cook)thread2 = threading.Thread(target=wash)# 啟動(dòng)線程thread1.start()thread2.start()# 等待所有線程完成thread1.join()thread2.join()print("飯做好啦！")這段代碼中，Thread類用來創(chuàng)建線程，target參數(shù)指定線程要執(zhí)行的函數(shù)。start()讓線程開始執(zhí)行，而join()確保主線程等待這些小線程們完成它們的任務(wù)。
在多線程世界，如果兩個(gè)線程同時(shí)操作同一資源（比如共享食材），就可能出亂子。這時(shí)就需要“鎖”來幫忙了，Python里的鎖叫Lock。
import threadingshared_resource = 0lock = threading.Lock()def increase(): global shared_resource lock.acquire() # 上鎖，防止同時(shí)訪問 shared_resource += 1 lock.release() # 解鎖，釋放控制權(quán)threads = [threading.Thread(target=increase) for _ in range(100)]for t in threads: t.start()for t in threads: t.join()print("共享資源的最終值:", shared_resource)每次訪問共享資源前，先acquire()上鎖，操作完后release()解鎖，這樣就避免了數(shù)據(jù)混亂。
但鎖用不好也會(huì)出問題，就像兩個(gè)廚師互相等待對(duì)方手中的鍋，形成了死鎖。要小心設(shè)計(jì)，避免循環(huán)等待。
想象一下，如果你每次炒菜都要新雇一個(gè)廚師，那得多浪費(fèi)？線程池(ThreadPoolExecutor)就是解決這個(gè)問題的神器，它預(yù)先創(chuàng)建好一些線程，重復(fù)利用。
from concurrent.futures import ThreadPoolExecutordef task(n): print(f"執(zhí)行任務(wù){(diào)n}")with ThreadPoolExecutor(max_workers=5) as executor: executor.map(task, range(1, 6))這里，ThreadPoolExecutor創(chuàng)建了一個(gè)最多有5個(gè)線程的池，map()函數(shù)并行執(zhí)行任務(wù)列表中的每個(gè)任務(wù)。
守護(hù)線程就像廚房的清潔工，在所有其他線程完成后默默清理。通過setDaemon(True)設(shè)置線程為守護(hù)線程。
def cleaner(): while True: # 假設(shè)這是一個(gè)無限循環(huán)，清理任務(wù) print("打掃廚房...") if not other_threads_running(): # 假定函數(shù)檢查其他線程是否還在運(yùn)行 breakclean_thread = threading.Thread(target=cleaner)clean_thread.setDaemon(True)clean_thread.start()# 其他線程的代碼...print("廚房關(guān)閉，清潔完成。")雖然Python標(biāo)準(zhǔn)庫沒有直接提供線程優(yōu)先級(jí)的功能，但可以通過隊(duì)列等間接實(shí)現(xiàn)。不過，大多數(shù)情況下，Python的線程調(diào)度是公平的，不需要擔(dān)心。
Python的GIL是一個(gè)讓人又愛又恨的東西，它保證了任何時(shí)刻只有一個(gè)線程在執(zhí)行Python字節(jié)碼，這對(duì)多核CPU來說不是個(gè)好消息。但在I/O密集型任務(wù)中，GIL的影響沒那么大。
不同線程需要不同的“調(diào)料”怎么辦？threading.local()來幫忙，它提供了線程本地的存儲(chǔ)空間。
import threadinglocal_data = threading.local()def set_data(): local_data.value = "這是我的調(diào)料"def get_data(): print(local_data.value)t1 = threading.Thread(target=set_data)t2 = threading.Thread(target=get_data)t1.start()t2.start()t1.join()t2.join()在這里，每個(gè)線程都有自己的local_data，互不影響。
線程中的異常不會(huì)自動(dòng)傳遞到主線程，需要用try-except捕獲處理。
def risky_task(): raise ValueError("出錯(cuò)了!")try: t = threading.Thread(target=risky_task) t.start() t.join()except ValueError as e: print(f"捕獲到異常: {e}")確保即使線程出錯(cuò)，程序也不會(huì)突然崩潰。
最后，來點(diǎn)實(shí)戰(zhàn)吧，比如多線程下載圖片，體驗(yàn)速度的提升。
import requestsimport threadingfrom queue import Queuedef download_image(url): response = requests.get(url) with open(f"image_{url[-4:]}", 'wb') as f: f.write(response.content) print(f"下載完成：{url}")image_urls = ["http://example.com/image1.jpg", "http://example.com/image2.jpg"] # 假設(shè)的URLqueue = Queue()threads = []for url in image_urls: queue.put(url)def worker(): while not queue.empty(): url = queue.get() download_image(url) queue.task_done()for _ in range(3): # 啟動(dòng)3個(gè)下載線程 t = threading.Thread(target=worker) t.start() threads.append(t)# 等待所有下載任務(wù)完成for t in threads: t.join()print("所有圖片下載完成！")通過隊(duì)列分配任務(wù)給多個(gè)線程，實(shí)現(xiàn)了并行下載，大大提高了效率。
好啦，今天的探險(xiǎn)就到這里！希望你已經(jīng)對(duì)Python多線程有了更深入的理解。
本文鏈接：http://www.tebozhan.com/showinfo-26-89711-0.htmlPython 多線程編程的十個(gè)關(guān)鍵概念
聲明：本網(wǎng)頁內(nèi)容旨在傳播知識(shí)，若有侵權(quán)等問題請(qǐng)及時(shí)與本網(wǎng)聯(lián)系，我們將在第一時(shí)間刪除處理。郵件：2376512515@qq.com
下一篇： C# 線程池的使用方法
Copyright ? 2016-2023 天津谷騏科技有限公司 版權(quán)所有 sitemap.xml
違法及侵權(quán)請(qǐng)聯(lián)系：2376512515@qq.com 津ICP備18001702號(hào)
津公網(wǎng)安備 12010102000574號(hào)