在python中生成一个包含套接字连接的QThread

Question

我目前正在尝试实现一个包含套接字连接的 QThread。套接字连接重复运行（同时 1:）检查接收到的新数据。一旦接收到该数据，它就会发出一个信号，调用一个函数并向其提供接收到的数据。

我的套接字连接工作了。当我单独运行该函数时，它会等待数据，并在新数据进入时进行打印。但是，由于我尝试使用 Qt 构建 GUI，所以我必须将其放在自己的线程中，以便应用程序能够继续运行。

因此，为了线程化它，我实现了一个 GenericThread 类，它接受任何函数并在线程内运行它。我的 MainWindow 类连接套接字 SIGNAL，实例化一个 GenericThread，然后启动它。然而，这会导致我的应用程序挂起。下面是相关的代码片段：

套接字连接

def remoteConn(self, HOST='my.server', PORT=25562):
  import socket
  s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
  s.connect((HOST, PORT))
  newLinesRaw = ''
  while 1:
    newData = s.recv(1024)
    if newData:
      print '<rawData>\n', newData, '\n</newData>\n'
      newLinesRaw += newData
    else:
      if newLinesRaw:
        newLines = newLinesRaw.split('\n')
        print '\nNew Lines:\n', newLines
        self.emit(QtCore.SIGNAL('newRemoteLines'), newLines)
        newLinesRaw=''
      else:
        time.sleep(.1)
  s.close()

通用线程类

class GenericThread(QtCore.QThread):
  def __init__(self, function, *args, **kwargs):
    QtCore.QThread.__init__(self)
    self.function = function
    self.args = args
    self.kwargs = kwargs

  def __del__(self):
    self.wait()

  def run(self):
    if self.args and self.kwargs:
      self.function(*self.args,**self.kwargs)
    elif self.args and not self.kwargs:
      self.function(*self.args)
    elif not self.args and self.kwargs:
      self.function(**self.kwargs)
    else:
      self.function()
    return

生成远程线程。请注意，两个打印语句都被执行。

  print 'spawning remote thread'
  self.connect(self, QtCore.SIGNAL('newRemoteLines'), self.routeServerLines)
  thread = GenericThread(self.remoteConn)
  thread.start()
  print 'thread started'

我对套接字和线程很陌生，所以我可能在某个地方犯了一个非常愚蠢的错误。

Answer 1

如果没有进一步引用该线程，则该线程可能会被销毁。

尝试使用 self.thread 而不仅仅是 thread。