launch_ems.py
No OneTemporary
Actions

Subscribers

None

File Metadata

	__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()