スレッド化されたチャット サーバーを作成しており、すべてのクライアントにメッセージを送信する方法が必要です。グローバル キューを使用できますが、クライアントを処理するスレッドの 1 つだけがメッセージを送信できます。したがって、各クライアントスレッド内に個別のキューオブジェクトを作成し、それらをリストに追加して、各クライアントのキューにメッセージを送信できるようにすることが可能かどうか疑問に思っていました。これは可能ですか?
clientqueues = [] #Global list of client queues
class ClientThread(threading.Thread):
def __init__(self):
myqueue = Queue.Queue() #Client queue
clientqueues.append(myqueue)
...
def MessageAllClients(message):
global clientqueues
for queue in clientqueues:
queue.put(message)
これは機能しますか、それとも間違った方法で行っていますか?