並行処理とネットワークプログラミングの基礎
基本的なソケット通信
import socket
サーバー = socket.socket() # TCPプロトコルをデフォルトで使用
サーバー.bind(('IPアドレス', ポート番号)) # IPとポートのバインディング
サーバー.listen(5) # 接続待ちキュー
クライアント, アドレス = サーバー.accept() # 接続受付、3ウェイハンドシェイク完了状態
データ = クライアント.recv(1024) # データ受信
ク ...
6月8日 21:59 投稿
Pythonマルチプロセス環境におけるデータ共有のメカニズムと実装
Pythonのmultiprocessingモジュールを用いて並列処理を構築する際、親プロセスと子プロセス間で状態を共有しようとすると、意図しない動作に直面することがあります。以下のスクリプトは、セマフォを用いて同時実行数を制御しつつ、複数のタスク結果を辞書へ集約する実装例です。
import time
from multiprocessing import Process, Semaphore
def execute_task(semaphore ...
6月4日 22:34 投稿