Создание QThread, содержащего соединение с сокетом в Python

Question

В настоящее время я пытаюсь реализовать QThread, который содержит соединение с сокетом. Соединение с сокетом выполняется повторно (пока 1 :) проверяет наличие новых данных. Как только эти данные получены, предполагается, что SIGNAL вызывает функцию и передает полученные данные.

У меня работает сокетное соединение. Когда я запускаю функцию самостоятельно, она ждет данных и печатает каждый раз, когда поступают новые данные. Однако, поскольку я пытаюсь построить графический интерфейс с помощью Qt, я должен поместить его в свой собственный поток, чтобы приложение продолжало функционировать.

Итак, чтобы реализовать его, я реализовал класс 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.