Как я могу выйти из потока, когда мой пользовательский интерфейс получает закрытый ввод в MFC
Я делаю некоторую программу с «MFC».
При нажатии кнопки A обработчик сообщений создает новый поток для работы.
На работе пользователь может нажать кнопку B, чтобы выйти из приложения.
В потоке, созданном кнопкой A, используется созданный мной класс C.
Класс динамически выделяет некоторые ресурсы на работу.
Когда кнопка B нажата, я хочу отменить выделение ресурсов до того, как мое приложение умрет.
Как я могу это сделать? Помогите, пожалуйста!!! :)
void CMyDlg::On_A_BnClicked() { // do the job button
...
AfxBeginThread(MyThread, (LPVOID)this);
...
}
UINT CMyDlg::MyThread(LPVOID arg) {
...
MyCClass mcc;
for (int i = 0; i < 100; i++) {
...
mcc.init(file_name);
mcc.do_somethin();
mcc.deinit();
...
}
...
}
void CMyDlg::On_B_BnClicked() { // close button
}
void MyCClass::init(file_name) {
mFileClass.Open(file_name, CFile::modeCreate | CFile::modeWrite);
// and so on
...
}
Если пользователь нажимает кнопку B, когда метод 'do_somethin' выполняется в MyThread.
Как я могу выйти из MyThread после метода deinit() объекта MyCClass?
Я подумал о том, как создать событие в обработчике кнопок B, а затем отправить сообщение в MyCClass.
Так что я могу деинициализировать все ресурсы в обработчике сообщений MyCClass.
Но похоже не работает. :(
Ответы 1
Общий механизм:
Ваш рабочий поток (WT) должен иметь защищенный элемент данных bool bRunning = true (по умолчанию), функцию-член Exit(), которая устанавливает bRunning = false. Цикл WT регулярно проверяет bRunning и прерывает false. Когда вы создаете WT, сохраните его дескриптор (скажем, hWT), а перед выходом из приложения вызовите hWT->Exit().
--
В случае, если выход WT может занять много времени, добавьте механизм синхронизации. Типа пример:
// WT.h
public:
int Run();
void Exit() // ** Assume that only main-thread call this, once. **
{
std::mutex m_dummy_mutex;
std::unique_lock<std::mutex> guard(m_dummy_mutex);
TRACE("WT state switched to not-running.\n");
m_bRunning = false; // <-- (1)
TRACE("Wait for WT stopped notification...\n");
// (It may happen that the receiver wakes up, although no notification happened.)
bool rv = m_stopped.wait_for(guard, std::chrono::seconds(5), // <-- (2)
[this]() {return (m_pResource == nullptr); });
// 'Spurious Wakeup' mitigation with lambda predicate.
#ifdef _DEBUG
if (rv)
TRACE("WT stopped notification - Recieved.\n");
else
TRACE("WT stopped notification - Timeout expired.\n");
#endif
}
protected:
std::condition_variable m_stopped;
bool m_bRunning = true; // Running until Stop().
CResource * m_pResource = nullptr;
В цикле WT:
// WT.cpp
int CWT::Run()
{
m_pResource = new CResource; // Let's say CResource is your Resource.
while (m_bRunning)
{
// Do something ... (May take time. Check regularly m_bRunning to abort.)
if (!m_bRunning)
{
delete m_pResource;
m_pResource = nullptr;
m_stopped.notify_one(); // <-- (3)
TRACE("WT stopped. Main-thread notified.\n");
continue;
}
}
return 0;
}
- Вместо new/delete лучше использовать умные указатели C++.
@hslee, я добавил «своего рода» решение этой проблемы.
Я закодировал с вашим первым советом. Конечно, есть некоторые задержки. Но в качестве альтернативы я сделал интерфейс ожидания для пользователя во время ожидания. Спасибо за ваши Коментарии. :-)
Если я это сделал, то мне нужно дождаться окончания метода
do_somethin(), который выполняется, когда пользователь нажимает кнопку B (это возможный сценарий, потому что методdo_somethin()требует много времени) '0' Я хочу немедленно выйти из приложения нажатием кнопка закрытия. :)