调用“enqueue_work”时出现问题 - vorbrodt thread_pool

Question

我正在尝试在我的代码中使用 vorbrodt 的线程池实现： https://vorbrodt.blog/2019/02/27/advanced-thread-pool/

所以，我有一个带有这个签名的函数：

static void InvokeJob( std::unique_ptr<BaseService> svc );

而且，我正在尝试通过以下方式将线程池中的一些作业排入队列：

pApp->pThreadPool->enqueue_work( App::InvokeJob, std::move( svc ) );

但是编译会失败：

In file included from /home/user1/testprj/project1/app/App.cpp:5:
In file included from /home/user1/testprj/project1/app/App.h:9:
In file included from /home/user1/testprj/project1/app/def.h:9:
In file included from /usr/include/c++/v1/iostream:38:
In file included from /usr/include/c++/v1/ios:216:
In file included from /usr/include/c++/v1/__locale:15:
In file included from /usr/include/c++/v1/string:505:
In file included from /usr/include/c++/v1/string_view:176:
In file included from /usr/include/c++/v1/__string:57:
In file included from /usr/include/c++/v1/algorithm:644:
In file included from /usr/include/c++/v1/memory:663:
/usr/include/c++/v1/tuple:1358:5: error: attempt to use a deleted function
    _VSTD::__invoke_constexpr(
    ^
/usr/include/c++/v1/__config:816:15: note: expanded from macro '_VSTD'
#define _VSTD std::_LIBCPP_ABI_NAMESPACE
              ^
/usr/include/c++/v1/tuple:1355:26: note: in instantiation of exception specification for '__apply_tuple_impl<void (*const &)(std::__1::unique_ptr<BaseService, std::__1::default_delete<BaseService> >), const std::__1::tuple<std::__1::unique_ptr<BaseService, std::__1::default_delete<BaseService> > > &, 0>' requested here
constexpr decltype(auto) __apply_tuple_impl(_Fn && __f, _Tuple && __t,
                         ^
/usr/include/c++/v1/tuple:1367:12: note: in instantiation of function template specialization 'std::__1::__apply_tuple_impl<void (*const &)(std::__1::unique_ptr<BaseService, std::__1::default_delete<BaseService> >), const std::__1::tuple<std::__1::unique_ptr<BaseService, std::__1::default_delete<BaseService> > > &, 0>' requested here
    _VSTD::__apply_tuple_impl(
           ^
/usr/include/c++/v1/tuple:1365:26: note: in instantiation of exception specification for 'apply<void (*const &)(std::__1::unique_ptr<BaseService, std::__1::default_delete<BaseService> >), const std::__1::tuple<std::__1::unique_ptr<BaseService, std::__1::default_delete<BaseService> > > &>' requested here
constexpr decltype(auto) apply(_Fn && __f, _Tuple && __t)
                         ^
/home/user1/testprj/project1/app/include/vorbrodt/pool.hpp:112:99: note: in instantiation of function template specialization 'std::__1::apply<void (*const &)(std::__1::unique_ptr<BaseService, std::__1::default_delete<BaseService> >), const std::__1::tuple<std::__1::unique_ptr<BaseService, std::__1::default_delete<BaseService> > > &>' requested here
                auto work = [p = std::forward<F>(f), t = std::make_tuple(std::forward<Args>(args)...)]() { std::apply(p, t); };
                                                                                                                ^
/home/user1/testprj/project1/app/App.cpp:221:27: note: in instantiation of function template specialization 'thread_pool::enqueue_work<void (&)(std::__1::unique_ptr<BaseService, std::__1::default_delete<BaseService> >), std::__1::unique_ptr<BaseService, std::__1::default_delete<BaseService> > >' requested here
    pApp->pThreadPool->enqueue_work( App::InvokeJob, std::move( svc ) );
                          ^
/usr/include/c++/v1/type_traits:1678:5: note: '~__nat' has been explicitly marked deleted here
    ~__nat() = delete;
    ^
In file included from /home/user1/testprj/project1/app/App.cpp:5:
In file included from /home/user1/testprj/project1/app/App.h:9:
In file included from /home/user1/testprj/project1/app/def.h:9:
In file included from /usr/include/c++/v1/iostream:38:
In file included from /usr/include/c++/v1/ios:216:
In file included from /usr/include/c++/v1/__locale:15:
In file included from /usr/include/c++/v1/string:505:
In file included from /usr/include/c++/v1/string_view:176:
In file included from /usr/include/c++/v1/__string:57:
In file included from /usr/include/c++/v1/algorithm:644:
In file included from /usr/include/c++/v1/memory:663:
/usr/include/c++/v1/tuple:1358:5: error: attempt to use a deleted function
    _VSTD::__invoke_constexpr(
    ^
/usr/include/c++/v1/__config:816:15: note: expanded from macro '_VSTD'
#define _VSTD std::_LIBCPP_ABI_NAMESPACE
              ^
/usr/include/c++/v1/tuple:1367:12: note: in instantiation of function template specialization 'std::__1::__apply_tuple_impl<void (*const &)(std::__1::unique_ptr<BaseService, std::__1::default_delete<BaseService> >), const std::__1::tuple<std::__1::unique_ptr<BaseService, std::__1::default_delete<BaseService> > > &, 0>' requested here
    _VSTD::__apply_tuple_impl(
           ^
/usr/include/c++/v1/tuple:1365:26: note: in instantiation of exception specification for 'apply<void (*const &)(std::__1::unique_ptr<BaseService, std::__1::default_delete<BaseService> >), const std::__1::tuple<std::__1::unique_ptr<BaseService, std::__1::default_delete<BaseService> > > &>' requested here
constexpr decltype(auto) apply(_Fn && __f, _Tuple && __t)
                         ^
/home/user1/testprj/project1/app/include/vorbrodt/pool.hpp:112:99: note: in instantiation of function template specialization 'std::__1::apply<void (*const &)(std::__1::unique_ptr<BaseService, std::__1::default_delete<BaseService> >), const std::__1::tuple<std::__1::unique_ptr<BaseService, std::__1::default_delete<BaseService> > > &>' requested here
                auto work = [p = std::forward<F>(f), t = std::make_tuple(std::forward<Args>(args)...)]() { std::apply(p, t); };
                                                                                                                ^
/home/user1/testprj/project1/app/App.cpp:221:27: note: in instantiation of function template specialization 'thread_pool::enqueue_work<void (&)(std::__1::unique_ptr<BaseService, std::__1::default_delete<BaseService> >), std::__1::unique_ptr<BaseService, std::__1::default_delete<BaseService> > >' requested here
    pApp->pThreadPool->enqueue_work( App::InvokeJob, std::move( svc ) );
                          ^
/usr/include/c++/v1/type_traits:1678:5: note: '~__nat' has been explicitly marked deleted here
    ~__nat() = delete;
    ^
In file included from /home/user1/testprj/project1/app/App.cpp:5:
In file included from /home/user1/testprj/project1/app/App.h:9:
In file included from /home/user1/testprj/project1/app/def.h:9:
In file included from /usr/include/c++/v1/iostream:38:
In file included from /usr/include/c++/v1/ios:216:
In file included from /usr/include/c++/v1/__locale:15:
In file included from /usr/include/c++/v1/string:505:
In file included from /usr/include/c++/v1/string_view:176:
In file included from /usr/include/c++/v1/__string:57:
In file included from /usr/include/c++/v1/algorithm:644:
In file included from /usr/include/c++/v1/memory:663:
/usr/include/c++/v1/tuple:1367:5: error: no matching function for call to '__apply_tuple_impl'
    _VSTD::__apply_tuple_impl(
    ^~~~~~~~~~~~~~~~~~~~~~~~~~
/usr/include/c++/v1/__config:816:15: note: expanded from macro '_VSTD'
#define _VSTD std::_LIBCPP_ABI_NAMESPACE
              ^
/usr/include/c++/v1/tuple:1351:79: note: expanded from macro '_LIBCPP_NOEXCEPT_RETURN'
#define _LIBCPP_NOEXCEPT_RETURN(...) noexcept(noexcept(__VA_ARGS__)) { return __VA_ARGS__; }
                                                                              ^~~~~~~~~~~
/home/user1/testprj/project1/app/include/vorbrodt/pool.hpp:112:99: note: in instantiation of function template specialization 'std::__1::apply<void (*const &)(std::__1::unique_ptr<BaseService, std::__1::default_delete<BaseService> >), const std::__1::tuple<std::__1::unique_ptr<BaseService, std::__1::default_delete<BaseService> > > &>' requested here
                auto work = [p = std::forward<F>(f), t = std::make_tuple(std::forward<Args>(args)...)]() { std::apply(p, t); };
                                                                                                                ^
/home/user1/testprj/project1/app/App.cpp:221:27: note: in instantiation of function template specialization 'thread_pool::enqueue_work<void (&)(std::__1::unique_ptr<BaseService, std::__1::default_delete<BaseService> >), std::__1::unique_ptr<BaseService, std::__1::default_delete<BaseService> > >' requested here
    pApp->pThreadPool->enqueue_work( App::InvokeJob, std::move( svc ) );
                          ^
/usr/include/c++/v1/tuple:1355:26: note: candidate template ignored: substitution failure [with _Fn = void (*const &)(std::__1::unique_ptr<BaseService, std::__1::default_delete<BaseService> >), _Tuple = const std::__1::tuple<std::__1::unique_ptr<BaseService, std::__1::default_delete<BaseService> > > &, _Id = <0>]
constexpr decltype(auto) __apply_tuple_impl(_Fn && __f, _Tuple && __t,
                         ^
3 errors generated.
gmake[3]: *** [CMakeFiles/app_ocs.dir/build.make:107: CMakeFiles/app_ocs.dir/App.cpp.o] Error 1
gmake[3]: *** Waiting for unfinished jobs....
gmake[2]: *** [CMakeFiles/Makefile2:96: CMakeFiles/app_ocs.dir/all] Error 2
gmake[1]: *** [CMakeFiles/Makefile2:103: CMakeFiles/app_ocs.dir/rule] Error 2
gmake: *** [Makefile:138: app_ocs] Error 2

谁能帮帮我，谢谢。

Answer 1

首先，感谢您阅读我的博客；）

我得到同样的错误 :( 看起来 unique_ptr 被转发给 worker lambda 的方式并没有像它应该的那样工作。最简单的解决方法是使用 shared_ptr 代替，这会起作用。否则我将不得不考虑它看看我能不能想出一个解决办法...