python - Python Socket 非同期送受信設計

Question

私はpythonソケットクライアントを書いています

1. message one(例: Hello) 5 秒ごと、message two(例: 15 秒) 15 秒ごとに送信
2. いつでもメッセージを受信

別のスレッドで送受信を行うことを意味します。ただし、まだブロックされています。誰か提案がありますか？

スレッド #1

threading.Thread(target=Thread2, args=(sock)).start()
sock.recv(1024)

スレッド #2

def Thread2(sock):
    count = 0
    while True:
        sleep(5)
        count = count + 5
        sock.send('Hello')
        if count % 15 == 0
            sock.send('15 seconds')

Answer 1

ブロッキングではありません。メインスレッドが first の後に何もしないというだけですsock.recv(1024)。常にデータを収集するように指示する必要があります。

メインスレッド

threading.Thread(target=Thread2, args=(sock,)).start()
while True:
    data = sock.recv(1024)
    if not data:
        break
    print data

そのプロセスを簡単に中断することはできないことに注意してください。そのためには、スレッドをデーモンとして設定する必要があります。

メインスレッド

t = threading.Thread(target=Thread2, args=(sock,))
t.daemon = True
t.start()
while True:
    data = sock.recv(1024)
    if not data:
        break
    print data

また、渡すときはargs、タプルを渡すことを忘れないargs=(sock,)でargs=(sock)ください。Python の場合args=(sock)は と同等args=sockです。犯人はきっとこいつだ！

あなたのコードにはこれ以上の問題はありません。