come condividere le variabili globali attraverso i thread in python?

Question

Voglio terminare un ciclo in esecuzione in un thread separato utilizzando una variabile globale. ma questo codice non sembra interrompere il ciclo in loop. Mi aspetto che il programma non stampi più '.' dopo 2 secondi, ma funziona ancora a tempo indeterminato.

Sto facendo qualcosa di fondamentalmente sbagliato qui?

import time 
import threading 
run = True 

def foo(): 
    while run: 
     print '.', 

t1 = threading.Thread(target=foo) 
t1.run() 
time.sleep(2) 
run = False 
print 'run=False' 
while True: 
    pass 

Answer 1

1. si sta eseguendo foo() sul thread principale chiamando t1.run(). Dovresti chiamare lo t1.start().

2. Hai due definizioni di foo() - non importa, ma non dovrebbe esserci.

3. Non è stato inserito un sleep() all'interno del ciclo del filo (in foo()). Questo è molto brutto, dal momento che suona il processore. Dovresti almeno inserire time.sleep(0) (rilasciare il time slice ad altri thread) se non farlo dormire un po 'più a lungo.

Ecco un esempio di lavoro:

import time 
import threading 
run = True 

def foo(): 
    while run: 
     print '.', 
     time.sleep(0) 

t1 = threading.Thread(target=foo) 
t1.start() 
time.sleep(2) 
run = False 
print 'run=False' 
while True: 
    pass 

Answer 2

Non avvia un thread chiamando run(), si avvia chiamando start(). Fixing che ha funzionato per me.

Answer 3

In aggiunta alle risposte date ...

La 'corsa' variabile è una variabile globale.

Quando lo si modifica in un'altra funzione, ad es. all'interno della funzione main(), è necessario fare riferimento alla variabile globale, altrimenti non sarà modificata globalmente.

def main(): 
    global run 
    ... 
    run = False 
    ... 

if __name__ == "__main__": 
main()