c++ - 将 thread_pool 与 deadline_timer 组合 - 模板问题(时间)

Question

我已经集成了 Boost 的 asio 服务并将其与线程池结合使用。

创建了一个线程池来处理 futures 和异步任务，我想进一步扩展它以处理截止时间计时器(反模式？)。不幸的是，我对处理模板代码的理解达到了极限。更准确地说，我想传递一个 boost::posix_time (例如: boost::posix_time::milliseconds(100) 或 boost::posix_time::seconds(5) )，但我很难理解我怎么能使这成为可能。

下面的部分代码 list 是我的线程池的当前实现。

//////////////////////////////////////////////////////////////////////////
class thread_pool
{
public:

    // ...
    // Other boring stuff here...


    //////////////////////////////////////////////////////////////////////////
    template<class Task>
    void enqueue_async(Task task)
    {
        m_pIO->post( std::bind(&thread_pool::wrap_task, this,
                                                  std::function< void() >( task )));
    }

    //////////////////////////////////////////////////////////////////////////
    // NOTE: Needing help here - 'expiry_time' should be relative.
    template <class Task, class ???>
    void enqueue_deadline_async(Task task, const ??? & expiry_time)
    {
        const std::shared_ptr<boost::asio::basic_deadline_timer<???> > apTimer = std::make_shared<boost::asio::deadline_timer>(*get_service_pointer(), expiry_time);
        apTimer->async_wait(std::bind(&thread_pool::enqueue_async, this, task));
    }

private:

    //////////////////////////////////////////////////////////////////////////
    void wrap_task( std::function< void() > task )
    {
        try
        {
            task();
        }
        catch (const std::exception &e)
        {
            // Todo: Log that there is a problem!!
            BOOST_ASSERT_MSG(0,e.what());
        }
    }

};

到目前为止，我一直在使用 enqueue_task(...) 将异步任务排队以供线程池处理。我现在想扩展线程池，以便能够异步调用截止日期计时器的回调参数(请参阅 enqueue_deadline_async())，但让线程池处理任务。

将 thread_pool 与 deadline_time 集成的原因是:

• 尽量减少代码中并发运行的 io_services 的数量。
• 防止 deadline_time 阻塞 io_service 的时间过长 - 减少对其他未决计时器的影响。

最后，我在 io_service 中的嵌套调用是否危险？

环境配置:

• Ubuntu v17.04 (Zesty) x86_x64
• Boost v1.63
• 海湾合作委员会 6.3

Answer 1

一些事情，

template <class Task, class ???>
void enqueue_deadline_async(Task task, const ??? & expiry_time)

因为它是一个可推导的模板参数，只要给它命名，就可以了

template <class Task, class T>
void enqueue_deadline_async(Task task, const T & expiry_time)

下一步:

const std::shared_ptr<boost::asio::basic_deadline_timer<???> > apTimer = std::make_shared<boost::asio::deadline_timer>(*get_service_pointer(), expiry_time);

首先，boost::asio::deadline_timer 已经允许您在问题中想要的内容。所以不要乱用 basic_deadline_timer。其次，共享指针无论如何都需要转换为 apTimer 的类型，这使得它的用处更小(因为选择另一个计时时钟模型甚至无法编译)。

解决方案

只需使用 deadline_timer 也使用的接口(interface):

template <class Task>
void enqueue_deadline_async(Task task, const boost::posix_time::time_duration& expiry_time)

有效:

int main() {
    thread_pool tp;
    tp.enqueue_deadline_async([]{ }, boost::posix_time::seconds(5));
    tp.enqueue_deadline_async([]{ }, boost::posix_time::milliseconds(5));
}