Come posso terminare un QThread

Question

Recentemente, mi sono imbattuto in questo problema come ho memtionato in questo titolo. Ho provato usando QThread :: terminate(), ma non posso semplicemente fermare il thread, che è in un ciclo morto (diciamo, mentre (1)).

grazie mille.

Answer 1

Hai provato exit o quit?

Answer 2

Il thread ha chiamato QThread::setTerminationEnabled(false)? Ciò farebbe ritardare indefinitamente la terminazione del thread.

EDIT: Non so su quale piattaforma ci si trova, ma ho controllato l'implementazione di Windows di QThread :: terminate. Supponendo che il thread fosse effettivamente in esecuzione per cominciare, e la terminazione non è stata disabilitata tramite la funzione sopra, è fondamentalmente un wrapper attorno all'API di Windows TerminateThread(). Questa funzione accetta la mancanza di rispetto da nessun thread e tende a lasciare un disastro dietro con perdite di risorse e stato penzolante simile. Se non si sta uccidendo il thread, si ha a che fare con le chiamate del kernel zombie (molto probabilmente con I/O bloccato) o si hanno problemi ancora più grandi da qualche parte.

Answer 3

Terminare il thread è la soluzione facile per arrestare un'operazione asincrona, ma di solito è una cattiva idea: il thread potrebbe fare una chiamata di sistema o potrebbe essere nel mezzo dell'aggiornamento di una struttura di dati quando viene interrotta, che potrebbe lasciare il programma o anche il sistema operativo in uno stato instabile.

Prova a trasformare il tuo while (1) in while (isAlive()) e make isAlive() restituisce false quando vuoi che il thread esca.

Answer 4

Per utilizzare pipe senza nome

int gPipeFdTest[2]; //create a global integer array 

Come quando dove si intende creare tubi utilizzare

if(pipe(gPipeFdTest) < 0) 

{ 

perror("Pipe failed"); 

exit(1); 

} 

Il codice precedente creerà un tubo che presenta due estremità gPipeFdTest [0] per la lettura e gPipeFdTest [1] per la scrittura. Quello che puoi fare è impostare la funzione di corsa per leggere la pipe usando select system call. E da dove si vuole uscire di corsa, ci si prepara a scrivere usando la chiamata di sistema di scrittura. Ho usato una chiamata di sistema selezionata per monitorare l'estremità letta della pipa come meglio si adatta alla mia implmentazione. Cerca di capire tutto questo nel tuo caso. Se hai bisogno di ulteriore aiuto, dammi un ronzio.

Modifica:

Il mio problema era proprio come il tuo. Ho avuto un ciclo while (1) e le altre cose che ho provato erano necessarie mutex e altri fantasiosi mumbo jumbo multithreading, che aggiungevano complessità e debugging era un incubo. L'uso dei tubi mi ha assolto da quelle complessità, oltre a semplificare il codice. Non sto dicendo che sia l'opzione migliore, ma nel mio caso si è rivelata l'alternativa migliore e più pulita. Sono stato intercettato dalla mia applicazione sospesa prima di questa soluzione.

Answer 5

QThreads può deadlock se terminano "naturalmente" durante la terminazione.

Ad esempio in Unix, se il thread è in attesa di una chiamata "read", il tentativo di terminazione (un segnale Unix) farà interrompere la chiamata "read" con un codice di errore prima che il thread venga distrutto.

Ciò significa che il thread può ancora raggiungere il punto di uscita naturale mentre viene terminato. Quando lo fa, viene raggiunto un deadlock poiché un mutex interno è già bloccato dalla chiamata "terminate".

Per risolvere il problema, verificare che il thread non sia mai restituito se è stato terminato.

while(read(...) > 0) { 

    // Do stuff... 
} 

while(wasTerminated) 
    sleep(1); 

return; 

wasTerminated qui è in realtà implementato un po 'più complesso, utilizzando int atomiche:

enum { 

    Running, Terminating, Quitting 
}; 

QAtomicInt _state; // Initialized to Running 

void myTerminate() 
{ 
    if(_state.testAndSetAquire(Running, Terminating)) 
    terminate(); 
} 

void run() 
{ 
    [...] 

    while(read(...) > 0) { 

    [...] 
    } 

    if(!_state.testAndSetAquire(Running, Quitting)) { 
    for(;;) sleep(1); 
    } 
}