Partage de variable entre les threads

global

global

#Ajout des librairies :

import socket 			#pour les sockets	
import websockets 		#pour les websockets  
import asyncio    		#pour les fonctions asynchrones (qui s'execute dans n'importe quel ordre)		
import time				#pour le sleep()	
from threading import Thread


#Fonction liée au thread UDP 
def listen_udp():
	len_data = 1024
	#Création socket UDP
	s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

	#Lier la socket à l'adress IP et le port
	s.bind(('localhost', 1234))
	print("Serveur UDP à l'écoute")
    global msg_gnuradio
	while(True):

		addr = s.recvfrom(len_data)
		msg_gnuradio = format(addr)
		# print(msg_gnuradio)
		time.sleep(1)


#Fonction liée au thread WEB 
async def listen_ws(websocket, path):
    try:
        msg_client = await websocket.recv()
        print("< " + msg_client)
        i = 0
        global msg_gnuradio
        while True:
            try:
                await websocket.send(format(i)+" : "+msg_gnuradio)
                # print("> datas envoyées")
                time.sleep(1)
                i = i+1
            except KeyboardInterrupt:
                print("Exiting program...")
    finally:
        await websocket.send("Le serveur n'est pas connecté à GNURadio")
	

def start_loop(loop, server):
    loop.run_until_complete(server)
    loop.run_forever()


#Lancement Thread UDP 
udp = Thread(target=listen_udp)			#Création thread pour l'UDP	
udp.start()

# start a new event loop
new_loop = asyncio.new_event_loop()

#Lancement Thread WEB 
port_websockets = 8000		#port pour les connexions websocket	
nb_clients = 0				#nombre de clients connecté	
start_server = websockets.serve(listen_ws, "localhost", port_websockets, loop=new_loop)
web = Thread(target=start_loop, args=(new_loop, start_server))
web.start()
print("Serveur websocket à l'écoute sur le port " + str(port_websockets))

for i in range(10):
    print(format(i)+" : " +msg_gnuradio)
    time.sleep(2)

msg_gnuradio = "o"