Python 並發程式設計中的異常處理：確保應用程式的穩定性-Python教學-PHP中文網

Python 並發程式設計中的異常處理：確保應用程式的穩定性

WBOY

發布： 2024-02-19 23:30:27

轉載

955 人瀏覽過

Python 并发编程中的异常处理：确保应用程序的稳定性

python 並發異常處理 多執行緒 多進程協程

多執行緒

在多重執行緒環境中，每個執行緒都有自己的執行流和堆疊。異常發生時，通常只會影響該特定執行緒。為了處理執行緒中的異常，可以使用 threading.Thread() 的 join() 方法或 Thread.exc_info 屬性。

import threading

def worker_thread(name):
print(f"{name}: Starting")
raise RuntimeError("Error in thread")

try:
threads = []
for i in range(5):
thread = threading.Thread(target=worker_thread, args=(f"Thread {i}",))
threads.append(thread)

for thread in threads:
thread.start()
thread.join()
except RuntimeError as exc:
print(f"Main thread: Exception occurred in child thread: {exc}")

登入後複製

多重行程

在多進程環境中，每個進程都有自己獨立的記憶體空間和執行流。異常發生時，它會影響整個進程。要處理進程中的異常，可以使用 multiprocessing.Process() 的 join() 方法或 Process.exitcode 屬性。

import multiprocessing

def worker_process(name):
print(f"{name}: Starting")
raise RuntimeError("Error in process")

try:
processes = []
for i in range(5):
process = multiprocessing.Process(target=worker_process, args=(f"Process {i}",))
processes.append(process)

for process in processes:
process.start()
process.join()
except RuntimeError as exc:
print(f"Main process: Exception occurred in child process: {exc}")

登入後複製

協程

協程是輕量級線程，在單線程環境中執行。異常發生時，它會傳播到協程的呼叫者。要處理協程中的異常，可以使用 asyncio.Task.exception() 方法。

import asyncio

async def worker_coroutine(name):
print(f"{name}: Starting")
raise RuntimeError("Error in coroutine")

async def main():
tasks = []
for i in range(5):
task = asyncio.create_task(worker_coroutine(f"Coroutine {i}"))
tasks.append(task)

for task in tasks:
try:
await task
except RuntimeError as exc:
print(f"Main coroutine: Exception occurred in child coroutine: {exc}")

asyncio.run(main())

登入後複製

最佳實踐