Source code for lib.thread

#!/usr/bin/python3
# -*- coding: utf-8 -*-

'''Pychemqt, Chemical Engineering Process simulator
Copyright (C) 2009-2023, Juan José Gómez Romera <jjgomera@gmail.com>

This program is free software: you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation, either version 3 of the License, or
(at your option) any later version.

This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
GNU General Public License for more details.

You should have received a copy of the GNU General Public License
along with this program.  If not, see <http://www.gnu.org/licenses/>.'''


###############################################################################
# Library for work with thread in pychemqt for improve UI response
#   - WaitforClick: Thread for draw stream in PFD
#   - Evaluate: Thread to insolate entity calculation from gui, used in
#        streams equipment, and project
###############################################################################

from time import sleep

from tools.qt import QtCore



[docs]
class WaitforClick(QtCore.QThread):
    """
    Thread used in PFD drawing to specified stream input and output or add
    equipment.
    TODO: Use to customize stream drawing
    """

[docs]
    def __init__(self, num, parent=None):
        super().__init__(parent)
        self.setTerminationEnabled(True)
        self.num = num



[docs]
    def run(self):
        """Wait until the mouse is clicked"""
        while True:
            sleep(0.1)
            if len(self.parent().Pos) >= self.num:
                break





[docs]
class Evaluate(QtCore.QThread):
    """
    Thread used to insolate calculation process in entities (stream, project
    and equipment, so gui can response while calculation is in process
    """

[docs]
    def __init__(self, parent=None):
        super().__init__(parent)
        self.mutex = QtCore.QMutex()
        self.entity = None
        self.kwargs = None



[docs]
    def start(self, entity, kwargs):
        """Rewrite QThread start procedure"""
        self.entity = entity
        self.kwargs = kwargs
        QtCore.QThread.start(self)



[docs]
    def run(self):
        """Evaluate entity"""
        self.mutex.lock()
        self.entity(**self.kwargs)
        self.mutex.unlock()