首页 > 代码库 > 基于multiprocessing和threading实现非阻塞的GUI界面显示

基于multiprocessing和threading实现非阻塞的GUI界面显示

2024-08-24 19:46:27   220人阅读

=========================================================
环境：python2.7、pyqt4、eric16.11
热点：multiprocessing、threading、GUI、pyqt
需求：
希望界面上的QTextEdit控件可以滚动刷新日志，且软件界面不可以有阻塞。
=========================================================

郑重提示：如欲转载，请注明出处。

最终实现效果如下：
技术分享
 
该实现的核心思想是：
先建立一个pipe，write端传给子进程，子进程无限发数据，read端传给子线程，在子进程活动的情况下无限取数据；子线程中再把read到的数据写入QTextEdit控件上。下面贴上详细的代码：
Ui_qt_main.py
  1. # -*- coding: utf-8 -*-
  3. # Form implementation generated from reading ui file ‘F:\workspace\pyqt5\gui_thread_pipe_subprocess\qt_main.ui‘
  4. #
  5. # Created by: PyQt4 UI code generator 4.11.4
  6. #
  7. # WARNING! All changes made in this file will be lost!
  9. from PyQt4 import QtCore, QtGui
  11. try:
  12.     _fromUtf8 = QtCore.QString.fromUtf8
  13. except AttributeError:
  14.     def _fromUtf8(s):
  15.         return s
  17. try:
  18.     _encoding = QtGui.QApplication.UnicodeUTF8
  19.     def _translate(context, text, disambig):
  20.         return QtGui.QApplication.translate(context, text, disambig, _encoding)
  21. except AttributeError:
  22.     def _translate(context, text, disambig):
  23.         return QtGui.QApplication.translate(context, text, disambig)
  25. class Ui_MainWindow(object):
  26.     def setupUi(self, MainWindow):
  27.         MainWindow.setObjectName(_fromUtf8("MainWindow"))
  28.         MainWindow.resize(800, 600)
  29.         self.centralwidget = QtGui.QWidget(MainWindow)
  30.         self.centralwidget.setObjectName(_fromUtf8("centralwidget"))
  31.         self.verticalLayout = QtGui.QVBoxLayout(self.centralwidget)
  32.         self.verticalLayout.setObjectName(_fromUtf8("verticalLayout"))
  33.         self.textEdit = QtGui.QTextEdit(self.centralwidget)
  34.         self.textEdit.setObjectName(_fromUtf8("textEdit"))
  35.         self.verticalLayout.addWidget(self.textEdit)
  36.         self.horizontalLayout = QtGui.QHBoxLayout()
  37.         self.horizontalLayout.setObjectName(_fromUtf8("horizontalLayout"))
  38.         spacerItem = QtGui.QSpacerItem(40, 20, QtGui.QSizePolicy.Expanding, QtGui.QSizePolicy.Minimum)
  39.         self.horizontalLayout.addItem(spacerItem)
  40.         self.pushButton = QtGui.QPushButton(self.centralwidget)
  41.         self.pushButton.setObjectName(_fromUtf8("pushButton"))
  42.         self.horizontalLayout.addWidget(self.pushButton)
  43.         spacerItem1 = QtGui.QSpacerItem(40, 20, QtGui.QSizePolicy.Expanding, QtGui.QSizePolicy.Minimum)
  44.         self.horizontalLayout.addItem(spacerItem1)
  45.         self.verticalLayout.addLayout(self.horizontalLayout)
  46.         MainWindow.setCentralWidget(self.centralwidget)
  47.         self.menubar = QtGui.QMenuBar(MainWindow)
  48.         self.menubar.setGeometry(QtCore.QRect(0, 0, 800, 23))
  49.         self.menubar.setObjectName(_fromUtf8("menubar"))
  50.         MainWindow.setMenuBar(self.menubar)
  51.         self.statusbar = QtGui.QStatusBar(MainWindow)
  52.         self.statusbar.setObjectName(_fromUtf8("statusbar"))
  53.         MainWindow.setStatusBar(self.statusbar)
  55.         self.retranslateUi(MainWindow)
  56.         QtCore.QMetaObject.connectSlotsByName(MainWindow)
  58.     def retranslateUi(self, MainWindow):
  59.         MainWindow.setWindowTitle(_translate("MainWindow", "MainWindow", None))
  60.         self.pushButton.setText(_translate("MainWindow", "star", None))
  63. if __name__ == "__main__":
  64.     import sys
  65.     app = QtGui.QApplication(sys.argv)
  66.     MainWindow = QtGui.QMainWindow()
  67.     ui = Ui_MainWindow()
  68.     ui.setupUi(MainWindow)
  69.     MainWindow.show()
  70.     sys.exit(app.exec_())
mainWindow.py
  1. #-*- coding: utf-8 -*-
  3. #mainWindow.py
  5. from PyQt4 import QtCore, QtGui
  6. from Ui_qt_main import Ui_MainWindow
  7. from handleSubprocess import HandleSubProcess
  8. import multiprocessing, threading
  11. class MainWindow(QtGui.QMainWindow, Ui_MainWindow):
  12.     def __init__(self):
  13.         super(MainWindow, self).__init__()
  14.         self.setupUi(self)
  15.         #联动按键
  16.         self.btnStar = "star"
  17.         self.btnStop = "stop"
  18.         self.connect(self.pushButton, QtCore.SIGNAL("clicked()"), self.buttonOn)
  19.         pass
  20.     
  21.     def buttonOn(self):
  22.         if self.btnStar == self.pushButton.text():
  23.             self.pushButton.setText(self.btnStop)
  24.             self.starRun()
  25.             pass
  26.         elif self.btnStop == self.pushButton.text():
  27.             self.stopRun()
  28.             self.pushButton.setText(self.btnStar)
  29.             pass
  30.         pass
  31.     
  32.     def stopRun(self):
  33.         print "stopRun"
  34.         if self.p.is_alive():
  35.             self.p.terminate()
  36.             self.t1.join(1)
  37.             pass
  38.         pass
  39.     
  40.     def starRun(self):
  41.         #print "starRun"
  42.         parent_conn, child_conn = multiprocessing.Pipe()
  43.         #子进程
  44.         self.p = HandleSubProcess(child_conn)
  45.         self.t1 = threading.Thread(target=self.run_thread, args=(parent_conn,self.p))
  46.         self.p.start()
  47.         self.t1.start()
  48.         pass
  49.     
  50.     def run_thread(self, parent_conn, pp):
  51.         while pp.is_alive:
  52.             self.textEdit.append(parent_conn.recv())
  53.             self.delay()
  54.             pass
  55.         print "==== run_thread  end ==================\n"
  56.         pass
  57.     
  58.     def delay(self, timeout=9999999):
  59.         cnt = timeout
  60.         while cnt>0:
  61.             cnt -= 1
  62.             pass
  63.         pass
  64.     pass
handleSubprocess.py
  1. #-*- coding: utf-8 -*-
  3. #handleSubprocess.py
  5. import multiprocessing
  7. class HandleSubProcess(multiprocessing.Process):
  8.     def __init__(self, child_conn):
  9.         super(HandleSubProcess, self).__init__()
  10.         self.child_conn = child_conn
  11.         pass
  12.     
  13.     def run(self):
  14.         cnt = 0
  15.         while True:
  16.             self.child_conn.send("handleSubprocess\t"+str(cnt))
  17.             cnt += 1
  18.             self.delay()
  19.             pass
  20.         pass
  21.     
  22.     def delay(self, timeout=9999999):
  23.         cnt = timeout
  24.         while cnt>0:
  25.             cnt -= 1
  26.             pass
  27.         pass
  28.     pass
enterPoint.py
  1. #-*- coding: utf-8 -*-
  3. #enterPoint.py
  5. import sys
  6. from PyQt4 import QtCore, QtGui 
  7. from mainWindow import MainWindow
  11. if __name__ == "__main__":
  12.     
  13.     app = QtGui.QApplication(sys.argv)
  14.     ui = MainWindow()
  15.     ui.show()
  16.     sys.exit(app.exec_())
以此与同道中人共勉。



null


基于multiprocessing和threading实现非阻塞的GUI界面显示


联系
我们