【完全独学Python】threadingで効率的な並行処理（マルチスレッド）を実現する！

import threading
import time

# スレッドで実行する関数
def print_numbers():
    for i in range(5):
        print("thread:" + str(i))
        time.sleep(1)  # 1秒待機

# スレッドの作成
thread = threading.Thread(target=print_numbers)

# スレッドの開始
thread.start()

# メインスレッドでの処理
for i in range(5, 10):
    print("main:" + str(i))
    time.sleep(1)

import threading
import time

def print_numbers():
    for i in range(5):
        print("thread:" + str(i))
        time.sleep(1)

thread = threading.Thread(target=print_numbers)
thread.start()

# スレッドの終了を待機
thread.join()

print("main:" + "スレッドが終了しました")

import threading
import time

def print_thread_id():
    print(f"スレッドID: {threading.get_ident()}")
    

thread = threading.Thread(target=print_thread_id)
thread.start()

thread2 = threading.Thread(target=print_thread_id)
thread2.start()

import threading
import time

def print_thread_name():
    print(f"スレッド名: {threading.current_thread().name}")

thread = threading.Thread(target=print_thread_name, name="MyThread")
thread.start()
thread.join()

thread2 = threading.Thread(target=print_thread_name, name="MyThread2")
thread2.start()
thread2.join()

import threading
import time

def background_task():
    while True:
        print("バックグラウンドタスク実行中")
        time.sleep(2)

# デーモンスレッドの作成
thread = threading.Thread(target=background_task)
thread.setDaemon(True)
thread.start()

# メインスレッドの処理
time.sleep(5)
print("メインスレッド終了")

import threading

# 共有変数
counter = 0

# ロックオブジェクトの作成
lock = threading.Lock()

def increment():
    global counter
    for _ in range(1000000):
        # ロックを取得
        lock.acquire()
        counter += 1
        # ロックを解放
        lock.release()

def decrement():
    global counter
    for _ in range(1000000):
        # ロックを取得
        lock.acquire()
        counter -= 1
        # ロックを解放
        lock.release()

# スレッドの作成
thread1 = threading.Thread(target=increment)
thread2 = threading.Thread(target=decrement)

# スレッドの開始
thread1.start()
thread2.start()

# スレッドの終了を待機
thread1.join()
thread2.join()

# カウンターの値を表示
print("Counter:", counter)

import threading

condition = threading.Condition()
shared_data = []

def consumer():
    with condition:
        condition.wait()  # データが追加されるまで待機
        print(f"消費者がデータを受け取りました: {shared_data}")

def producer():
    with condition:
        shared_data.append(1)
        print("生産者がデータを追加しました")
        condition.notify()  # 待機中のスレッドを通知

# スレッドの作成
consumer_thread = threading.Thread(target=consumer)
producer_thread = threading.Thread(target=producer)

# スレッドの開始
consumer_thread.start()
producer_thread.start()

# スレッドの終了を待機
consumer_thread.join()
producer_thread.join()