Module `matisse_controller.gui.threads.logging_thread`

Source code

from queue import Queue

from PyQt5.QtCore import QThread, pyqtSignal

from matisse_controller.gui.threads import ExitFlag


class LoggingThread(QThread):
    """
    A QThread which waits for data to come through a Queue. It blocks until data is available, then sends it to the UI
    thread by emitting a Qt signal. The thread exits when an instance of ExitFlag is pushed to the message queue.

    Note: Any Qt slots implemented in this class will be executed in the creating thread for instances of this class.
    """
    message_received = pyqtSignal(str)

    def __init__(self, queue: Queue, *args, **kwargs):
        super().__init__(*args, **kwargs)
        self.queue = queue

    def run(self):
        while True:
            message = self.queue.get()
            if isinstance(message, ExitFlag):
                break
            else:
                self.message_received.emit(message)

Classes

class LoggingThread (queue, *args, **kwargs)

A QThread which waits for data to come through a Queue. It blocks until data is available, then sends it to the UI thread by emitting a Qt signal. The thread exits when an instance of ExitFlag is pushed to the message queue.

Note: Any Qt slots implemented in this class will be executed in the creating thread for instances of this class.

Source code

class LoggingThread(QThread):
    """
    A QThread which waits for data to come through a Queue. It blocks until data is available, then sends it to the UI
    thread by emitting a Qt signal. The thread exits when an instance of ExitFlag is pushed to the message queue.

    Note: Any Qt slots implemented in this class will be executed in the creating thread for instances of this class.
    """
    message_received = pyqtSignal(str)

    def __init__(self, queue: Queue, *args, **kwargs):
        super().__init__(*args, **kwargs)
        self.queue = queue

    def run(self):
        while True:
            message = self.queue.get()
            if isinstance(message, ExitFlag):
                break
            else:
                self.message_received.emit(message)

Ancestors

PyQt5.QtCore.QThread
PyQt5.QtCore.QObject
sip.wrapper
sip.simplewrapper

Methods

def message_received(...)

def run(self)

run(self)

Source code

def run(self):
    while True:
        message = self.queue.get()
        if isinstance(message, ExitFlag):
            break
        else:
            self.message_received.emit(message)