閉じたunixソケットでsocket.accept（）を呼び出す

Question

Socket.close（）は、そのソケットですでに実行されているsocket.accept（）呼び出しをブロックしません。

Pythonプログラムには、すでに閉じられているunixドメインソケットでblocking socket.accept（）を呼び出すスレッドがいくつかあります。 socket.accept（）呼び出しを停止するか、 例外を発生させることによって、これらのスレッドを強制終了します。

私は、プログラムを停止することなく、プログラムに新しいコードをロードすることでこれを実行しようとしています。 したがって、これらのスレッドを生成したコードまたはソケットを閉じたコードを変更することは選択できません。

これを行う方法はありますか？

これはhttps://stackoverflow.com/a/10090348/3084431に似ていますが、これらのソリューションは、私のコードのための作業を習慣：

1. この点は真実ではない、閉鎖は受け入れに例外を発生しません。シャットダウンしますが、スレッドが閉じられてもそれを呼び出すことはできません。
2. 私はこのソケットにもう接続できません。ソケットが閉じています。
3. accept呼び出しのスレッドは既に実行されており、変更できません。明確化のために3

と同じ

、私はこの問題を持っているいくつかのサンプルコードを書かれています。 このコード私は必要なもののpython 2とPython 3

import socket 
import threading 
import time 

address = "./socket.sock" 

sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM) 
sock.bind(address) 
sock.listen(5) 

def accept(): 
    print(sock.accept()) 

t = threading.Thread(target=accept, name="acceptorthread") 
t.start() 

sock.close() 

time.sleep(0.5) # give the thread some time to register the closing 

print(threading.enumerate()) # the acceptorthread will still be running 

の両方で動作しますが、このコードは何とかアクセプタスレッドを停止することができる終えた後、私は実行することができるものです。

Answer 1

すべてのリスナーにソケットがクローズされたことを通知するメカニズムはありません。あなたは自分で何かを書く必要があります。簡単な解決策は、ソケットにタイムアウトを使用することです：

sock.settimeout(1) 

def accept(): 
    while True: 
     try: 
      print(sock.accept()) 
     except socket.timeout: 
      continue 
     break 

あなたはソケットを閉じたときに今.accept()次の呼び出し（タイムアウトの後）は、「悪い記述」例外がスローされます。

また、PythonのソケットAPIはスレッドセーフではありません。マルチスレッド環境では、ソケット呼び出しをロック（または他の同期メソッド）でラップすることをお勧めします。

さらに高度な（そして効率的な）ソケットは、select callでラップしてください。ソケットを使用するには、非ブロックモードである必要はありません。

したがって、これらのスレッドを生成したコードを変更するか、ソケットを閉じたコードを変更することは選択できません。

この場合、あなたは破棄されます。スレッド内で動作するコードを変更することなく、達成することは不可能です。それは "私は車を変更せずに私の壊れた車を修正することができます"と尋ねるようなものです。起こらない、仲間。

Answer 2

selectorsから「読み取り可能な」結果が得られたソケットでのみ、.accept()を呼び出す必要があります。その後、受け入れられないを中断する必要があります。

偽のウェイクアップの場合は、とにかくO_NONBLOCKモードのリスニングソケットが必要です。