spacepaste

Paste details

reply | raw

  1.  
  2. import sys
  3. import PyQt5
  4. from PyQt5.QtWidgets import *
  5. from PyQt5.QtCore import *
  6. from queue import Queue
  7. import time
  9. def doJob(data_in):
  10. print('doJob: processing data',data_in)
  11. time.sleep(int(data_in))
  12. return data_in
  16. class WorkerThread(QThread):
  18. def __init__(self,func,jobqueue,outqueue,parent=None):
  19. QThread.__init__(self,parent)
  21. self.func=func
  22. self.jobqueue=jobqueue
  23. self.outqueue=outqueue
  24. self.timer=QTimer()
  25. self.timer.moveToThread(self)
  26. self.timer.timeout.connect(self.stopthread)
  27. self._running=True
  29. def run(self):
  30. self.timer.start(4000)
  31. #loop = QEventLoop()
  32. #loop.exec_()
  33. while self._running:
  34. args=self.jobqueue.get()
  35. rec=self.func(*args)
  36. self.jobqueue.task_done()
  37. self.outqueue.put(rec)
  39. def stopthread(self):
  40. self._running=False
  41. self.quit()
  42. print('stopthread called')
  43. self.outqueue.put(None)
  46. class MainWindow(QMainWindow):
  47. def __init__(self):
  48. super(self.__class__, self).__init__()
  49. frame=QWidget()
  50. self.setCentralWidget(frame)
  51. hl=QVBoxLayout()
  52. frame.setLayout(hl)
  54. self.startBtn=QPushButton()
  55. self.startBtn.setText('Start')
  56. self.startBtn.clicked.connect(self.pressedStartBtn)
  58. hl.addWidget(self.startBtn)
  60. self.show()
  62. def pressedStartBtn(self):
  64. self.jobq=Queue()
  65. self.outq=Queue()
  67. for ii in range(20):
  68. self.jobq.put(str(ii))
  70. self.worker = WorkerThread(doJob,self.jobq,self.outq,self)
  71. self.worker.start()
  73. results=[]
  74. while self.outq.qsize():
  75. resii=self.outq.get()
  76. results.append(resii)
  79. def main():
  80. # a new app instance
  81. app = QApplication(sys.argv)
  82. form = MainWindow()
  83. form.show()
  84. sys.exit(app.exec_())
  86. if __name__ == "__main__":
  87. main()
  88.  
Powered by spacepaste. Paste removal.