Pythonでマルチスレッドとマルチプロセスを用いたファイル操作の実装と違い

# マルチスレッドでのファイル書き込み
import threading

def write_file(thread_id):
    with open(f"thread_{thread_id}.txt", "w") as f:
        f.write(f"This is from Thread-{thread_id}")

threads = []
for i in range(5):
    t = threading.Thread(target=write_file, args=(i,))
    threads.append(t)
    t.start()

for t in threads:
    t.join()

# 応用例1: 大量のファイル操作を高速化
import time

# シングルスレッド
start = time.time()
for i in range(1000):
    with open(f"single_thread_{i}.txt", "w") as f:
        f.write(f"This is from single thread-{i}")
print("Single Thread Time:", time.time() - start)

# マルチスレッド
start = time.time()
threads = []
for i in range(1000):
    t = threading.Thread(target=write_file, args=(i,))
    threads.append(t)
    t.start()
for t in threads:
    t.join()
print("Multi Thread Time:", time.time() - start)

# 応用例2: ファイルの読み書きでのロック制御
from threading import Lock

lock = Lock()

def write_with_lock(thread_id):
    lock.acquire()
    try:
        with open(f"thread_{thread_id}.txt", "w") as f:
            f.write(f"This is from Thread-{thread_id}")
    finally:
        lock.release()

# 応用例3: マルチプロセスでのデータ分割
from multiprocessing import Process

def write_file_multiprocess(process_id, data):
    with open(f"process_{process_id}.txt", "w") as f:
        f.write(data)

if __name__ == '__main__':
    data = "This is a test data."
    processes = []
    for i in range(5):
        p = Process(target=write_file

_multiprocess, args=(i, data[i*4:i*4+4]))
        processes.append(p)
        p.start()

    for p in processes:
        p.join()