File size: 4,674 Bytes
985c397 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 | # ***************************************************************************
# * Copyright (c) 2017 Markus Hovorka <m.hovorka@live.de> *
# * Copyright (c) 2017 Bernd Hahnebach <bernd@bimstatik.org> *
# * *
# * This file is part of the FreeCAD CAx development system. *
# * *
# * This program is free software; you can redistribute it and/or modify *
# * it under the terms of the GNU Lesser General Public License (LGPL) *
# * as published by the Free Software Foundation; either version 2 of *
# * the License, or (at your option) any later version. *
# * for detail see the LICENCE text file. *
# * *
# * 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 Library General Public License for more details. *
# * *
# * You should have received a copy of the GNU Library General Public *
# * License along with this program; if not, write to the Free Software *
# * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 *
# * USA *
# * *
# ***************************************************************************
__title__ = "FreeCAD FEM solver task"
__author__ = "Markus Hovorka"
__url__ = "https://www.freecad.org"
## \addtogroup FEM
# @{
import threading
import time
from . import report
from . import signal
class Task:
def __init__(self):
self.report = None
self.signalStarting = set()
self.signalStarted = set()
self.signalStopping = set()
self.signalStopped = set()
self.signalAbort = set()
self.signalStatus = set()
self.signalStatusCleared = set()
self.startTime = None
self.stopTime = None
self.running = False
self._aborted = False
self._failed = False
self._status = []
def stopping():
self.stopTime = time.time()
self.running = False
self.signalStopping.add(stopping)
@property
def time(self):
if self.startTime is not None:
endTime = self.stopTime if self.stopTime is not None else time.time()
return endTime - self.startTime
return None
@property
def failed(self):
return self._failed
@property
def aborted(self):
return self._aborted
@property
def status(self):
return "".join(self._status)
def start(self):
self.report = report.Report()
self.clearStatus()
self._aborted = False
self._failed = False
self.stopTime = None
self.startTime = time.time()
self.running = True
signal.notify(self.signalStarting)
signal.notify(self.signalStarted)
def run(self):
raise NotImplementedError()
def join(self):
raise NotImplementedError()
def abort(self):
self._aborted = True
signal.notify(self.signalAbort)
def fail(self):
self._failed = True
def pushStatus(self, line):
self._status.append(line)
signal.notify(self.signalStatus, line)
def clearStatus(self):
self._status = []
signal.notify(self.signalStatusCleared)
def protector(self):
try:
self.run()
except Exception:
self.fail()
raise
class Thread(Task):
def __init__(self):
super().__init__()
self._thread = None
def start(self):
super().start()
self._thread = threading.Thread(target=self.protector)
self._thread.daemon = True
self._thread.start()
self._attachObserver()
def join(self):
if self._thread is not None:
self._thread.join()
def _attachObserver(self):
def waitForStop():
self._thread.join()
signal.notify(self.signalStopping)
signal.notify(self.signalStopped)
thread = threading.Thread(target=waitForStop)
thread.daemon = True
thread.start()
## @}
|