扭曲的数据接收挂起

Question

我正在使用 python twisted 库，并且正在让服务器接收数据以对接收到的数据进行一些处理，然后关闭连接。我观察到程序在没有打印语句的情况下挂在 dataReceived 中。它通过打印语句。想知道打印是否以某种方式减慢了执行速度以避免竞争条件，或者我是否编码了错误？

我的代码如下：

class Stack(Protocol):
   def __init__(self, factory):
    self.factory = factory
    self.bytesremaining = None
    self.payload = ""
    self.headerseen = False
   def dataReceived(self, data):
    if self.headerseen == False:
            header = unpack('B',data[0])[0]
            if header == 128:
                    self.pop()
                    return
            self.bytesremaining = self.datalength = unpack('B',data[0])[0]
            print self.datalength #without this print the execution hangs in the middle.
            if len(data) > 1 and (len(self.factory.pushstack) < 100):
                    self.payload += data[1:]
                    self.bytesremaining -= len(data) - 1
            self.headerseen = True
    elif len(self.factory.pushstack) < 100:
            self.payload += data
            self.bytesremaining -= len(data) - 1
    if self.bytesremaining == 0:
            self.factory.pushstack.appendleft(self.payload)
            retval = pack('B',0)
            self.transport.write(retval)
            self.transport.loseConnection()

class StackFactory(ServerFactory):
  def __init__(self):
    self.clients = []
    self.pushstack = collections.deque()
    self.popstack = collections.deque()
    self.clientsmap = {}

  def buildProtocol(self, addr):
    return Stack(self)

Answer 1

在我看来，OS X (selectreactor) 的默认扭曲反应器不如 kqueue 稳定。

安装 kqueue 反应器后，我再也看不到这个问题了。

from twisted.internet import kqreactor
kqreactor.install()
from twisted.internet import reactor

扭曲的数据接收挂起

Twisted dataReceived hangs

python

asynchronous

twisted