Версия для печати темы Нажмите сюда для просмотра этой темы в оригинальном формате

Форум программистов > C/C++: Общие вопросы > Управление очередью в boost::asio::io_service

Автор: Deeoni$ 18.11.2012, 13:15

Здравствуйте. Есть библиотека объекты классов которой общаются между собой через boost::signal2 сигналы. Библиотека многопоточная, т.е. разные ее модули работают в разных потоках, но все сигналы от них должны обрабатываться в одном специальном потоке. Для этого я использовал boost::asio::io_service, который принимает сигналы от модулей и обрабатывает их в этом специальном потоке. Код выглядит примерно так. Код class MyIOService public:          //! Метод запускающий обслуживающий поток     void init()     {         io_service_ = shared_ptr<boost::asio::io_service>(new boost::asio::io_service);         io_thread_ = auto_ptr<thread>(new thread(&SHCoreIOService::ioServiceRoutine, this, io_service_));     };     //! Метод останавливающий обслуживающий поток     void release(){...};     //! Передача сигнала в очередь io_service     void postSignal(boost::signals2::signal<void()>& sig)     {         io_service_->post(std::bind(std::ref(sig)));     }; private:     shared_ptr<boost::asio::io_service> io_service_;    /*!< Объект обслуживающие асинхронный ввод/вывод */     auto_ptr<thread> io_thread_;                        /*!< Обслуживающий поток */     atomic_bool stop_flag_;                             /*!< Флаг останова цикла обслуживания io операций */     //! Потоковый метод работающий с io_service     void ioServiceRoutine(shared_ptr<boost::asio::io_service> io)     {         while (!stop_flag_)         {             io->run();             Sleep(50);         };     }; }; Но в какой-то момент появилась необходимость присвоить сигналам некую степень важности. Если конкретнее, то сигналы могут приходить в очередь как от самой библиотеки, так и от клиентского кода, через интерфейсный класс. Так вот клиентские сигналы имеют более высокую степень важности, чем сигналы библиотеки. На практике это значит, что клиентский сигнал попадая в очередь должен: 1) Удалять из очереди все не обработанные сигналы от библиотеки 2) Блокировать очередь для поступления новых Так вот вопрос есть ли какой-нибудь способ управлять очередью io_service, а точнее удалять из нее не нужные мне объекты? Или надо писать свой класс для этого?

Powered by Invision Power Board (http://www.invisionboard.com)
© Invision Power Services (http://www.invisionpower.com)