Блог

У меня возник вопрос о объединяемых потоках в wxWidgets.

Когда пользователь захочет этого, я хочу остановить поток, выполняющий некоторую работу. По этой причине я вызываю в этом рабочем потоке TestDestroy(), чтобы проверить, следует ли останавливать поток. Но я могу остановить поток только таким образом, вызвав Delete() , который не следует вызывать для объединяемых потоков.

Есть ли у меня возможность остановить поток (используя TestDestroy) или мне нужно полностью изменить свой код?

Заранее спасибо,

ТиБо

Текущая документация для wxThread::Delete() гласит:

Эта функция работает с объединяемым потоком, но в этом случае функция TestDestroy() потока возвращает значение true, а затем ожидает его завершения (т. Е. Она отличается от Wait() тем, что запрашивает завершение потока перед ожиданием).

Итак, похоже, что вы можете использовать Delete() в объединяемом потоке.

Вы должны вызвать метод Exit() из вашего рабочего потока или просто вернуться из метода Run и вызвать метод MyThread-> Wait(), а затем удалить объект thread.

Объявление потока :

 class MyThread : public wxThread {
  virtual void * run();
};
  

Реализация потока :

 MyThread::run()
{
  while(1)
  {
    if(TestDestroy())
    {
        this.Exit();  // or return;
    }
    // Do some work
  }
}
  

Объявление указателя потока :

 MyThread * pMyThread;
  

Создание, запуск и остановка потока

 void launchThread{
  pMyThread = new wxThread(wxTHREAD_JOINABLE);
  pMyThread->Create();
  pMyThread->Run();
}

void stopThread(){
  pMyThread->Delete();
  pMyThread->Wait();
  delete pMyThread;
}
  

Надеюсь, что это поможет.

PS: это мой первый ответ на переполнение стека. Я не знаю, как я могу легко написать какой-нибудь код с автоматическим отступом?

Вам не придется переписывать свой код.

Обычно лучше, чтобы поток завершался возвратом из его основной функции, как предлагает документация.

Один из способов достижения этого, и, вероятно, самый простой, — создать некоторый объект, который будет перехвачен функцией основного потока.

Например:

 struct ThreadEndingException { };

void DoSomeWork() {
    ...
    if (TestDestroy())
        throw ThreadEndingException();
    ...
}

void ThreadFunction() {
    try {
        DoSomeWork();
    }
    catch (const ThreadEndingExceptionamp;) {
        // Do nothing, the function will return after leaving this catch.
    }
}