Переместить упакованный_задачу в лямбду - PullRequest
Новая
       34

Переместить упакованный_задачу в лямбду

5 голосов
/ 19 декабря 2010

Я хочу переместиться и вызвать boost :: packaged_task внутри лямбды.

Однако я не могу найти элегантного решения.

например. Это не скомпилируется. 

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

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

            execution_queue_.try_push([=]
            {
                try{task();}
                catch(boost::task_already_started&){}
            });

            return std::move(future);       
        }

    int _tmain(int argc, _TCHAR* argv[])
    {
        executor ex;
        ex.begin_invoke([]{std::cout << "Hello world!";});
       //error C3848: expression having type 'const boost::packaged_task<R>' would lose some const-volatile qualifiers in order to call 'void boost::packaged_task<R>::operator ()(void)'
//          with
//          [
//              R=void
//          ]
        return 0;
    }

Мое довольно уродливое решение: 

    struct task_adaptor_t
    {
        // copy-constructor acts as move constructor
        task_adaptor_t(const task_adaptor_t& other) : task(std::move(other.task)){}
        task_adaptor_t(task_type&& task) : task(std::move(task)){}
        void operator()() const { task(); }
        mutable task_type task;
    } task_adaptor(std::move(task));

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

Каков «правильный» способ переместить упакованную задачу в лямбду, которая ее вызывает?

Ответы [ 2 ]

2 голосов
/ 20 декабря 2010

При правильной реализации std :: bind (или что-то эквивалентное в отношении типов с поддержкой перемещения) вы должны иметь возможность комбинировать bind и лямбду C ++ 0x следующим образом: 

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

execution_queue_.try_push(std::bind([](task_type const& task)
{
    try{task();}
    catch(boost::task_already_started&){}
},std::move(task)));

return future;

Кстати: вам не нужен std :: move для будущего, потому что будущее - это локальный объект.Как таковой, он уже подвержен потенциальному выбрасыванию копии, и если компилятор не может сделать это, он должен переместить конструкцию, возвращающую значение из «будущего».Явное использование std :: move в этом случае может фактически запретить копирование / перемещение.

2 голосов
/ 20 декабря 2010

Есть аналогичный вопрос, который я написал о переходе на лямбды.C ++ 0x не имеет синтаксиса захвата хода.Единственное решение, которое я мог придумать, это какой-то объект прокси-функции. 

template<typename T, typename F> class move_capture_proxy {
    T t;
    F f;
public:
    move_capture_proxy(T&& a, F&& b) 
        : t(std::move(a)), f(std::move(b)) {}
    auto operator()() -> decltype(f(std::move(b)) {
        return f(std::move(b));
    }
};
template<typename T, typename F> move_capture_proxy<T, F> make_move_proxy(T&& t, F&& f) {
    return move_capture_proxy<T, F>(std::move(t), std::move(f));
}

execution_queue.try_push(make_move_proxy(std::move(task), [](decltype(task)&& ref) {
    auto task = std::move(ref);
    // use task
});

Обратите внимание, что я на самом деле не пробовал этот код, и он стал бы намного лучше с шаблонами с переменным числом аргументов, но MSVC10У меня их нет, поэтому я не знаю о них.

...