Как определить тупик с библиотекой Asio?
У меня небольшая проблема с библиотекой boost :: asio. Мое приложение получает и обрабатывает данные асинхронно, оно создает потоки и запускает io_service.run () для каждого из них.
boost::asio::io_service io;
boost::thread_group thread_pool;
...
int cpu_cnt = get_cpu_count();
for (int i = 0; i < cpu_cnt; ++i)
{
thread_pool.create_thread( boost::bind(&run_service, &io) );
}
void run_service(boost::asio::io_service* io)
{
try
{
io->run();//make fun
}
catch(const std::exception& e)
{ //process error
}
catch(...)
{ //process error
}
}
Время от времени мое приложение получает сообщение (через систему обмена сообщениями Windows) от некоторого супервизорного приложения, которое проверяет, активна моя программа или нет. Если мое приложение не ответит, оно будет перезапущено. Сложная часть здесь - проверить, что потоки работают и не заблокированы. Я могу отправить обработчик в io_service вот так:
io.post( &reply_to_supervisor );
но этот метод влияет только на один поток. Как я могу проверить, что все потоки запущены и не заблокированы?
Ответы 3
Я предполагаю, что ваш io-> run () выполняет какой-то цикл, ожидающий завершения asio. Я также предполагаю, что у вас есть тайм-аут для этой операции asio. Грязный способ проверки - запустить поток состояния и проверить, истекло ли время ожидания потока asio при ожидании завершения asio или что было опубликовано событие asio. В любом случае вы должны установить какую-то переменную или дескриптор, чтобы знать, что ваш поток «жив» и зацикливается. Затем ваш поток состояния проверит каждую переменную / дескриптор и сбросит их после проверки.
Имейте в виду, я уверен, что есть и другие способы, но это то, что сейчас пришло в голову ... =)
Мне это кажется экземпляром Проблема с остановкой, но, поскольку вы, похоже, работаете в Windows, вы можете взглянуть на библиотеку just :: thread Just Software Solution. Это реализация черновой библиотеки потоков C++ 0x, которая имеет встроенное обнаружение взаимоблокировок в собственных мьютексах.
В конце концов, вам, вероятно, лучше задать этот вопрос на список рассылки asio. Автор библиотеки очень полезен, и либо он, либо другой хардкорный пользователь asio может дать лучший ответ там.
Я могу ошибаться, но решит ли вашу проблему использование io_service для каждого потока?
Другая идея: опубликуйте cpu_cnt раз, когда вызовы reply_to_supervisor используют немного sleep() - нехорошо, но должно работать