waiting_loop.py

import time
import socket
import json
import threading

# Flag di controllo per avviare e fermare il loop
waiting_active = False
waiting_thread = None

# Funzione per avviare il loop
def waiting_loop():
    global waiting_active
    host = '10.3.1.1'  # Indirizzo del server
    port = 7000  # Porta del server

    client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)  # Creazione della connessione
    client_socket.connect((host, port))

    # Ciclo che invia i dati finché waiting_active è True
    while waiting_active:
        with open("Actions/standard.txt", "r") as f:
            message = f.read()
        message = json.dumps(message)
        client_socket.send(message.encode())
        time.sleep(2)

        with open("Actions/waiting.txt", "r") as f:
            message = f.read()
        message = json.dumps(message)
        client_socket.send(message.encode())
        time.sleep(2)

        with open("Actions/waiting1.txt", "r") as f:
            message = f.read()
        message = json.dumps(message)
        client_socket.send(message.encode())
        time.sleep(2)

        with open("Actions/waiting2.txt", "r") as f:
            message = f.read()
        message = json.dumps(message)
        client_socket.send(message.encode())
        time.sleep(2)

        with open("Actions/waiting3.txt", "r") as f:
            message = f.read()
        message = json.dumps(message)
        client_socket.send(message.encode())
        time.sleep(2)

        with open("Actions/waiting4.txt", "r") as f:
            message = f.read()
        message = json.dumps(message)
        client_socket.send(message.encode())
        time.sleep(2)

    client_socket.close()  # Chiude la connessione quando il loop si ferma

# Funzione per avviare il thread del waiting loop
def start_waiting_loop():
    global waiting_active, waiting_thread
    if not waiting_active:
        waiting_active = True
        waiting_thread = threading.Thread(target=waiting_loop)
        waiting_thread.start()

# Funzione per fermare il waiting loop
def stop_waiting_loop():
    global waiting_active, waiting_thread
    waiting_active = False
    if waiting_thread is not None:
        #waiting_thread.join()  # Aspetta che il thread termini prima di proseguire
        waiting_thread = None

if __name__ == '__main__':
    start_waiting_loop()  # Avvia il loop (questo può essere chiamato dal file principale)
    time.sleep(10)  # Esegui il loop per 10 secondi
    stop_waiting_loop()