我已经使用 python-socketIO 实现了这个模型，但是我无法在扭曲中做类似的事情。我有一个数据源进来，我把这个数据以 8192 字节的块读取。这是二进制数据，因此在将其发送给客户端之前需要对其进行处理。但是我无法停止输入数据进行处理。在 python-socketIO 中，我曾经将函数作为后台任务处理这些数据，同时我继续获取更多数据。任何想法如何在使用扭曲的 python 库中做类似的事情。
“后台任务”我想你的意思是一个线程。您可以使用 Twisted 处理线程。涉及最少概念的最多方法是deferToThread：
from twisted.internet.protocol import Protocol
from twisted.internet.threads import deferToThread
class YourProtocol(Protocol):
def dataReceived(self, data):
d = deferToThread(your_process_data, data)
d.addCallback(your_result_handler)
d.addErrback(your_error_handler)
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句