0

我希望我的 websocket 客户端在 my_flag 设置为 True 后立即关闭连接。这是我的套接字类:

class BridgeSocket(WebSocketClientProtocol):
    def __init__(self,factory,my_flag):
        self.my_flag = my_flag

现在,my_flag 在程序运行的其他地方一段时间后被设置为 true。(在不同的线程内)。而不是等待

while True:
    sleep(1)

一种循环,是否有任何事件可以定义并附加到我的 websocket 类。即当 my_flag 设置为 true 时触发的函数

4

2 回答 2

0

使用threading.Event

# initialization code
self.my_event = threading.Event()

# sct.my_event.set() is called from somewhere

# waiting code, to replace while True:...
sct.my_event.wait()
于 2014-01-02T07:17:24.497 回答
0

您应该使用 Twisted 生成后台任务deferToThread,然后使用callFromThread.

于 2014-01-02T12:58:10.323 回答