OneEye Changeset - a54daf689665

Changeset - a54daf689665

Parent rev.

Child rev.

[Not reviewed]

default

0 2 0

Laman - 8 years ago 2017-01-07 23:02:14

core exiting on gui exit

2 files changed with 12 insertions and 2 deletions:

src/core.py

src/util.py

0 comments (0 inline, 0 general)

src/core.py

➞

Show inline comments

 import os
 import multiprocessing
 import threading
 import logging as log
 import PIL
 from util import MsgQueue
 from gui import gui
 from imageanalyzer import ImageAnalyzer
 from go import Go
@@ @@ -15,13 +17,14 @@ class Core: @@
 		self.tresW=60.0
 		self.tresB=30.0
 		self._ownMessages=MsgQueue(self._handleEvent)
 		self._guiMessages=MsgQueue()
 		self._frame=PIL.Image.open("../images/7.jpg")
 		imgPath=os.path.join(os.path.dirname(__file__), "..","images","7.jpg")
 		self._frame=PIL.Image.open(imgPath)
 		self._guiProc=multiprocessing.Process(name="gui", target=gui, args=(self._guiMessages,self._ownMessages))
 		self._guiProc.start()
 		self._guiMessages.send("setCurrentFrame",(self._frame,))
 	def setCorners(self,corners):
@@ @@ -33,22 +36,28 @@ class Core: @@
 		if tresB is not None: self.tresB=tresB
 		if tresW is not None: self.tresW=tresW
 		if self.detector.analyze(self._frame):
 			self._guiMessages.send("setGameState",(self.detector.board,))
 	def listen(self):
 		self._ownMessages.listen()
 		listenerThread=threading.Thread(target=lambda: self._ownMessages.listen())
 		listenerThread.start()
 	def joinGui(self):
 		self._guiProc.join()
 		self._ownMessages.send("kill")
 	def _handleEvent(self,e):
 		actions={"setCorners":self.setCorners, "setTresholds":self.setTresholds}
 		(actionName,args,kwargs)=e
 		return actions[actionName](*args,**kwargs)
 core=Core()
 core.listen()
 core.joinGui()
 """
 core
 ====
 grid
 go

src/util.py

➞

Show inline comments

@@ @@ -19,10 +19,11 @@ class MsgQueue: @@
 		while True:
 			self._event.wait()
 			msg=self._queue.get()
 			if self._queue.empty():
 				self._event.clear()
 			log.info(msg)
 			if msg[0]=="kill": break
 			self._handleEvent(msg)
 	def setHandler(self,handler):
 		self._handleEvent=handler

0 comments (0 inline, 0 general)