创建接受带有转发参数的共享 packaged_task

Question

您好，我不知道如何编写正确的队列绑定并执行传递给 OCRQueue::enqueue() 方法的 lambda 表达式

// the task queue
std::queue< std::function<void(OCRK*)> > tasks;

// add new work item to the pool
template<class F>
auto OCRQueue::enqueue(F&& f)
-> std::future<typename std::result_of<F(OCRK*)>::type>
{
    using return_type = typename std::result_of<F(OCRK*)>::type;

    auto task = std::make_shared< std::packaged_task<return_type()> >
    (
        // how to initialize this task so that it can be called 
        // task(OCRK*) passing the parameter to f(OCRK*)
        std::bind
        (
            std::forward<F>(f)
        )
    );

    std::future<return_type> res = task->get_future();
    {
        std::unique_lock<std::mutex> lock(queue_mutex);

        // don't allow enqueueing after stopping the pool
        if (stop)
            throw std::runtime_error("enqueue on stopped thread_pool");

        // this fails because task does not accept parameters
        tasks.emplace([task](OCRK* ocr){ task(ocr); });
    }
    condition.notify_one();
    return res;
}

目前这无法在“auto task =”上编译，因为 f 需要一个 OCRK* 类型的参数：

错误 6 错误 C2064：术语不计算为采用 0 个参数的函数 C:\Program Files (x86)\Microsoft Visual Studio 12.0\VC\include\xrefwrap 58 1 Skilja.PR.API

On: 1> d:\sourcecode\skilja\alpr\alpr\skilja.pr.api.native\OCRQueue.h(51) : 参见函数模板实例化 'std::shared_ptr> std::make_shared, std::_Bind &,>>(std::_Bind &,> &&)' 正在编译

预期的用法是这样的：

OCRQueue ocrPool(std::thread::hardware_concurrency());
auto work = [](OCRK* ocr)
{
    return ocr->DoSomething();
};
future<DoSomethingResult> result = ocrPool.enqueue(work);

OCRK* 将在出队并在另一个线程中执行时传递给入队函数。

Answer 1

要创建一个接受单个参数的可调用对象，您需要告诉bind 为参数使用占位符：

std::bind( std::forward<F>(f), std::placeholders::_1 )

这告诉bind 留下一个未绑定的参数，当您调用函数对象时必须提供该参数。

但我完全不明白你为什么使用bind，你没有绑定任何东西，f 已经是一个接受单个参数的可调用对象，你为什么不把它传递给packaged_task构造函数？

还有一个问题，就是你说你想要一个接受单个参数的任务，但是你声明了packaged_task<return_type()>，这是一个不带参数的任务。我想你想要：

auto task = std::make_shared< std::packaged_task<return_type(OCRK*)> >(std::forward<F>(f));

还有：

    tasks.emplace([task](OCRK* ocr){ task(ocr); });

这仍然会失败，因为task 是shared_ptr，所以它是不可调用的。应该是：

    tasks.emplace([task](OCRK* ocr){ (*task)(ocr); });