mirror of
https://github.com/Denvi/FlatCAM.git
synced 2026-03-21 15:47:10 +01:00
114 lines
2.6 KiB
Python
114 lines
2.6 KiB
Python
from FlatCAMGUI import FlatCAMActivityView
|
|
from PyQt4 import QtCore
|
|
import weakref
|
|
|
|
|
|
class FCProcess(object):
|
|
|
|
def __init__(self, descr):
|
|
self.callbacks = {
|
|
"done": []
|
|
}
|
|
self.descr = descr
|
|
|
|
def __del__(self):
|
|
self.done()
|
|
|
|
def done(self):
|
|
print "FCProcess.done()"
|
|
for fcn in self.callbacks["done"]:
|
|
fcn(self)
|
|
|
|
def connect(self, callback, event="done"):
|
|
if callback not in self.callbacks[event]:
|
|
self.callbacks[event].append(callback)
|
|
|
|
def disconnect(self, callback, event="done"):
|
|
try:
|
|
self.callbacks[event].remove(callback)
|
|
except ValueError:
|
|
pass
|
|
|
|
def status_msg(self):
|
|
return self.descr
|
|
|
|
|
|
class FCProcessContainer(object):
|
|
|
|
def __init__(self):
|
|
|
|
self.procs = []
|
|
|
|
def add(self, proc):
|
|
|
|
self.procs.append(weakref.ref(proc))
|
|
|
|
def new(self, descr):
|
|
proc = FCProcess(descr)
|
|
|
|
proc.connect(self.on_done, event="done")
|
|
|
|
# if proc not in self.procs:
|
|
# self.procs.append(proc)
|
|
self.add(proc)
|
|
|
|
self.on_change(proc)
|
|
|
|
return proc
|
|
|
|
def on_change(self, proc):
|
|
pass
|
|
|
|
def on_done(self, proc):
|
|
self.remove(proc)
|
|
|
|
def remove(self, proc):
|
|
|
|
to_be_removed = []
|
|
|
|
for pref in self.procs:
|
|
if pref() == proc or pref() is None:
|
|
to_be_removed.append(pref)
|
|
|
|
for pref in to_be_removed:
|
|
self.procs.remove(pref)
|
|
|
|
|
|
class FCVisibleProcessContainer(QtCore.QObject, FCProcessContainer):
|
|
something_changed = QtCore.pyqtSignal()
|
|
|
|
def __init__(self, view):
|
|
assert isinstance(view, FlatCAMActivityView)
|
|
|
|
#super(FCVisibleProcessContainer, self).__init__()
|
|
FCProcessContainer.__init__(self)
|
|
QtCore.QObject.__init__(self)
|
|
|
|
self.view = view
|
|
|
|
self.something_changed.connect(self.update_view)
|
|
|
|
def on_done(self, proc):
|
|
print "FCVisibleProcessContainer.on_done()"
|
|
super(FCVisibleProcessContainer, self).on_done(proc)
|
|
|
|
#self.update_view()
|
|
self.something_changed.emit()
|
|
|
|
def on_change(self, proc):
|
|
print "FCVisibleProcessContainer.on_change()"
|
|
super(FCVisibleProcessContainer, self).on_change(proc)
|
|
|
|
#self.update_view()
|
|
self.something_changed.emit()
|
|
|
|
def update_view(self):
|
|
print "FCVisibleProcessContainer.update_view()"
|
|
if len(self.procs) == 0:
|
|
self.view.set_idle()
|
|
|
|
elif len(self.procs) == 1:
|
|
self.view.set_busy(self.procs[0]().status_msg())
|
|
|
|
else:
|
|
self.view.set_busy("%d processes running." % len(self.procs)) |