storm/fenrir
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

improve eventManager

Browse Source
This commit is contained in:
chrys 2017-04-24 21:42:04 +02:00
parent b061773778
commit b4a0232707
1 changed files with 18 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
src/fenrir/core/eventManager.py
View File

@ -46,13 +46,12 @@ class eventManager():
print(e) print(e)
def proceedEventLoop(self): def proceedEventLoop(self):
event = self._eventQueue.get() event = self._eventQueue.get()
print(event)
self.eventDispatcher(event) self.eventDispatcher(event)
def eventDispatcher(self, event): def eventDispatcher(self, event):
if not event: if not event:
return return
if event['Type'] == fenrirEventType.Ignore: if event['Type'] == fenrirEventType.Ignore:
pass return
elif event['Type'] == fenrirEventType.StopMainLoop: elif event['Type'] == fenrirEventType.StopMainLoop:
self._mainLoopRunning.value = 0 self._mainLoopRunning.value = 0
return return
@ -90,29 +89,37 @@ class eventManager():
self._eventQueue.get_nowait() self._eventQueue.get_nowait()
except Empty: except Empty:
pass pass
def putToEventQueue(self,event, data):
if not isinstance(event, fenrirEventType):
return False
self._eventQueue.put({"Type":event,"Data":data})
return True
def eventWorkerThread(self, event, function): def eventWorkerThread(self, event, function):
if not isinstance(event, fenrirEventType):
return
if not callable(function):
return
while self._mainLoopRunning.value: while self._mainLoopRunning.value:
Data = None Data = None
try: try:
Data = function() Data = function()
print(Data)
except Exception as e: except Exception as e:
print(e) print(e)
self._eventQueue.put({"Type":event,"Data":Data}) self.putToEventQueue(event, Data)
def p(): def p():
time.sleep(0.5) time.sleep(1.5)
return("p") return("p")
s = time.time()
e = eventManager() e = eventManager()
e.addEventThread(fenrirEventType.ScreenUpdate,p) e.addEventThread(fenrirEventType.ScreenUpdate,p)
e.addEventThread(fenrirEventType.BrailleInput,p) #e.addEventThread(fenrirEventType.BrailleInput,p)
e.addEventThread(fenrirEventType.PlugInputDevice,p) #e.addEventThread(fenrirEventType.PlugInputDevice,p)
e.addEventThread(fenrirEventType.ScreenChanged,p) #e.addEventThread(fenrirEventType.ScreenChanged,p)
time.sleep(1.5) time.sleep(1.5)
e.addEventThread(fenrirEventType.StopMainLoop,e.stopMainEventLoop) e.addEventThread(fenrirEventType.StopMainLoop,e.stopMainEventLoop)
s = time.time()
e.startMainEventLoop() e.startMainEventLoop()
print(time.time() - s - 1.5) print(time.time() - s )