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

问题描述

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

所以,我有一个带有此签名的函数

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

而且,我正尝试通过以下方法将一些作业放入thread_pool中:

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,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> > > &>' 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> > > &>' 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::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::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::move( svc ) );
                          ^
/usr/include/c++/v1/tuple:1355:26: note: candidate template ignored: substitution failure [with _Fn = void (*const &)(std::__1::unique_ptr<BaseService,_Tuple = const std::__1::tuple<std::__1::unique_ptr<BaseService,_Id = <0>]
constexpr decltype(auto) __apply_tuple_impl(_Fn && __f,^
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

有人可以帮我吗,谢谢。

解决方法

首先,感谢您阅读我的博客;)

我遇到相同的错误:(看来unique_ptr转发给工作器lambda的方式无法正常工作。最简单的解决方法是改用shared_ptr,它将起作用。否则,我将不得不对此进行思考看看我是否可以提出解决方案...