0

我正在实现 Herb Sutter 在他的演讲“C++ and Beyond 2012”中介绍的并发包装器。

template <typename T>
class ConcurrentWrapper {

  private:

    std::deque<std::unique_ptr<std::function<void()>>> _tasks;
    std::mutex _mutex;
    std::condition_variable _cond;

    T _object;
    std::thread _worker;
    std::atomic<bool> _done {false};

  public:

    template <typename... ArgsT>
    ConcurrentWrapper(ArgsT&&... args) :
      _object {std::forward<ArgsT>(args)...},
      _worker {
        [&]() {
          typename decltype(_tasks)::value_type task;
          while(!_done) {
            { 
              std::unique_lock<std::mutex> lock(_mutex);
              while(_tasks.empty()) {
                _cond.wait(lock);
              }
              task = std::move(_tasks.front());
              _tasks.pop_front();
            } 
            (*task)();
          }
        }
      } {
    }

    ~ConcurrentWrapper() {

      {
        std::unique_lock<std::mutex> lock(_mutex);
        _tasks.push_back(std::make_unique<std::function<void()>>(
          [&](){_done = true;}
        ));
      }
      _cond.notify_one();
      _worker.join();           
    }

    template <typename F, typename R = std::result_of_t<F(T&)>>
    std::future<R> operator()(F&& f) {

      std::packaged_task<R(T&)> task(std::forward<F>(f)); 
      auto fu = task.get_future();

      {
        std::unique_lock<std::mutex> lock(_mutex);
        _tasks.push_back(std::make_unique<std::function<void()>>(
          [this, task=MoveOnCopy<decltype(task)>(std::move(task))]() { 
            task.object(this->_object); 
          }
        ));
      }
      _cond.notify_one();

      return fu;
    }
};

基本上，这个想法是包装一个对象并使用 operation 以 FIFO 顺序提供线程安全访问()。但是，在某些运行中（并不总是发生），以下程序挂起：

ConcurrentWrapper<std::vector<int>> results;

results(
  [&](std::vector<T>& data) {
    std::cout << "sorting...\n";
    std::sort(data.begin(), data.end());
    std::cout << "done ...\n";
    EXPECT_EQ(data, golden);
  }   
).get();

但是，程序可以在没有显式调用get()方法的情况下正常工作。

results(
  [&](std::vector<T>& data) {
    std::cout << "sorting...\n";
    std::sort(data.begin(), data.end());
    std::cout << "done ...\n";
    EXPECT_EQ(data, golden);
  }    
);    // Function correctly without calling get

可能是什么问题？我执行错了吗？我注意到这里有一个帖子说“在调用 f.get() 之前需要调用 packaged_task，否则你的程序将冻结，因为未来永远不会准备好。” 这是真的？如果是，我怎样才能解决这个问题？

-std=c++1z -pthread我正在使用with编译代码G++ 6.1

4

0 回答 0