RError.com

RError.com Logo RError.com Logo

RError.com Navigation

  • 主页

Mobile menu

Close
  • 主页
  • 系统&网络
    • 热门问题
    • 最新问题
    • 标签
  • Ubuntu
    • 热门问题
    • 最新问题
    • 标签
  • 帮助
主页 / 问题 / 1495208
Accepted
Игорь Ищенко
Игорь Ищенко
Asked:2023-02-11 19:24:40 +0000 UTC2023-02-11 19:24:40 +0000 UTC 2023-02-11 19:24:40 +0000 UTC

闪烁指示器 PyQt5 Python

  • 772

我在线程之间传递数据时遇到问题。有一个小应用,其思路如下:
有一个按钮,一个表格和两个指标——rx和rx。通过按下按钮,表格应该开始填充数据,并且指示灯应该闪烁。

我在三个线程中实现了它。
Main - 主窗口本身。
附加线程table_thread- 处理数据并将其传递给主线程以填充表。该线程还通知第三个线程rx_tx_blink_thread已发生记录并且指示灯应闪烁。

所有这些都是使用 workerfill_in_table_widget和rx_tx_blink_widget使用moveToThread.

主要问题是您需要fill_in_table_widget将需要闪烁的 worker 信息传输给 worker rx_tx_blink_widget。而这个 worker 应该将改变指标颜色的信息传递给主线程,然后等待50 мс,然后再次将改变颜色的信息传递给原来的线程。

我有这样的链实现:

       self.table_thread = QtCore.QThread()
       self.fill_in_table_widget = FillTableWorker()
       self.fill_in_table_widget.moveToThread(self.table_thread)
       self.fill_in_table_widget.new_table_row.connect(self.add_row_in_table)
       self.table_thread.started.connect(self.fill_in_table_widget.run)

       self.rx_tx_blink_thread = QtCore.QThread()
       self.rx_tx_blink_widget = RxTxWorker()
       self.rx_tx_blink_widget.moveToThread(self.rx_tx_blink_thread)
       self.rx_tx_blink_widget.rx_tx_blink_signal.connect(self.rx_tx_blink)
       self.rx_tx_blink_thread.started.connect(self.rx_tx_blink_widget.run)
       # вот тут я соединяю сигнал  tx_rx воркера fill_in_table_widget  
       # с методом blink воркера rx_tx_blink_widget. А из этого метода я передаю сигнал в 
       # метод главного окна **rx_tx_blink**, но до него сигнал судя по всему не доходит и 
       #индикаторы не меняют цвет.
       self.fill_in_table_widget.tx_rx.connect(self.rx_tx_blink_widget.blink)

请帮助我理解问题是什么以及如何实现这样的连接,以便第一个附加线程将信号传输到第二个附加线程,而后者已经将其传递给主线程,实现 50 毫秒的延迟。

下面我附上了整个代码,它应该运行:

import sys
from PyQt5 import QtCore
from PyQt5.QtWidgets import *
from PyQt5.QtGui import *
from time import sleep


class MainWindow(QMainWindow):
   def __init__(self):
       super().__init__()
       # конфигурация главного окна и центрального виджета
       self.central_widget = QWidget(self)
       self.setGeometry(50, 50, 1500, 800)
       self.setWindowTitle('Чтение БКУ')
       self.setCentralWidget(self.central_widget)
       self.layout_main_window = QVBoxLayout()
       self.central_widget.setLayout(self.layout_main_window)
       # кнопка считать
       self.btn_start_reading = QPushButton("Считать")
       self.btn_start_reading.clicked.connect(self.start_read)
       self.layout_main_window.addWidget(self.btn_start_reading)
       # таблица
       self.table = QTableWidget()
       self.table.setColumnCount(9)
       self.table.setRowCount(13500)
       self.table.setHorizontalHeaderLabels(['№', 'Дата и время', 'БКУ', 'КЛ', 'АУ', 'Канал', 'Код события', 'Доп. параметр', 'Описание'])
       self.table.horizontalHeader().setStretchLastSection(True)
       self.table.horizontalHeader().setVisible(True)
       self.layout_main_window.addWidget(self.table)
       # индикаторы
       self.tx = QLabel()
       self.tx.setStyleSheet(rx_tx_yellow_stylesheet)
       self.rx = QLabel()
       self.rx.setStyleSheet(rx_tx_yellow_stylesheet)
       self.layout_main_window.addWidget(self.rx)
       self.layout_main_window.addWidget(self.tx)


   def start_read(self):
       # конфигурация доп потоков
       self.table_thread = QtCore.QThread()
       self.fill_in_table_widget = FillTableWorker()
       self.fill_in_table_widget.moveToThread(self.table_thread)
       self.fill_in_table_widget.new_table_row.connect(self.add_row_in_table)
       self.table_thread.started.connect(self.fill_in_table_widget.run)

       self.rx_tx_blink_thread = QtCore.QThread()
       self.rx_tx_blink_widget = RxTxWorker()
       self.rx_tx_blink_widget.moveToThread(self.rx_tx_blink_thread)
       self.rx_tx_blink_widget.rx_tx_blink_signal.connect(self.rx_tx_blink)
       self.rx_tx_blink_thread.started.connect(self.rx_tx_blink_widget.run)
       # соединяем два потока между собой
       self.fill_in_table_widget.tx_rx.connect(self.rx_tx_blink_widget.blink)

       self.table.clearContents() # очищаем таблицу от старых данных
       self.table_thread.start() # запускаем поток записи данных в таблицу

       # если раскомментирвоать поток снизу, программа начинает виснусть.
       # self.rx_tx_blink_thread.start() # запускаем поток мигания индикаторов

   
   @QtCore.pyqtSlot(int, object)   
   def add_row_in_table(self, i, list):
       self.table.setItem(i, 0, list[0])
       self.table.setItem(i, 1, list[1])
       self.table.setItem(i, 2, list[2])
       self.table.setItem(i, 3, list[3])
       self.table.setItem(i, 4, list[4])
       self.table.setItem(i, 5, list[5])
       self.table.setItem(i, 6, list[6])
       self.table.setItem(i, 7, list[7])
       self.table.setItem(i, 8, list[8])

   
   @QtCore.pyqtSlot(str, str)
   def rx_tx_blink(self, rx, tx):
       if rx == 'blink':
           self.rx.setStyleSheet(rx_stylesheet)
       elif rx == 'white':
           self.rx.setStyleSheet(rx_tx_yellow_stylesheet)
       if tx == 'blink':
           self.tx.setStyleSheet(tx_stylesheet)
       elif tx == 'white':
           self.tx.setStyleSheet(rx_tx_yellow_stylesheet)


rx_tx_yellow_stylesheet = """
       border-radius: 6px;
       min-height: 12px;
       max-height: 12px;
       min-width: 12px;
       max-width: 12px;
       background-color: yellow;
   """

rx_stylesheet = """
       border-radius: 6px;
       min-height: 12px;
       max-height: 12px;
       min-width: 12px;
       max-width: 12px;
       background-color: green;
   """
tx_stylesheet = """
       border-radius: 6px;
       min-height: 12px;
       max-height: 12px;
       min-width: 12px;
       max-width: 12px;
       background-color: red;
   """


class FillTableWorker(QtCore.QObject):
   new_table_row = QtCore.pyqtSignal(int, object)
   tx_rx = QtCore.pyqtSignal(str)

   def __init__(self):
       super().__init__()
       self.i = 0

   def run(self):
       i = self.i
       for i in range(12000):
           event = ['12:10:2022_11:37:56', 1, 1, 1, 1, 138, 1, 1]
           self.tx_rx.emit('Tx')
           list = [
               QTableWidgetItem(str(i+1)),
               QTableWidgetItem(str(event[0])),
               QTableWidgetItem(str(event[1])),
               QTableWidgetItem(str(event[2])),
               QTableWidgetItem(str(event[3])),
               QTableWidgetItem(str(event[4])),
               QTableWidgetItem(str(event[5])),
               QTableWidgetItem(str(event[6])),
               QTableWidgetItem(str(event[7])),
           ]
           self.new_table_row.emit(i, list)
           self.tx_rx.emit('Rx')
           i += 1
           sleep(0.05)


class RxTxWorker(QtCore.QObject):
   rx_tx_blink_signal = QtCore.pyqtSignal(str, str)

   def __init__(self):
       super().__init__()
       self.rx_color = 'white'
       self.tx_color = 'white'

   def run(self):
       while True:
           self.rx_tx_blink_signal.emit(self.rx_color, self.tx_color)


   @QtCore.pyqtSlot(str)
   def blink(self, text):
       if text == 'Rx':
           self.rx_color = 'blink'
           sleep(0.05)
           self.rx_color = 'white'
       elif text == 'Tx':
           self.tx_color = 'blink'
           sleep(0.05)
           self.tx_color = 'white'


if __name__ == '__main__':
   app = QApplication(sys.argv)
   main_window = MainWindow()
   main_window.show()
   sys.exit(app.exec_())
python
  • 1 1 个回答
  • 41 Views

1 个回答

  • Voted
  1. Best Answer
    S. Nick
    2023-02-11T22:39:24Z2023-02-11T22:39:24Z

    我不明白你对第三个线程的想法rx_tx_blink_thread并尝试使用以下方法实现你的想法:

    void QTimer:: singleShot (int msec, const QObject *receiver, const char *member)

    此静态函数在给定时间间隔后调用槽。
    使用此函数非常方便,因为您不必费心处理 timerEvent 或创建本地 QTimer 对象。

    让我知道它是否有效或出了什么问题。

    import sys
    # from time import sleep              # заменил на QtCore.QThread.msleep(50)
    
    from PyQt5 import QtCore
    from PyQt5.QtWidgets import *
    from PyQt5.QtGui import *
    
    
    rx_tx_yellow_stylesheet = """
           border-radius: 6px;
           min-height: 12px;
           max-height: 12px;
           min-width: 12px;
           max-width: 12px;
           background-color: yellow;
       """
    
    rx_stylesheet = """
           border-radius: 6px;
           min-height: 12px;
           max-height: 12px;
           min-width: 12px;
           max-width: 12px;
           background-color: green;
       """
    tx_stylesheet = """
           border-radius: 6px;
           min-height: 12px;
           max-height: 12px;
           min-width: 12px;
           max-width: 12px;
           background-color: red;
       """
    
    
    class FillTableWorker(QtCore.QObject):
       new_table_row = QtCore.pyqtSignal(int, object)
    #   tx_rx = QtCore.pyqtSignal(str)
    
       def __init__(self):
           super().__init__()
           self.i = 0
    
       def run(self):
           i = self.i
           for i in range(12000):
               event = ['12:10:2022_11:37:56', 1, 1, 1, 1, 138, 1, 1]
    #           self.tx_rx.emit('Tx')
               list = [
                   QTableWidgetItem(str(i+1)),
                   QTableWidgetItem(str(event[0])),
                   QTableWidgetItem(str(event[1])),
                   QTableWidgetItem(str(event[2])),
                   QTableWidgetItem(str(event[3])),
                   QTableWidgetItem(str(event[4])),
                   QTableWidgetItem(str(event[5])),
                   QTableWidgetItem(str(event[6])),
                   QTableWidgetItem(str(event[7])),
               ]
               self.new_table_row.emit(i, list)
    #           self.tx_rx.emit('Rx')
               i += 1
    #           sleep(0.05)
               QtCore.QThread.msleep(50)
    
    
    class MainWindow(QMainWindow):
       def __init__(self):
           super().__init__()
           self.central_widget = QWidget(self)
           self.setGeometry(50, 50, 1300, 600)
           self.setWindowTitle('Чтение БКУ')
           self.setCentralWidget(self.central_widget)
           self.layout_main_window = QVBoxLayout()
           self.central_widget.setLayout(self.layout_main_window)
    
           # кнопка считать
           self.btn_start_reading = QPushButton("Считать")
           self.btn_start_reading.clicked.connect(self.start_read)
           self.layout_main_window.addWidget(self.btn_start_reading)
           
           # таблица
           self.table = QTableWidget()
           self.table.setColumnCount(9)
           self.table.setRowCount(13500)
           self.table.setHorizontalHeaderLabels(['№', 'Дата и время', 
               'БКУ', 'КЛ', 'АУ', 'Канал', 'Код события', 
               'Доп. параметр', 'Описание'])
           self.table.horizontalHeader().setStretchLastSection(True)
           self.table.horizontalHeader().setVisible(True)
           self.layout_main_window.addWidget(self.table)
           # индикаторы
           self.tx = QLabel()
           self.tx.setStyleSheet(rx_tx_yellow_stylesheet)
           self.rx = QLabel()
           self.rx.setStyleSheet(rx_tx_yellow_stylesheet)
           self.layout_main_window.addWidget(self.rx)
           self.layout_main_window.addWidget(self.tx)
    
       def start_read(self):
           # конфигурация доп потоков
           self.table_thread = QtCore.QThread()
           self.fill_in_table_widget = FillTableWorker()
           self.fill_in_table_widget.moveToThread(self.table_thread)
           self.fill_in_table_widget.new_table_row.connect(self.add_row_in_table)
           self.table_thread.started.connect(self.fill_in_table_widget.run)
          
           self.table.clearContents() # очищаем таблицу от старых данных
           self.table_thread.start()  # запускаем поток записи данных в таблицу
    
    # !!! vvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvvv   
       @QtCore.pyqtSlot(int, object)   
       def add_row_in_table(self, i, list):
           self.blink('Tx')                                         # !!! +++
       
           self.table.setItem(i, 0, list[0])
           self.table.setItem(i, 1, list[1])
           self.table.setItem(i, 2, list[2])
           self.table.setItem(i, 3, list[3])
           self.table.setItem(i, 4, list[4])
           self.table.setItem(i, 5, list[5])
           self.table.setItem(i, 6, list[6])
           self.table.setItem(i, 7, list[7])
           self.table.setItem(i, 8, list[8])
    
           QtCore.QTimer.singleShot(25, lambda: self.blink('Rx'))   # !!! +++
    
       def blink(self, text):
           if text == 'Rx':
               self.rx_tx_blink(rx='blink', tx='white')
               QtCore.QTimer.singleShot(50, 
                   lambda: self.rx_tx_blink(rx='white', tx='blink'))
           elif text == 'Tx':
               self.rx_tx_blink(rx='white', tx='blink')       
               QtCore.QTimer.singleShot(50, 
                   lambda: self.rx_tx_blink(rx='blink', tx='white'))
    
       def rx_tx_blink(self, rx, tx):
           if rx == 'blink':
               self.rx.setStyleSheet(rx_stylesheet)
               self.tx.setStyleSheet(rx_tx_yellow_stylesheet)
           elif tx == 'blink':
               self.tx.setStyleSheet(tx_stylesheet)
               self.rx.setStyleSheet(rx_tx_yellow_stylesheet)
    # !!! ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
    
    
    if __name__ == '__main__':
       app = QApplication(sys.argv)
       main_window = MainWindow()
       main_window.show()
       sys.exit(app.exec_())
    

    在此处输入图像描述

    在此处输入图像描述

    在此处输入图像描述

    • 2

相关问题

  • 是否可以以某种方式自定义 QTabWidget?

  • telebot.anihelper.ApiException 错误

  • Python。检查一个数字是否是 3 的幂。输出 无

  • 解析多个响应

  • 交换两个数组的元素,以便它们的新内容也反转

Sidebar

Stats

  • 问题 10021
  • Answers 30001
  • 最佳答案 8000
  • 用户 6900
  • 常问
  • 回答
  • Marko Smith

    我看不懂措辞

    • 1 个回答
  • Marko Smith

    请求的模块“del”不提供名为“default”的导出

    • 3 个回答
  • Marko Smith

    "!+tab" 在 HTML 的 vs 代码中不起作用

    • 5 个回答
  • Marko Smith

    我正在尝试解决“猜词”的问题。Python

    • 2 个回答
  • Marko Smith

    可以使用哪些命令将当前指针移动到指定的提交而不更改工作目录中的文件?

    • 1 个回答
  • Marko Smith

    Python解析野莓

    • 1 个回答
  • Marko Smith

    问题:“警告:检查最新版本的 pip 时出错。”

    • 2 个回答
  • Marko Smith

    帮助编写一个用值填充变量的循环。解决这个问题

    • 2 个回答
  • Marko Smith

    尽管依赖数组为空,但在渲染上调用了 2 次 useEffect

    • 2 个回答
  • Marko Smith

    数据不通过 Telegram.WebApp.sendData 发送

    • 1 个回答
  • Martin Hope
    Alexandr_TT 2020年新年大赛! 2020-12-20 18:20:21 +0000 UTC
  • Martin Hope
    Alexandr_TT 圣诞树动画 2020-12-23 00:38:08 +0000 UTC
  • Martin Hope
    Air 究竟是什么标识了网站访问者? 2020-11-03 15:49:20 +0000 UTC
  • Martin Hope
    Qwertiy 号码显示 9223372036854775807 2020-07-11 18:16:49 +0000 UTC
  • Martin Hope
    user216109 如何为黑客设下陷阱,或充分击退攻击? 2020-05-10 02:22:52 +0000 UTC
  • Martin Hope
    Qwertiy 并变成3个无穷大 2020-11-06 07:15:57 +0000 UTC
  • Martin Hope
    koks_rs 什么是样板代码? 2020-10-27 15:43:19 +0000 UTC
  • Martin Hope
    Sirop4ik 向 git 提交发布的正确方法是什么? 2020-10-05 00:02:00 +0000 UTC
  • Martin Hope
    faoxis 为什么在这么多示例中函数都称为 foo? 2020-08-15 04:42:49 +0000 UTC
  • Martin Hope
    Pavel Mayorov 如何从事件或回调函数中返回值?或者至少等他们完成。 2020-08-11 16:49:28 +0000 UTC

热门标签

javascript python java php c# c++ html android jquery mysql

Explore

  • 主页
  • 问题
    • 热门问题
    • 最新问题
  • 标签
  • 帮助

Footer

RError.com

关于我们

  • 关于我们
  • 联系我们

Legal Stuff

  • Privacy Policy

帮助

© 2023 RError.com All Rights Reserve   沪ICP备12040472号-5