[Python] スレッドの終了を待機するjoinメソッドの使い方

import threading
import time
def worker():
    print("スレッドが開始されました。")
    time.sleep(2)  # 2秒間の処理
    print("スレッドが終了しました。")
# スレッドの作成
thread = threading.Thread(target=worker)
thread.start()  # スレッドの開始
thread.join()   # スレッドの終了を待機
print("メインスレッドが終了しました。")

スレッドが開始されました。
スレッドが終了しました。
メインスレッドが終了しました。

import threading
import time
def worker():
    print("スレッドが開始されました。")
    time.sleep(5)  # 5秒間の処理
    print("スレッドが終了しました。")
thread = threading.Thread(target=worker)
thread.start()
thread.join(timeout=3)  # 3秒のタイムアウトを設定
if thread.is_alive():
    print("スレッドはまだ実行中です。")
else:
    print("スレッドは終了しました。")

スレッドが開始されました。
スレッドはまだ実行中です。

import threading
import time
def worker(thread_id):
    print(f"スレッド {thread_id} が開始されました。")
    time.sleep(2)  # 2秒間の処理
    print(f"スレッド {thread_id} が終了しました。")
threads = []
for i in range(3):  # 3つのスレッドを作成
    thread = threading.Thread(target=worker, args=(i,))
    threads.append(thread)
    thread.start()  # スレッドの開始
for thread in threads:
    thread.join()  # 各スレッドの終了を待機
print("全てのスレッドが終了しました。")

スレッド 0 が開始されました。
スレッド 1 が開始されました。
スレッド 2 が開始されました。
スレッド 0 が終了しました。
スレッド 1 が終了しました。
スレッド 2 が終了しました。
全てのスレッドが終了しました。

import threading
result = 0
def worker():
    global result
    for i in range(5):
        result += i
    print("スレッドがデータを更新しました。")
thread = threading.Thread(target=worker)
thread.start()
thread.join()  # スレッドの終了を待機
print(f"最終結果: {result}")

スレッドがデータを更新しました。
最終結果: 10

import threading
import time
def worker():
    print("スレッドが開始されました。")
    time.sleep(5)  # 5秒間の処理
    print("スレッドが終了しました。")
thread = threading.Thread(target=worker)
thread.start()
thread.join(timeout=3)  # 3秒のタイムアウトを設定
if thread.is_alive():
    print("スレッドはまだ実行中です。")
else:
    print("スレッドは終了しました。")

スレッドが開始されました。
スレッドはまだ実行中です。

from concurrent.futures import ThreadPoolExecutor
import time
def worker(thread_id):
    print(f"スレッド {thread_id} が開始されました。")
    time.sleep(2)  # 2秒間の処理
    print(f"スレッド {thread_id} が終了しました。")
    return thread_id
with ThreadPoolExecutor(max_workers=3) as executor:
    futures = [executor.submit(worker, i) for i in range(3)]
    for future in futures:
        result = future.result()  # スレッドの結果を取得
        print(f"スレッド {result} の結果を取得しました。")

スレッド 0 が開始されました。
スレッド 1 が開始されました。
スレッド 2 が開始されました。
スレッド 0 が終了しました。
スレッド 1 が終了しました。
スレッド 2 が終了しました。
スレッド 0 の結果を取得しました。
スレッド 1 の結果を取得しました。
スレッド 2 の結果を取得しました。

import threading
import time
def daemon_worker():
    while True:
        print("デーモンスレッドが動作中...")
        time.sleep(1)
daemon_thread = threading.Thread(target=daemon_worker)
daemon_thread.daemon = True  # デーモンスレッドに設定
daemon_thread.start()
time.sleep(3)  # メインスレッドが3秒間待機
print("メインスレッドが終了します。")

デーモンスレッドが動作中...
デーモンスレッドが動作中...
デーモンスレッドが動作中...
メインスレッドが終了します。

import threading
def worker():
    raise ValueError("スレッド内でエラーが発生しました。")
thread = threading.Thread(target=worker)
thread.start()
thread.join()  # スレッドの終了を待機
try:
    thread.join()  # 例外を捕捉するために再度joinを呼び出す
except Exception as e:
    print(f"エラーが発生しました: {e}")

エラーが発生しました: スレッド内でエラーが発生しました。

import threading
import time
def worker(thread_id):
    print(f"スレッド {thread_id} が開始されました。")
    time.sleep(2)  # 2秒間の処理
    print(f"スレッド {thread_id} が終了しました。")
threads = []
for i in range(5):  # 5つのスレッドを作成
    thread = threading.Thread(target=worker, args=(i,))
    threads.append(thread)
    thread.start()  # スレッドの開始
for thread in threads:
    thread.join()  # 各スレッドの終了を待機
print("全てのスレッドが終了しました。")

スレッド 0 が開始されました。
スレッド 1 が開始されました。
スレッド 2 が開始されました。
スレッド 3 が開始されました。
スレッド 4 が開始されました。
スレッド 0 が終了しました。
スレッド 1 が終了しました。
スレッド 2 が終了しました。
スレッド 3 が終了しました。
スレッド 4 が終了しました。
全てのスレッドが終了しました。

import threading
def worker_a(event):
    print("スレッドAが開始されました。")
    event.wait()  # スレッドBの終了を待機
    print("スレッドAが終了しました。")
def worker_b(event):
    print("スレッドBが開始されました。")
    event.set()  # スレッドAの終了を待機
    print("スレッドBが終了しました。")
event = threading.Event()
thread_a = threading.Thread(target=worker_a, args=(event,))
thread_b = threading.Thread(target=worker_b, args=(event,))
thread_a.start()
thread_b.start()
thread_a.join()
thread_b.join()

import threading
import time
def worker(thread_id):
    time.sleep(1)  # 1秒間の処理
    print(f"スレッド {thread_id} が終了しました。")
threads = []
for i in range(3):
    thread = threading.Thread(target=worker, args=(i,))
    threads.append(thread)
    thread.start()
# joinの呼び出し順序に注意
for thread in threads:
    thread.join()  # 各スレッドの終了を待機
print("全てのスレッドが終了しました。")

import threading
import time
def worker():
    print("サブスレッドが開始されました。")
    time.sleep(2)  # 2秒間の処理
    print("サブスレッドが終了しました。")
thread = threading.Thread(target=worker)
thread.start()
# メインスレッドが終了する前にjoinを呼び出す
thread.join()
print("メインスレッドが終了しました。")

import threading
def worker():
    print("スレッドが開始されました。")
    # スレッド内でリソースを使用
    # ここでリソースを解放する処理が必要
    print("スレッドが終了しました。")
thread = threading.Thread(target=worker)
thread.start()
thread.join()  # スレッドの終了を待機
print("メインスレッドが終了しました。")