c++ - 使用Boost Asio设置发布队列大小限制吗？

我正在使用boost::asio::io_service作为基本线程池。一些线程被添加到io_service，主线程开始发布处理程序，辅助线程开始运行处理程序，并且一切都完成了。到现在为止还挺好;与单线程代码相比，我得到了很好的加速。

但是，主线程要发布数百万个东西。而且它只是不断地发布它们，这比工作线程处理它们的速度快得多。我没有达到RAM限制，但是要排队那么多事情还是很愚蠢的。我想做的是为处理程序队列设置一个固定大小，如果队列已满，则设置post()块。

在Boost ASIO文档中，我看不到任何选项。这可能吗？

最佳答案

我正在使用信号量来修复处理程序的队列大小。以下代码说明了此解决方案:

void Schedule(boost::function<void()> function)
{
    semaphore.wait();
    io_service.post(boost::bind(&TaskWrapper, function));
}

void TaskWrapper(boost::function<void()> &function)
{
    function();
    semaphore.post();
}