ebbe.bass
/
PiXelTubes
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

thread manager 

Signed-off-by: Ebbe Baß <ebbe.bass>
main
Ebbe Baß 2024-02-17 17:19:53 +01:00
parent 070ae2fa41
commit f0f13debae
1 changed files with 14 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
server/app.py
View File

@ -7,7 +7,10 @@ import os
from getmac import get_mac_address from getmac import get_mac_address
import time import time
import sys import sys
from multiprocessing import Process, Value, Array, set_start_method from multiprocessing import Process, Manager
thread_manager = Manager()
TUBE_INDEX = thread_manager.Array()
app = Flask(__name__) app = Flask(__name__)
@ -145,18 +148,19 @@ def mqtt_publisher():
artNet.close() artNet.close()
sys.exit() sys.exit()
def tube_index_updater():
if __name__ == "__main__":
set_start_method("spawn")
flask_thread = Process(target=flask_api)
flask_thread.start()
publisher_thread = Process(target=mqtt_publisher)
publisher_thread.start()
while True: while True:
cur = db.cursor() cur = db.cursor()
cur.execute("SELECT mac_address, universe, dmx_address FROM tubes") cur.execute("SELECT mac_address, universe, dmx_address FROM tubes")
TUBE_INDEX = cur.fetchall() TUBE_INDEX = cur.fetchall()
cur.close() cur.close()
print("Updated tube index: "+str(TUBE_INDEX)) print("Updated tube index: "+str(TUBE_INDEX))
time.sleep(1) time.sleep(1)
if __name__ == "__main__":
tube_index_updater_thread = Process(target=tube_index_updater)
tube_index_updater_thread.start()
flask_thread = Process(target=flask_api)
flask_thread.start()
publisher_thread = Process(target=mqtt_publisher)
publisher_thread.start()