C++ packaged_task зависает в параллельной оболочке

Question

Я реализую параллельную оболочку, представленную Хербом Саттером, представленным в его докладе "C++ и после 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;
    }
};

По сути, идея заключается в том, чтобы обернуть объект и обеспечить потокобезопасный доступ в порядке 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(), иначе ваша программа остановится, поскольку будущее никогда не станет готовым". Это правда? Если да, как я могу решить эту проблему?

Я компилировал код используя -std=c++1z -pthread с G++ 6.1