Безопасное завершение потока

Question

Рабочий поток обрабатывает обновления баз. Когда приложение заканчивается, я хочу закончить его, но не позволяя ему оставить db непоследовательным. Поэтому я использую флаги перед каждой значительной операцией db. Через некоторое время, код полон, если это:

 void MyWorkerThread::RunMethod(){ 
     if (false == m_Manager->GetShutdownFlag()) { 
     DoSomethingOnDB(); 
     } 
     if (false == m_Manager->GetShutdownFlag()) { 
     DoSomethingMoreOnDB(); 
     } 
     ... 

Итак, есть ли другой способ справиться выключение без спамить так много, если х?

Answer 1

Там в шаблон в коде, что означает, что вы можете абстрагировать как функция:

void MyWorkerThread::execDBCommand(auto cmd){ 
    if (! m_Manager->GetShutdownFlag()) { 
     cmd(); 
    } else throw std::runtime_error("shutdown"); // or a custom exception 
} 

с внешним try...catch для этого исключения в вашем RunMethod более непосредственно прервать обработку.

Однако флаг отключения может быть лучше обработан как сигнал для потока, который затем откатывает любую ожидающую транзакцию и отменяет обработку без необходимости проверять состояние перед каждой инструкцией. Вам также придется маскировать сигналы во время вызовов БД.

Это зависит от вашей программной архитектуры, конечно.

Answer 2

Вам было бы лучше синхронизировать потоки через какой-либо объект синхронизации (событие, блокировку, мьютексы, семафор, критический раздел, что угодно ...) или такие, чтобы основной поток мог ждать рабочего потока.

Здесь у вас есть условие гонки: что делать, если флаг выключения поднимается сразу после if Состояние оценивается и до выполнения операции БД?

Вот иллюстрация с мьютексами как известный примитив синхронизации, но есть лучшие способы.

Главная нить:

int main() { 
    ... wait for signal to exit the app 
    // the DB operations are running on another thread 
    ... 
    // assume that we start shutdown here 
    // also assume that there is some global mutex g_mutex 
    // following line blocks if mutex is locked in worker thread: 
    std::lock_guard<std::mutex> lock(g_mutex); 
    Cleanup(); // should also ensure that worker is stopped 
} 

Рабочий поток:

void MyWorkerThread::RunMethod() 
{ 
    { 
    std::lock_guard<std::mutex> lock(g_mutex); 
    DoSomethingOnDB(); 
    } 
    // some other, non locked execution which doesn't prevent 
    // main thread from exiting 
    ... 
    { 
    std::lock_guard<std::mutex> lock(g_mutex); 
    DoSomethingMoreOnDB(); 
    } 
} 

, как, очевидно, вы не хотите, чтобы повторить все блокировки, вы должны обернуть его:

void MyWorkerThread::RunMethod() 
    { 
    Execute(DoSomethingOnDB); 
    ... 
    Execute(DoSomethingMoreOnDB); 
    } 

    void MyWorkerThread::Execute(DatabaseFn fn) 
    { 
    std::lock_guard<std::mutex> lock(g_mutex); 
    fn(); 
    } 

Answer 3

Если ваши функции Do возвратили что-то, то вы могли бы & & или || их вместе, поэтому, как только один из них вернет «ложный» или «истинный», в зависимости от условия завершения, вы прекратите обработку.

Что произойдет, если флаг отключения будет установлен другим потоком во время вашей операции (или непосредственно перед его выполнением?), И что произойдет, если вы все равно выполните этот процесс.

Answer 4

У вас есть замки ReaderWriter уже в ваших приложениях? Вы должны рассматривать закрытие базы данных как операцию записи и получить блокировку Writer перед ее запуском. Тогда никто из других Read (которые получают Lock Lock) или операции записи (которые получают Writer Lock) могут запускаться после завершения закрытия.

Answer 5

Ваше использование флага будет ограничено различными методами, которые используют базу данных: DoSomethingOnDB, DoSomethingMoreOnDB ...

Предполагая, что вы используете семафоры и замки должным образом (который не кажется, здесь), вы можете собрать методы баз данных, связанных с в сложный метод и заблокировать вашу базу данных там и выполнить одну операцию проверки bool в этом единственном методе, чтобы только один поток выполнял операцию базы данных за раз.