Python：複数の連続したタイムアウトを設定する

Question

イベントを受け取る（つまりソケットを使用する）何らかの種類のサーバーが必要です。イベントごとに異なるID（つまりdstポート番号）があります。

特定のIDの最初のパケットが表示されている瞬間から、何らかのタイムアウト（つまり1ms）を開始し、同じIDの他に何もイベントが受信されない場合トリガされますが、何かが受信された場合、タイムアウトは1msにリセットされます。

これは、signalsとSIGALARM信号を使用することで実現できます。しかし、私は異なるIDごとに複数の「タイマー」を保持したい。

Answer 1

selectの求人と思われます。ソケットを使用しているときは、クライアント用のソケット記述子を持っています（おそらく、クライアントごとに1つですが、持っている限り動作します）。パケットがあなたのソケットの1つに到着するまで、またはタイムアウトが発生するまで待ちます。これはまさにselectの機能です。

あなたがメッセージを受信したときにように、すべてのソケット記述子で（そして、あなたのメインループでは、単に最も早いツー期限切れとタイムアウトを計算し、select.selectにtimeoutパラメータとしてこれを提供し、各クライアントの有効期限を計算しますrlistパラメータ）。その後、新しいパケット/メッセージが到着したとき、または最も古いタイムアウトが切れるとき、あなたは目を覚ます。新しいパケットの場合は、パケットを処理して、そのプロバイダのタイムアウトを1msにリセットします。それ以外の場合は、タイムアウトの期限が切れたときに行う操作を実行します。

次に、期限切れのタイムアウトを計算します。リンス。泡。繰り返す。

このような何か：

now = time.time() 
timeout = min([(client.expiration - now) for client in clients_list]) 
rrdy, wrdy, xrdy = select.select([client.sock for client in clients_list], [], [], timeout) 
if not rrdy: 
    # Timeout 
    now = time.time() 
    for client in clients_list: 
     if client.expiration < now: 
      process_timeout(client) 
else: 
    # Process incoming messages 
    for rsock in rrdy: 
     process_message(rsock.recv(4096)) 
     client.expiration = time.time() + .001 

Answer 2

schedスケジューラを持つ内蔵モジュールを参照してください。

新しいスケジューラインスタンスを作成してから、scheduler.enterを使用して遅延の後に関数を呼び出すようにスケジュールできます。制限時間内にメッセージを受け取った場合は、scheduler.cancel(event)を使用してそのイベントをキューから削除することができます。 scheduler.run()を使用して別のスレッドでスケジューラを実行するか、タイムアウトのある選択多重化スレッドでscheduler.run(blocking=False)を使用できます。