並行処理

1
# スレッドの基本
2
import threading
3
import time
4

5
def worker(num):
6
    print(f"Worker {num} started")
7
    time.sleep(2)
8
    print(f"Worker {num} finished")
9

10
# スレッドの作成と実行
11
threads = []
12
for i in range(5):
13
    thread = threading.Thread(target=worker, args=(i,))
14
    threads.append(thread)
15
    thread.start()
16

17
# スレッドの待機
18
for thread in threads:
19
    thread.join()
20

21
print("All workers finished")

1
# マルチプロセスの基本
2
import multiprocessing
3
import time
4

5
def worker(num):
6
    print(f"Worker {num} started")
7
    time.sleep(2)
8
    print(f"Worker {num} finished")
9

10
# プロセスの作成と実行
11
processes = []
12
for i in range(5):
13
    process = multiprocessing.Process(target=worker, args=(i,))
14
    processes.append(process)
15
    process.start()
16

17
# プロセスの待機
18
for process in processes:
19
    process.join()
20

21
print("All workers finished")

1
# asyncioの基本
2
import asyncio
3

4
async def worker(num):
5
    print(f"Worker {num} started")
6
    await asyncio.sleep(2)
7
    print(f"Worker {num} finished")
8

9
async def main():
10
    # タスクの作成と実行
11
    tasks = [worker(i) for i in range(5)]
12
    await asyncio.gather(*tasks)
13
    print("All workers finished")
14

15
# イベントループの実行
16
asyncio.run(main())