3

我正在开发一个需要在线程池中运行许多作业的 C++ 项目。这些作业容易失败，这意味着我需要知道每个作业在完成后是如何终止的。大多数情况下，作为一名 Java 程序员，我喜欢使用“futures”或类似范例的想法，类似于 Java 的 util.concurrent 包中的各种类。

我有两个问题：首先，C++ 是否已经存在类似的东西（我在 Boost 中没有找到任何东西，但也许我还不够努力）；其次，这对 C++ 来说是不是一个理智的想法？

我在这里找到了我要完成的工作的一个简短示例：

http://www.boostcookbook.com/Recipe:/1234841

这种方法有意义吗？

4

3 回答 3

5

Boost 已经实现了期货和其他线程工具。

请注意，当您get()在 a 上调​​用该方法时boost::unique_future，它将重新引发异步执行期间可能已存储在其中的任何异常。

我建议您执行以下操作：

#pragma once

#include <tbb/concurrent_queue.h>

#include <boost/thread.hpp>
#include <boost/noncopyable.hpp>

#include <functional>

namespace internal
{
    template<typename T>
    struct move_on_copy
    {
        move_on_copy(const move_on_copy<T>& other) : value(std::move(other.value)){}
        move_on_copy(T&& value) : value(std::move(value)){}
        mutable T value;
    };

    template<typename T>
    move_on_copy<T> make_move_on_copy(T&& value)
    {
        return move_on_copy<T>(std::move(value));
    }
}

class executor : boost::noncopyable
{
    boost::thread thread_;

    tbb::concurrent_bounded_queue<std::function<void()>> execution_queue_;

    template<typename Func>
    auto create_task(Func&& func) -> boost::packaged_task<decltype(func())> // noexcept
    {   
        typedef boost::packaged_task<decltype(func())> task_type;

        auto task = task_type(std::forward<Func>(func));            

        task.set_wait_callback(std::function<void(task_type&)>([=](task_type& my_task) // The std::function wrapper is required in order to add ::result_type to functor class.
        {
            try
            {
                if(boost::this_thread::get_id() == thread_.get_id())  // Avoids potential deadlock.
                    my_task();
            }
            catch(boost::task_already_started&){}
        }));

        return std::move(task);
    }

public:

    explicit executor() // noexcept
    {
        thread_ = boost::thread([this]{run();});
    }

    ~executor() // noexcept
    {   
        execution_queue_.push(nullptr); // Wake the execution thread.
        thread_.join();
    }

    template<typename Func>
    auto begin_invoke(Func&& func) -> boost::unique_future<decltype(func())> // noexcept
    {   
        // Create a move on copy adaptor to avoid copying the functor into the queue, tbb::concurrent_queue does not support move semantics.
        auto task_adaptor = internal::make_move_on_copy(create_task(func));

        auto future = task_adaptor.value.get_future();

        execution_queue_.push([=]
        {
            try{task_adaptor.value();}
            catch(boost::task_already_started&){}
        });

        return std::move(future);       
    }

    template<typename Func>
    auto invoke(Func&& func) -> decltype(func()) // noexcept
    {
        if(boost::this_thread::get_id() == thread_.get_id())  // Avoids potential deadlock.
            return func();

        return begin_invoke(std::forward<Func>(func), prioriy).get();
    }

private:

    void run() // noexcept
    {
        while(true)
        {
            std::function<void()> func;
            execution_queue_.pop(func); 
                    if(!func)
                       break;
            func();
        }
    }   
};
于 2011-06-03T18:16:21.453 回答
5

Futures 既存在于即将到来的标准（C++0x）中，也存在于 boost 中。请注意，虽然主名称future相同，但您需要阅读文档以找到其他类型并了解语义。我不知道 Java 的未来，所以我不能告诉你它们有什么不同，如果有的话。

boost 中的库是由Anthony Williams编写的，我相信他也参与了该部分标准的定义。他还编写了 C++ Concurrency in Action，其中包括对期货、任务、承诺和相关对象的良好描述。如果您有兴趣，他的公司还出售 C++0x 线程库的完整实现。

于 2011-06-03T18:41:15.963 回答
-1

C++ 模板比 Java 泛型限制更少，因此“Future”可以很容易地与它们和线程同步原语一起移植。至于支持这种机制的现有库，希望其他人知道。

于 2011-06-03T18:15:43.403 回答