Pythonでループ処理をマルチスレッドで処理する方法を教えてください。

2年 ago
光, 明
1 minute

Pythonでは、マルチスレッドを使ってループを処理する方法はいくつかあります。以下はその一般的な2つの方法です。

  1. スレッド
  2. トピック
  3. 開始(はじ)める
  4. 結合する
import threading
def process_loop(start, end):
# 这里是循环的处理逻辑
for i in range(start, end):
# 处理迭代
# 定义循环的起始和结束值
start = 0
end = 100
# 创建多个线程对象
num_threads = 4
threads = []
for i in range(num_threads):
t = threading.Thread(target=process_loop, args=(start, end))
threads.append(t)
start = end
end += 100
# 启动线程
for t in threads:
t.start()
# 等待所有线程结束
for t in threads:
t.join()
  1. concurrent.futures.ThreadPoolExecutor
  2. 送信
  3. シャットダウン()
from concurrent.futures import ThreadPoolExecutor
def process_iteration(i):
# 处理迭代
# 定义循环的起始和结束值
start = 0
end = 100
# 创建线程池对象
num_threads = 4
with ThreadPoolExecutor(max_workers=num_threads) as executor:
# 提交循环迭代的任务
futures = [executor.submit(process_iteration, i) for i in range(start, end)]
# 等待所有任务执行完成
for future in futures:
future.result()

どちらのやり方でもマルチスレッドで処理するループを作れますが、どちらを採用するかはあなたのニーズや好みによって異なります。

bannerAds