синхронизация потоков

Question

скажем, у меня есть метод блокировки, давайте вызовем Block ().

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

однако у меня есть другое условие.

Я хочу, чтобы вызов block возвращался через 5 секунд, в противном случае я хочу, чтобы основной поток знал, что вызов Block завершился неудачей, и выйти из рабочего потока.

что было бы лучшим решением для этого сценария?

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

Кроме того, я определю логическое указание IsReturned, возвращала ли функция Block уже. после вызова блокировки, чтобы установить его истинным.

в соответствии с этим логическим значением в функции таймера, я решаю, как поступить:

1. если логическое значение истинно, я ничего не делаю.

2. если логическое значение равно false, я могу поставить APC OnFailure в очередь или, возможно, сообщить о событии Sucess в главном потоке и принудительно выйти из рабочего потока (дело в том, что я не уверен, что смогу это сделать)

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

p.s - если я точно знаю, что могу отменить рабочий поток внутри функции таймера, я не думаю, что мне даже нужен материал gettickcount.

спасибо!

Answer 1

Я бы предложил для этого использовать библиотеку boost :: threads. Вы можете периодически проверять, является ли блокирующий поток присоединяемым (т.е. все еще работает), а затем прерывать его через пять секунд. Затем вам нужно будет написать функцию блокировки, чтобы обработать это прерывание и завершить работу.

#include <boost/thread/thread.hpp>

void Block(void)
{
    //Do work and periodically call boost::this_thread::sleep()
    try
    {
        boost::this_thread::sleep(boost::posix_time::milliseconds(100));
    }
    catch(boost::thread_interrupted const&)
    {
        return;
    }
}

int main(int argc, char *argv[])
{
    boost::thread blockThread(Block); //If Block takes arguments, just add them as arguments to the constructor.
    time_t startTime = time(NULL);

    while(true)
    {
        if(blockThread.joinable() && (time(NULL) - startTime) > 5)
        {
            blockThread.interrupt();
        }
        //Do whatever you want while waiting for the thread to finish.
    }
}

Редактировать: см. Документацию Управление потоками , чтобы узнать больше точек прерывания и определение класса потоков повышения.

Edit2: если вам не нужно выполнять какую-либо работу в основном потоке в ожидании завершения блокирующего потока, и нет удобного места для обработки прерываний в Block(), вы можете явно убить поток с помощью чего-то вроде это:

void Block(void)
{
    //Do work
}

int main(args)
{
    boost::thread blockThread(Block);

    //timed_join() returns false if the thread is still running after the specified time.
    if(!blockThread.timed_join(boost::posix_time::milliseconds(5000)))
    {   //detach() will kill the thread, any memory initialised in Block() will not be freed, any locals may or may not be freed either.
        blockThread.detach();
    }
}

Answer 2

Я думаю, у вас примерно правильная идея, хотя вы, вероятно, хотите, чтобы сообщения WM_TIMER доставлялись в основной поток, а не в потенциально блокирующий поток. В противном случае сообщения таймера могут быть потеряны, если поток блокируется до срабатывания таймера! Аналогично, проверьте прошедшее время в главном потоке, а не в рабочем, поскольку, если Block() блокируется, он не вернется, и вызов GetTickCount() после Block() никогда не произойдет.

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

Как правило, уничтожение заблокированной темы может быть опасным. Документация Java настоятельно предупреждает против этого, и, если что-то, проблемы хуже с C ++. Считай себя предупрежденным!

Answer 3

Первое создание потоков - это дорогое удовольствие, поэтому выполнение каждого вызова Block может быть не очень хорошей идеей.

Во-вторых, есть множество способов решить эту проблему, это также сильно зависит от вашей среды. Например, в Windows возможный способ сделать это - создать рабочий поток с очередью сообщений. Затем вы определяете пару сообщений, которые вы обрабатываете в своем рабочем потоке. Одним из них может быть WM_CALLBLOCK, другим может быть WM_AREYOUREADY и WM_YESIAM, когда вы хотите вызвать Block (), вы можете просто отправить это сообщение в рабочий поток, и он вызовет функцию. С помощью сообщения вы также можете передать любые параметры, которые вам нужны для Block (). Поскольку ваша функция блокирует - если вы отправите сообщение WM_AREYOUREADY, вы не получите прямого ответа WM_YESIAM. Таким образом, вы могли бы рассчитать время ожидания на этом.