Как я могу завершить QThread

Question

В последнее время я сталкиваюсь с этой проблемой, как я записал в этом разделе. Я попытался использовать QThread :: terminate(), но я просто НЕ могу остановить поток, который находится в мертвом цикле (скажем, while (1)).

спасибо большое.

Answer 1

Вы пробовали exit или quit?

Answer 2

Был ли поток называть QThread::setTerminationEnabled(false)? Это приведет к бесконечной задержке потока.

EDIT: Я не знаю, на какой платформе вы находитесь, но я проверил реализацию Windows QThread :: terminate. Предполагая, что поток на самом деле работает для начала, и завершение не было отключено с помощью вышеупомянутой функции, это в основном оболочка вокруг TerminateThread() в Windows API. Эта функция принимает неуважение от нитей и, как правило, оставляет беспорядок с утечками ресурсов и подобным обвисшим состоянием. Если это не убивает поток, вы либо имеете дело с вызовами ядра зомби (скорее всего, заблокированными ввода-выводами), либо имеют еще большие проблемы где-то.

Answer 3

Завершение потока - это простое решение для остановки операции async, но обычно это плохая идея: поток может выполнять системный вызов или может быть посреди обновления структуры данных при ее завершении, что может оставить программу или даже ОС в неустойчивом состоянии.

Попытайтесь преобразовать свое время (1) во время (isAlive()) и make isAlive() вернуть false, когда вы хотите, чтобы поток вышел.

Answer 4

Чтобы использовать неназванные трубы

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

В качестве, когда, где вы собираетесь создать трубы использовать

if(pipe(gPipeFdTest) < 0) 

{ 

perror("Pipe failed"); 

exit(1); 

} 

Приведенный выше код создает трубу, которая имеет два конца gPipeFdTest [0] для чтения и gPipeFdTest [1] для записи. Что вы можете сделать, так это в вашей функции запуска, настроенной на чтение канала с использованием системного вызова. И с того места, где вы хотите выйти из режима работы, там настроена запись с использованием системного вызова. Я использовал выбранный системный вызов для мониторинга конца считывания, поскольку он подходит для моего внедрения. Постарайтесь понять все это в вашем случае. Если вам нужна дополнительная помощь, дайте мне шум.

Edit:

Моя проблема была так же, как ваши. У меня было некоторое время (1) цикл, а другие вещи, которые я пробовал, нуждались в мьютексах и других причудливых многопоточных mumbo jumbo, которые добавили сложности и отладки были кошмаром. Использование труб освободило меня от этих сложностей, кроме упрощенного кода. Я не говорю, что это лучший вариант, но в моем случае это была лучшая и самая чистая альтернатива. Перед этим решением я прослушивал свое приложение.

Answer 5

QThreads может зайти в тупик, если они заканчиваются «естественно» во время завершения.

Например, в Unix, если поток ожидает «чтение», попытка завершения (сигнал Unix) заставит «читать» вызов прерываться с кодом ошибки до уничтожения потока.

Это означает, что нить все еще может достигать естественной точки выхода при ее окончании. Когда это происходит, достигается взаимоблокировка, поскольку некоторые внутренние мьютекс уже заблокированы вызовом «завершить».

Мое обходное решение - убедиться, что нить никогда не возвращается, если она была прекращена.

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

    // Do stuff... 
} 

while(wasTerminated) 
    sleep(1); 

return; 

wasTerminated здесь на самом деле реализован немного более сложным, с использованием атомных Интсов:

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); 
    } 
}