20

TCP経由でデータを送信するプロジェクトに取り組んでいます。ThreadedTCPServer を使用すると、すでにそれを行うことができます。サーバー スレッドは、受信したデータの文字列を読み取り、変数の値を設定するだけで済みます。一方、これらの変数の値が変化するのを確認するには、メインスレッドが必要です。これまでの私のコードは、ThreadedTCPServer の例から変更しただけです。

import socket
import threading
import SocketServer

x =0

class ThreadedTCPRequestHandler(SocketServer.BaseRequestHandler):

    def handle(self):
        data = self.request.recv(1024)
        # a few lines of code in order to decipher the string of data incoming
        x = 0, 1, 2, etc.. #depending on the data string it just received

class ThreadedTCPServer(SocketServer.ThreadingMixIn, SocketServer.TCPServer):
    pass

if __name__ == "__main__":
    # Port 0 means to select an arbitrary unused port
    HOST, PORT = 192.168.1.50, 5000

    server = ThreadedTCPServer((HOST, PORT), ThreadedTCPRequestHandler)

    # Start a thread with the server -- that thread will then start one
    # more thread for each request
    server_thread = threading.Thread(target=server.serve_forever)
    # Exit the server thread when the main thread terminates
    server_thread.daemon = True
    server_thread.start()
    print "Server loop running in thread:", server_thread.name

    while True:
        print x
        time.sleep(1)

    server.shutdown()

したがって、これが機能する方法は、プログラムが常に x の値を出力し、新しいメッセージが入ってくると x の値が変化することです。問題は、メインスレッドで出力される x が、サーバースレッドで新しい値が割り当てられている x と同じではないことです。サーバースレッドからメインスレッドの x の値を変更するにはどうすればよいですか?

4

1 に答える 1

36

Queueスレッド間でa を共有してみてください。

役立つリソース

  • An Introduction to Python Concurrencyは、David Beazley によるプレゼンテーションで、マルチスレッド、スレッド通信、および並行性全般に関する優れた入門書です。
于 2013-04-16T18:49:38.330 に答える