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

finish threading

Browse Source
This commit is contained in:
chrys 2016-07-08 00:07:03 +02:00
parent 1d8d6471ee
commit f52bef7e0c
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/fenrir-package/fenrir.py
View File

@ -23,6 +23,7 @@ class fenrir():
def __init__(self): def __init__(self):
self.threadUpdateScreen = None self.threadUpdateScreen = None
self.threadHandleInput = None self.threadHandleInput = None
self.threadHandleCommandQueue = None
self.runtime = environment.runtime self.runtime = environment.runtime
self.runtime['inputManager'] = inputManager.inputManager() self.runtime['inputManager'] = inputManager.inputManager()
if DEBUG: if DEBUG:
@ -41,8 +42,10 @@ class fenrir():
def proceed(self): def proceed(self):
self.threadUpdateScreen = Thread(target=self.updateScreen, args=()) self.threadUpdateScreen = Thread(target=self.updateScreen, args=())
self.threadHandleInput = Thread(target=self.handleInput, args=()) self.threadHandleInput = Thread(target=self.handleInput, args=())
self.threadCommandQueue = Thread(target=self.handleCommandQueue, args=())
self.threadUpdateScreen.start() self.threadUpdateScreen.start()
self.threadHandleInput.start() self.threadHandleInput.start()
self.threadCommandQueue.start()
while(self.runtime['running']): while(self.runtime['running']):
time.sleep(2) time.sleep(2)
self.shutdown() self.shutdown()
@ -55,6 +58,10 @@ class fenrir():
while(self.runtime['running']): while(self.runtime['running']):
self.runtime = self.runtime['screenDriver'].analyzeScreen(self.runtime) self.runtime = self.runtime['screenDriver'].analyzeScreen(self.runtime)
def handleCommandQueue(self):
while(self.runtime['running']):
self.runtime = self.runtime # command queue here
def shutdown(self): def shutdown(self):
self.threadUpdateScreen.stop() self.threadUpdateScreen.stop()
self.threadHandleInput.stop() self.threadHandleInput.stop()