R3852/launch_ems.py
70dd241f0e88master

launch_ems.py
View Options

			__author__ = 'Olivier Van Cutsem'

			from multiprocessing import Queue
			from rtevents_interface.rtevents_interf import RTEventInterface
			from emscore.ems_main import EnergyManagementSystem
			from emscore.simple_control import EMS_simple
			from emscore.mpc import EMS_MPC
			from ems_gui.gui import EMS_gui


			########### LAUNCHING THE THREADS ###################

			print("Starting EMS ")

			bms_stream_rtevents = Queue()
			ems_stream_rtevents = Queue()
			gui_stream = Queue()

			print("Launching threads for the interface frontend and the CMS")

			rtevents_interf = RTEventInterface(bms_stream_rtevents, ems_stream_rtevents) # RT Interface
			ems_core = EMS_MPC(bms_stream_rtevents, ems_stream_rtevents, gui_stream) # The core of the EMS logic

			# Start the thread

			rtevents_interf.start()
			ems_core.start()

			# Do infinite loop here for GUI job

			gui = EMS_gui()

			while True:
			# Messages coming from the EMS
			try:
			new_msg = gui_stream.get(True)
			except Queue.Empty:
			new_msg = None

			# Process the message
			gui.process_message(new_msg)


			rtevents_interf.join()
			ems_core.join()