VPF::Управление очередью в boost::asio::io_service

Deeoni$

Дата 18.11.2012, 13:15 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 23
Регистрация: 24.2.2003

Репутация: нет
Всего: нет

Здравствуйте.

Есть библиотека объекты классов которой общаются между собой через 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, а точнее удалять из нее не нужные мне объекты? Или надо писать свой класс для этого?

1 Пользователей читают эту тему (1 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема \| C/C++: Общие вопросы \| Следующая тема »