Прерывание boost :: thread, пока прерывания отключены - PullRequest
Новая
       24

Прерывание boost :: thread, пока прерывания отключены

1 голос
/ 02 марта 2011

При использовании boost :: threads я столкнулся с этой проблемой прерывания.Когда я делаю boost :: thread_interrupt из потока A в потоке B, в то время как у B отключены прерывания (boost :: this_thread :: disable_interrupts di), прерывание кажется потерянным.То есть, если я добавлю boost :: thread :: interrupt_point () после разрешения прерывания, он не выдаст исключение boost :: thread_interrupted.

Это ожидаемое поведение или яделаете что-то не так?

Спасибо

1 Ответ

4 голосов
/ 02 марта 2011

Ничто в документации не говорит о том, что прерывания повторно запускаются, когда поток B повторно разрешает прерывания. Я попробовал простую тестовую программу и могу подтвердить поведение, которое вы описываете.

После повторного включения прерываний вы можете проверить this_thread::interruption_requested(), чтобы увидеть, было ли прерывание запрошено, когда прерывания были отключены. Если прерывание действительно было запрошено, вы можете вызвать исключение thread_interrupted самостоятельно.

Вот рабочая программа, которая демонстрирует это: 

#include <boost/thread.hpp>
#include <iostream>

using namespace std;
using namespace boost;

void threadB()
{
    int ticks = 0;
    this_thread::disable_interruption* disabler = 0;
    try
    {
        while (ticks < 20)
        {
            if (ticks == 5)
            {
                cout << "Disabling interruptions\n";
                disabler = new this_thread::disable_interruption;
            }
            if (ticks == 15)
            {
                cout << "Re-enabling interruptions\n";
                delete disabler;
                if (this_thread::interruption_requested())
                {
                    cout << "Interrupt requested while disabled\n";
                    throw thread_interrupted();
                }
            }
            cout << "Tick " << ticks << "\n";
            thread::sleep(get_system_time() + posix_time::milliseconds(100));
            ++ticks;
        }
    }
    catch (thread_interrupted)
    {
        cout << "Interrupted\n";
    }
}

int main()
{
    thread b(&threadB);
    thread::sleep(get_system_time() + posix_time::milliseconds(1000));
    b.interrupt();
    cout << "main -> Interrupt!\n";
    b.join();
}

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

...