SHA256
31 lines
567 B
Python
31 lines
567 B
Python
# Aquitectura: 3 hilos -> Wwebsocket -> Procesamiento -> Visualización
|
|
|
|
# Base: Hilos y datos buffer de datos compartidos
|
|
import queue
|
|
import threading
|
|
|
|
from src.cliente_ws import websocket_cliente
|
|
|
|
# Datos globals
|
|
ip_server = "10.42.0.100:81"
|
|
|
|
# Cola de datos compartidos
|
|
raw_data = queue.Queue()
|
|
data_clean = queue.Queue()
|
|
|
|
|
|
def debug_print():
|
|
while True:
|
|
raw = raw_data.get()
|
|
print(raw)
|
|
|
|
|
|
hilo_1 = websocket_cliente(raw_data, ip_server)
|
|
hilo_2 = threading.Thread(target=debug_print)
|
|
|
|
hilo_1.start()
|
|
hilo_2.start()
|
|
|
|
hilo_1.join()
|
|
hilo_2.join()
|