use_future.hpp 25 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941
  1. //
  2. // impl/use_future.hpp
  3. // ~~~~~~~~~~~~~~~~~~~
  4. //
  5. // Copyright (c) 2003-2018 Christopher M. Kohlhoff (chris at kohlhoff dot com)
  6. //
  7. // Distributed under the Boost Software License, Version 1.0. (See accompanying
  8. // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
  9. //
  10. #ifndef BOOST_ASIO_IMPL_USE_FUTURE_HPP
  11. #define BOOST_ASIO_IMPL_USE_FUTURE_HPP
  12. #if defined(_MSC_VER) && (_MSC_VER >= 1200)
  13. # pragma once
  14. #endif // defined(_MSC_VER) && (_MSC_VER >= 1200)
  15. #include <boost/asio/detail/config.hpp>
  16. #include <future>
  17. #include <tuple>
  18. #include <boost/asio/async_result.hpp>
  19. #include <boost/asio/detail/memory.hpp>
  20. #include <boost/system/error_code.hpp>
  21. #include <boost/asio/packaged_task.hpp>
  22. #include <boost/system/system_error.hpp>
  23. #include <boost/asio/system_executor.hpp>
  24. #include <boost/asio/detail/push_options.hpp>
  25. namespace boost {
  26. namespace asio {
  27. namespace detail {
  28. #if defined(BOOST_ASIO_HAS_VARIADIC_TEMPLATES)
  29. template <typename T, typename F, typename... Args>
  30. inline void promise_invoke_and_set(std::promise<T>& p,
  31. F& f, BOOST_ASIO_MOVE_ARG(Args)... args)
  32. {
  33. #if !defined(BOOST_ASIO_NO_EXCEPTIONS)
  34. try
  35. #endif // !defined(BOOST_ASIO_NO_EXCEPTIONS)
  36. {
  37. p.set_value(f(BOOST_ASIO_MOVE_CAST(Args)(args)...));
  38. }
  39. #if !defined(BOOST_ASIO_NO_EXCEPTIONS)
  40. catch (...)
  41. {
  42. p.set_exception(std::current_exception());
  43. }
  44. #endif // !defined(BOOST_ASIO_NO_EXCEPTIONS)
  45. }
  46. template <typename F, typename... Args>
  47. inline void promise_invoke_and_set(std::promise<void>& p,
  48. F& f, BOOST_ASIO_MOVE_ARG(Args)... args)
  49. {
  50. #if !defined(BOOST_ASIO_NO_EXCEPTIONS)
  51. try
  52. #endif // !defined(BOOST_ASIO_NO_EXCEPTIONS)
  53. {
  54. f(BOOST_ASIO_MOVE_CAST(Args)(args)...);
  55. p.set_value();
  56. }
  57. #if !defined(BOOST_ASIO_NO_EXCEPTIONS)
  58. catch (...)
  59. {
  60. p.set_exception(std::current_exception());
  61. }
  62. #endif // !defined(BOOST_ASIO_NO_EXCEPTIONS)
  63. }
  64. #else // defined(BOOST_ASIO_HAS_VARIADIC_TEMPLATES)
  65. template <typename T, typename F>
  66. inline void promise_invoke_and_set(std::promise<T>& p, F& f)
  67. {
  68. #if !defined(BOOST_ASIO_NO_EXCEPTIONS)
  69. try
  70. #endif // !defined(BOOST_ASIO_NO_EXCEPTIONS)
  71. {
  72. p.set_value(f());
  73. }
  74. #if !defined(BOOST_ASIO_NO_EXCEPTIONS)
  75. catch (...)
  76. {
  77. p.set_exception(std::current_exception());
  78. }
  79. #endif // !defined(BOOST_ASIO_NO_EXCEPTIONS)
  80. }
  81. template <typename F, typename Args>
  82. inline void promise_invoke_and_set(std::promise<void>& p, F& f)
  83. {
  84. #if !defined(BOOST_ASIO_NO_EXCEPTIONS)
  85. try
  86. #endif // !defined(BOOST_ASIO_NO_EXCEPTIONS)
  87. {
  88. f();
  89. p.set_value();
  90. #if !defined(BOOST_ASIO_NO_EXCEPTIONS)
  91. }
  92. catch (...)
  93. {
  94. p.set_exception(std::current_exception());
  95. }
  96. #endif // !defined(BOOST_ASIO_NO_EXCEPTIONS)
  97. }
  98. #if defined(BOOST_ASIO_NO_EXCEPTIONS)
  99. #define BOOST_ASIO_PRIVATE_PROMISE_INVOKE_DEF(n) \
  100. template <typename T, typename F, BOOST_ASIO_VARIADIC_TPARAMS(n)> \
  101. inline void promise_invoke_and_set(std::promise<T>& p, \
  102. F& f, BOOST_ASIO_VARIADIC_MOVE_PARAMS(n)) \
  103. { \
  104. p.set_value(f(BOOST_ASIO_VARIADIC_MOVE_ARGS(n))); \
  105. } \
  106. \
  107. template <typename F, BOOST_ASIO_VARIADIC_TPARAMS(n)> \
  108. inline void promise_invoke_and_set(std::promise<void>& p, \
  109. F& f, BOOST_ASIO_VARIADIC_MOVE_PARAMS(n)) \
  110. { \
  111. f(BOOST_ASIO_VARIADIC_MOVE_ARGS(n)); \
  112. p.set_value(); \
  113. } \
  114. /**/
  115. BOOST_ASIO_VARIADIC_GENERATE(BOOST_ASIO_PRIVATE_PROMISE_INVOKE_DEF)
  116. #undef BOOST_ASIO_PRIVATE_PROMISE_INVOKE_DEF
  117. #else // defined(BOOST_ASIO_NO_EXCEPTIONS)
  118. #define BOOST_ASIO_PRIVATE_PROMISE_INVOKE_DEF(n) \
  119. template <typename T, typename F, BOOST_ASIO_VARIADIC_TPARAMS(n)> \
  120. inline void promise_invoke_and_set(std::promise<T>& p, \
  121. F& f, BOOST_ASIO_VARIADIC_MOVE_PARAMS(n)) \
  122. { \
  123. try \
  124. { \
  125. p.set_value(f(BOOST_ASIO_VARIADIC_MOVE_ARGS(n))); \
  126. } \
  127. catch (...) \
  128. { \
  129. p.set_exception(std::current_exception()); \
  130. } \
  131. } \
  132. \
  133. template <typename F, BOOST_ASIO_VARIADIC_TPARAMS(n)> \
  134. inline void promise_invoke_and_set(std::promise<void>& p, \
  135. F& f, BOOST_ASIO_VARIADIC_MOVE_PARAMS(n)) \
  136. { \
  137. try \
  138. { \
  139. f(BOOST_ASIO_VARIADIC_MOVE_ARGS(n)); \
  140. p.set_value(); \
  141. } \
  142. catch (...) \
  143. { \
  144. p.set_exception(std::current_exception()); \
  145. } \
  146. } \
  147. /**/
  148. BOOST_ASIO_VARIADIC_GENERATE(BOOST_ASIO_PRIVATE_PROMISE_INVOKE_DEF)
  149. #undef BOOST_ASIO_PRIVATE_PROMISE_INVOKE_DEF
  150. #endif // defined(BOOST_ASIO_NO_EXCEPTIONS)
  151. #endif // defined(BOOST_ASIO_HAS_VARIADIC_TEMPLATES)
  152. // A function object adapter to invoke a nullary function object and capture
  153. // any exception thrown into a promise.
  154. template <typename T, typename F>
  155. class promise_invoker
  156. {
  157. public:
  158. promise_invoker(const shared_ptr<std::promise<T> >& p,
  159. BOOST_ASIO_MOVE_ARG(F) f)
  160. : p_(p), f_(BOOST_ASIO_MOVE_CAST(F)(f))
  161. {
  162. }
  163. void operator()()
  164. {
  165. #if !defined(BOOST_ASIO_NO_EXCEPTIONS)
  166. try
  167. #endif // !defined(BOOST_ASIO_NO_EXCEPTIONS)
  168. {
  169. f_();
  170. }
  171. #if !defined(BOOST_ASIO_NO_EXCEPTIONS)
  172. catch (...)
  173. {
  174. p_->set_exception(std::current_exception());
  175. }
  176. #endif // !defined(BOOST_ASIO_NO_EXCEPTIONS)
  177. }
  178. private:
  179. shared_ptr<std::promise<T> > p_;
  180. typename decay<F>::type f_;
  181. };
  182. // An executor that adapts the system_executor to capture any exeption thrown
  183. // by a submitted function object and save it into a promise.
  184. template <typename T>
  185. class promise_executor
  186. {
  187. public:
  188. explicit promise_executor(const shared_ptr<std::promise<T> >& p)
  189. : p_(p)
  190. {
  191. }
  192. execution_context& context() const BOOST_ASIO_NOEXCEPT
  193. {
  194. return system_executor().context();
  195. }
  196. void on_work_started() const BOOST_ASIO_NOEXCEPT {}
  197. void on_work_finished() const BOOST_ASIO_NOEXCEPT {}
  198. template <typename F, typename A>
  199. void dispatch(BOOST_ASIO_MOVE_ARG(F) f, const A&) const
  200. {
  201. promise_invoker<T, F>(p_, BOOST_ASIO_MOVE_CAST(F)(f))();
  202. }
  203. template <typename F, typename A>
  204. void post(BOOST_ASIO_MOVE_ARG(F) f, const A& a) const
  205. {
  206. system_executor().post(
  207. promise_invoker<T, F>(p_, BOOST_ASIO_MOVE_CAST(F)(f)), a);
  208. }
  209. template <typename F, typename A>
  210. void defer(BOOST_ASIO_MOVE_ARG(F) f, const A& a) const
  211. {
  212. system_executor().defer(
  213. promise_invoker<T, F>(p_, BOOST_ASIO_MOVE_CAST(F)(f)), a);
  214. }
  215. friend bool operator==(const promise_executor& a,
  216. const promise_executor& b) BOOST_ASIO_NOEXCEPT
  217. {
  218. return a.p_ == b.p_;
  219. }
  220. friend bool operator!=(const promise_executor& a,
  221. const promise_executor& b) BOOST_ASIO_NOEXCEPT
  222. {
  223. return a.p_ != b.p_;
  224. }
  225. private:
  226. shared_ptr<std::promise<T> > p_;
  227. };
  228. // The base class for all completion handlers that create promises.
  229. template <typename T>
  230. class promise_creator
  231. {
  232. public:
  233. typedef promise_executor<T> executor_type;
  234. executor_type get_executor() const BOOST_ASIO_NOEXCEPT
  235. {
  236. return executor_type(p_);
  237. }
  238. typedef std::future<T> future_type;
  239. future_type get_future()
  240. {
  241. return p_->get_future();
  242. }
  243. protected:
  244. template <typename Allocator>
  245. void create_promise(const Allocator& a)
  246. {
  247. BOOST_ASIO_REBIND_ALLOC(Allocator, char) b(a);
  248. p_ = std::allocate_shared<std::promise<T>>(b, std::allocator_arg, b);
  249. }
  250. shared_ptr<std::promise<T> > p_;
  251. };
  252. // For completion signature void().
  253. class promise_handler_0
  254. : public promise_creator<void>
  255. {
  256. public:
  257. void operator()()
  258. {
  259. this->p_->set_value();
  260. }
  261. };
  262. // For completion signature void(error_code).
  263. class promise_handler_ec_0
  264. : public promise_creator<void>
  265. {
  266. public:
  267. void operator()(const boost::system::error_code& ec)
  268. {
  269. if (ec)
  270. {
  271. this->p_->set_exception(
  272. std::make_exception_ptr(
  273. boost::system::system_error(ec)));
  274. }
  275. else
  276. {
  277. this->p_->set_value();
  278. }
  279. }
  280. };
  281. // For completion signature void(exception_ptr).
  282. class promise_handler_ex_0
  283. : public promise_creator<void>
  284. {
  285. public:
  286. void operator()(const std::exception_ptr& ex)
  287. {
  288. if (ex)
  289. {
  290. this->p_->set_exception(ex);
  291. }
  292. else
  293. {
  294. this->p_->set_value();
  295. }
  296. }
  297. };
  298. // For completion signature void(T).
  299. template <typename T>
  300. class promise_handler_1
  301. : public promise_creator<T>
  302. {
  303. public:
  304. template <typename Arg>
  305. void operator()(BOOST_ASIO_MOVE_ARG(Arg) arg)
  306. {
  307. this->p_->set_value(BOOST_ASIO_MOVE_CAST(Arg)(arg));
  308. }
  309. };
  310. // For completion signature void(error_code, T).
  311. template <typename T>
  312. class promise_handler_ec_1
  313. : public promise_creator<T>
  314. {
  315. public:
  316. template <typename Arg>
  317. void operator()(const boost::system::error_code& ec,
  318. BOOST_ASIO_MOVE_ARG(Arg) arg)
  319. {
  320. if (ec)
  321. {
  322. this->p_->set_exception(
  323. std::make_exception_ptr(
  324. boost::system::system_error(ec)));
  325. }
  326. else
  327. this->p_->set_value(BOOST_ASIO_MOVE_CAST(Arg)(arg));
  328. }
  329. };
  330. // For completion signature void(exception_ptr, T).
  331. template <typename T>
  332. class promise_handler_ex_1
  333. : public promise_creator<T>
  334. {
  335. public:
  336. template <typename Arg>
  337. void operator()(const std::exception_ptr& ex,
  338. BOOST_ASIO_MOVE_ARG(Arg) arg)
  339. {
  340. if (ex)
  341. this->p_->set_exception(ex);
  342. else
  343. this->p_->set_value(BOOST_ASIO_MOVE_CAST(Arg)(arg));
  344. }
  345. };
  346. // For completion signature void(T1, ..., Tn);
  347. template <typename T>
  348. class promise_handler_n
  349. : public promise_creator<T>
  350. {
  351. public:
  352. #if defined(BOOST_ASIO_HAS_VARIADIC_TEMPLATES)
  353. template <typename... Args>
  354. void operator()(BOOST_ASIO_MOVE_ARG(Args)... args)
  355. {
  356. this->p_->set_value(
  357. std::forward_as_tuple(
  358. BOOST_ASIO_MOVE_CAST(Args)(args)...));
  359. }
  360. #else // defined(BOOST_ASIO_HAS_VARIADIC_TEMPLATES)
  361. #define BOOST_ASIO_PRIVATE_CALL_OP_DEF(n) \
  362. template <BOOST_ASIO_VARIADIC_TPARAMS(n)> \
  363. void operator()(BOOST_ASIO_VARIADIC_MOVE_PARAMS(n)) \
  364. {\
  365. this->p_->set_value( \
  366. std::forward_as_tuple( \
  367. BOOST_ASIO_VARIADIC_MOVE_ARGS(n))); \
  368. } \
  369. /**/
  370. BOOST_ASIO_VARIADIC_GENERATE(BOOST_ASIO_PRIVATE_CALL_OP_DEF)
  371. #undef BOOST_ASIO_PRIVATE_CALL_OP_DEF
  372. #endif // defined(BOOST_ASIO_HAS_VARIADIC_TEMPLATES)
  373. };
  374. // For completion signature void(error_code, T1, ..., Tn);
  375. template <typename T>
  376. class promise_handler_ec_n
  377. : public promise_creator<T>
  378. {
  379. public:
  380. #if defined(BOOST_ASIO_HAS_VARIADIC_TEMPLATES)
  381. template <typename... Args>
  382. void operator()(const boost::system::error_code& ec,
  383. BOOST_ASIO_MOVE_ARG(Args)... args)
  384. {
  385. if (ec)
  386. {
  387. this->p_->set_exception(
  388. std::make_exception_ptr(
  389. boost::system::system_error(ec)));
  390. }
  391. else
  392. {
  393. this->p_->set_value(
  394. std::forward_as_tuple(
  395. BOOST_ASIO_MOVE_CAST(Args)(args)...));
  396. }
  397. }
  398. #else // defined(BOOST_ASIO_HAS_VARIADIC_TEMPLATES)
  399. #define BOOST_ASIO_PRIVATE_CALL_OP_DEF(n) \
  400. template <BOOST_ASIO_VARIADIC_TPARAMS(n)> \
  401. void operator()(const boost::system::error_code& ec, \
  402. BOOST_ASIO_VARIADIC_MOVE_PARAMS(n)) \
  403. {\
  404. if (ec) \
  405. { \
  406. this->p_->set_exception( \
  407. std::make_exception_ptr( \
  408. boost::system::system_error(ec))); \
  409. } \
  410. else \
  411. { \
  412. this->p_->set_value( \
  413. std::forward_as_tuple( \
  414. BOOST_ASIO_VARIADIC_MOVE_ARGS(n))); \
  415. } \
  416. } \
  417. /**/
  418. BOOST_ASIO_VARIADIC_GENERATE(BOOST_ASIO_PRIVATE_CALL_OP_DEF)
  419. #undef BOOST_ASIO_PRIVATE_CALL_OP_DEF
  420. #endif // defined(BOOST_ASIO_HAS_VARIADIC_TEMPLATES)
  421. };
  422. // For completion signature void(exception_ptr, T1, ..., Tn);
  423. template <typename T>
  424. class promise_handler_ex_n
  425. : public promise_creator<T>
  426. {
  427. public:
  428. #if defined(BOOST_ASIO_HAS_VARIADIC_TEMPLATES)
  429. template <typename... Args>
  430. void operator()(const std::exception_ptr& ex,
  431. BOOST_ASIO_MOVE_ARG(Args)... args)
  432. {
  433. if (ex)
  434. this->p_->set_exception(ex);
  435. else
  436. {
  437. this->p_->set_value(
  438. std::forward_as_tuple(
  439. BOOST_ASIO_MOVE_CAST(Args)(args)...));
  440. }
  441. }
  442. #else // defined(BOOST_ASIO_HAS_VARIADIC_TEMPLATES)
  443. #define BOOST_ASIO_PRIVATE_CALL_OP_DEF(n) \
  444. template <BOOST_ASIO_VARIADIC_TPARAMS(n)> \
  445. void operator()(const std::exception_ptr& ex, \
  446. BOOST_ASIO_VARIADIC_MOVE_PARAMS(n)) \
  447. {\
  448. if (ex) \
  449. this->p_->set_exception(ex); \
  450. else \
  451. { \
  452. this->p_->set_value( \
  453. std::forward_as_tuple( \
  454. BOOST_ASIO_VARIADIC_MOVE_ARGS(n))); \
  455. } \
  456. } \
  457. /**/
  458. BOOST_ASIO_VARIADIC_GENERATE(BOOST_ASIO_PRIVATE_CALL_OP_DEF)
  459. #undef BOOST_ASIO_PRIVATE_CALL_OP_DEF
  460. #endif // defined(BOOST_ASIO_HAS_VARIADIC_TEMPLATES)
  461. };
  462. // Helper template to choose the appropriate concrete promise handler
  463. // implementation based on the supplied completion signature.
  464. template <typename> class promise_handler_selector;
  465. template <>
  466. class promise_handler_selector<void()>
  467. : public promise_handler_0 {};
  468. template <>
  469. class promise_handler_selector<void(boost::system::error_code)>
  470. : public promise_handler_ec_0 {};
  471. template <>
  472. class promise_handler_selector<void(std::exception_ptr)>
  473. : public promise_handler_ex_0 {};
  474. template <typename Arg>
  475. class promise_handler_selector<void(Arg)>
  476. : public promise_handler_1<Arg> {};
  477. template <typename Arg>
  478. class promise_handler_selector<void(boost::system::error_code, Arg)>
  479. : public promise_handler_ec_1<Arg> {};
  480. template <typename Arg>
  481. class promise_handler_selector<void(std::exception_ptr, Arg)>
  482. : public promise_handler_ex_1<Arg> {};
  483. #if defined(BOOST_ASIO_HAS_VARIADIC_TEMPLATES)
  484. template <typename... Arg>
  485. class promise_handler_selector<void(Arg...)>
  486. : public promise_handler_n<std::tuple<Arg...> > {};
  487. template <typename... Arg>
  488. class promise_handler_selector<void(boost::system::error_code, Arg...)>
  489. : public promise_handler_ec_n<std::tuple<Arg...> > {};
  490. template <typename... Arg>
  491. class promise_handler_selector<void(std::exception_ptr, Arg...)>
  492. : public promise_handler_ex_n<std::tuple<Arg...> > {};
  493. #else // defined(BOOST_ASIO_HAS_VARIADIC_TEMPLATES)
  494. #define BOOST_ASIO_PRIVATE_PROMISE_SELECTOR_DEF(n) \
  495. template <typename Arg, BOOST_ASIO_VARIADIC_TPARAMS(n)> \
  496. class promise_handler_selector< \
  497. void(Arg, BOOST_ASIO_VARIADIC_TARGS(n))> \
  498. : public promise_handler_n< \
  499. std::tuple<Arg, BOOST_ASIO_VARIADIC_TARGS(n)> > {}; \
  500. \
  501. template <typename Arg, BOOST_ASIO_VARIADIC_TPARAMS(n)> \
  502. class promise_handler_selector< \
  503. void(boost::system::error_code, Arg, BOOST_ASIO_VARIADIC_TARGS(n))> \
  504. : public promise_handler_ec_n< \
  505. std::tuple<Arg, BOOST_ASIO_VARIADIC_TARGS(n)> > {}; \
  506. \
  507. template <typename Arg, BOOST_ASIO_VARIADIC_TPARAMS(n)> \
  508. class promise_handler_selector< \
  509. void(std::exception_ptr, Arg, BOOST_ASIO_VARIADIC_TARGS(n))> \
  510. : public promise_handler_ex_n< \
  511. std::tuple<Arg, BOOST_ASIO_VARIADIC_TARGS(n)> > {}; \
  512. /**/
  513. BOOST_ASIO_VARIADIC_GENERATE(BOOST_ASIO_PRIVATE_PROMISE_SELECTOR_DEF)
  514. #undef BOOST_ASIO_PRIVATE_PROMISE_SELECTOR_DEF
  515. #endif // defined(BOOST_ASIO_HAS_VARIADIC_TEMPLATES)
  516. // Completion handlers produced from the use_future completion token, when not
  517. // using use_future::operator().
  518. template <typename Signature, typename Allocator>
  519. class promise_handler
  520. : public promise_handler_selector<Signature>
  521. {
  522. public:
  523. typedef Allocator allocator_type;
  524. typedef void result_type;
  525. promise_handler(use_future_t<Allocator> u)
  526. : allocator_(u.get_allocator())
  527. {
  528. this->create_promise(allocator_);
  529. }
  530. allocator_type get_allocator() const BOOST_ASIO_NOEXCEPT
  531. {
  532. return allocator_;
  533. }
  534. private:
  535. Allocator allocator_;
  536. };
  537. template <typename Function, typename Signature, typename Allocator>
  538. inline void asio_handler_invoke(Function& f,
  539. promise_handler<Signature, Allocator>* h)
  540. {
  541. typename promise_handler<Signature, Allocator>::executor_type
  542. ex(h->get_executor());
  543. ex.dispatch(BOOST_ASIO_MOVE_CAST(Function)(f), std::allocator<void>());
  544. }
  545. template <typename Function, typename Signature, typename Allocator>
  546. inline void asio_handler_invoke(const Function& f,
  547. promise_handler<Signature, Allocator>* h)
  548. {
  549. typename promise_handler<Signature, Allocator>::executor_type
  550. ex(h->get_executor());
  551. ex.dispatch(f, std::allocator<void>());
  552. }
  553. // Helper base class for async_result specialisation.
  554. template <typename Signature, typename Allocator>
  555. class promise_async_result
  556. {
  557. public:
  558. typedef promise_handler<Signature, Allocator> completion_handler_type;
  559. typedef typename completion_handler_type::future_type return_type;
  560. explicit promise_async_result(completion_handler_type& h)
  561. : future_(h.get_future())
  562. {
  563. }
  564. return_type get()
  565. {
  566. return BOOST_ASIO_MOVE_CAST(return_type)(future_);
  567. }
  568. private:
  569. return_type future_;
  570. };
  571. // Return value from use_future::operator().
  572. template <typename Function, typename Allocator>
  573. class packaged_token
  574. {
  575. public:
  576. packaged_token(Function f, const Allocator& a)
  577. : function_(BOOST_ASIO_MOVE_CAST(Function)(f)),
  578. allocator_(a)
  579. {
  580. }
  581. //private:
  582. Function function_;
  583. Allocator allocator_;
  584. };
  585. // Completion handlers produced from the use_future completion token, when
  586. // using use_future::operator().
  587. template <typename Function, typename Allocator, typename Result>
  588. class packaged_handler
  589. : public promise_creator<Result>
  590. {
  591. public:
  592. typedef Allocator allocator_type;
  593. typedef void result_type;
  594. packaged_handler(packaged_token<Function, Allocator> t)
  595. : function_(BOOST_ASIO_MOVE_CAST(Function)(t.function_)),
  596. allocator_(t.allocator_)
  597. {
  598. this->create_promise(allocator_);
  599. }
  600. allocator_type get_allocator() const BOOST_ASIO_NOEXCEPT
  601. {
  602. return allocator_;
  603. }
  604. #if defined(BOOST_ASIO_HAS_VARIADIC_TEMPLATES)
  605. template <typename... Args>
  606. void operator()(BOOST_ASIO_MOVE_ARG(Args)... args)
  607. {
  608. (promise_invoke_and_set)(*this->p_,
  609. function_, BOOST_ASIO_MOVE_CAST(Args)(args)...);
  610. }
  611. #else // defined(BOOST_ASIO_HAS_VARIADIC_TEMPLATES)
  612. void operator()()
  613. {
  614. (promise_invoke_and_set)(*this->p_, function_);
  615. }
  616. #define BOOST_ASIO_PRIVATE_CALL_OP_DEF(n) \
  617. template <BOOST_ASIO_VARIADIC_TPARAMS(n)> \
  618. void operator()(BOOST_ASIO_VARIADIC_MOVE_PARAMS(n)) \
  619. {\
  620. (promise_invoke_and_set)(*this->p_, \
  621. function_, BOOST_ASIO_VARIADIC_MOVE_ARGS(n)); \
  622. } \
  623. /**/
  624. BOOST_ASIO_VARIADIC_GENERATE(BOOST_ASIO_PRIVATE_CALL_OP_DEF)
  625. #undef BOOST_ASIO_PRIVATE_CALL_OP_DEF
  626. #endif // defined(BOOST_ASIO_HAS_VARIADIC_TEMPLATES)
  627. private:
  628. Function function_;
  629. Allocator allocator_;
  630. };
  631. template <typename Function,
  632. typename Function1, typename Allocator, typename Result>
  633. inline void asio_handler_invoke(Function& f,
  634. packaged_handler<Function1, Allocator, Result>* h)
  635. {
  636. typename packaged_handler<Function1, Allocator, Result>::executor_type
  637. ex(h->get_executor());
  638. ex.dispatch(BOOST_ASIO_MOVE_CAST(Function)(f), std::allocator<void>());
  639. }
  640. template <typename Function,
  641. typename Function1, typename Allocator, typename Result>
  642. inline void asio_handler_invoke(const Function& f,
  643. packaged_handler<Function1, Allocator, Result>* h)
  644. {
  645. typename packaged_handler<Function1, Allocator, Result>::executor_type
  646. ex(h->get_executor());
  647. ex.dispatch(f, std::allocator<void>());
  648. }
  649. // Helper base class for async_result specialisation.
  650. template <typename Function, typename Allocator, typename Result>
  651. class packaged_async_result
  652. {
  653. public:
  654. typedef packaged_handler<Function, Allocator, Result> completion_handler_type;
  655. typedef typename completion_handler_type::future_type return_type;
  656. explicit packaged_async_result(completion_handler_type& h)
  657. : future_(h.get_future())
  658. {
  659. }
  660. return_type get()
  661. {
  662. return BOOST_ASIO_MOVE_CAST(return_type)(future_);
  663. }
  664. private:
  665. return_type future_;
  666. };
  667. } // namespace detail
  668. template <typename Allocator> template <typename Function>
  669. inline detail::packaged_token<typename decay<Function>::type, Allocator>
  670. use_future_t<Allocator>::operator()(BOOST_ASIO_MOVE_ARG(Function) f) const
  671. {
  672. return detail::packaged_token<typename decay<Function>::type, Allocator>(
  673. BOOST_ASIO_MOVE_CAST(Function)(f), allocator_);
  674. }
  675. #if !defined(GENERATING_DOCUMENTATION)
  676. #if defined(BOOST_ASIO_HAS_VARIADIC_TEMPLATES)
  677. template <typename Allocator, typename Result, typename... Args>
  678. class async_result<use_future_t<Allocator>, Result(Args...)>
  679. : public detail::promise_async_result<
  680. void(typename decay<Args>::type...), Allocator>
  681. {
  682. public:
  683. explicit async_result(
  684. typename detail::promise_async_result<void(typename decay<Args>::type...),
  685. Allocator>::completion_handler_type& h)
  686. : detail::promise_async_result<
  687. void(typename decay<Args>::type...), Allocator>(h)
  688. {
  689. }
  690. };
  691. template <typename Function, typename Allocator,
  692. typename Result, typename... Args>
  693. class async_result<detail::packaged_token<Function, Allocator>, Result(Args...)>
  694. : public detail::packaged_async_result<Function, Allocator,
  695. typename result_of<Function(Args...)>::type>
  696. {
  697. public:
  698. explicit async_result(
  699. typename detail::packaged_async_result<Function, Allocator,
  700. typename result_of<Function(Args...)>::type>::completion_handler_type& h)
  701. : detail::packaged_async_result<Function, Allocator,
  702. typename result_of<Function(Args...)>::type>(h)
  703. {
  704. }
  705. };
  706. #else // defined(BOOST_ASIO_HAS_VARIADIC_TEMPLATES)
  707. template <typename Allocator, typename Result>
  708. class async_result<use_future_t<Allocator>, Result()>
  709. : public detail::promise_async_result<void(), Allocator>
  710. {
  711. public:
  712. explicit async_result(
  713. typename detail::promise_async_result<
  714. void(), Allocator>::completion_handler_type& h)
  715. : detail::promise_async_result<void(), Allocator>(h)
  716. {
  717. }
  718. };
  719. template <typename Function, typename Allocator, typename Result>
  720. class async_result<detail::packaged_token<Function, Allocator>, Result()>
  721. : public detail::packaged_async_result<Function, Allocator,
  722. typename result_of<Function()>::type>
  723. {
  724. public:
  725. explicit async_result(
  726. typename detail::packaged_async_result<Function, Allocator,
  727. typename result_of<Function()>::type>::completion_handler_type& h)
  728. : detail::packaged_async_result<Function, Allocator,
  729. typename result_of<Function()>::type>(h)
  730. {
  731. }
  732. };
  733. #define BOOST_ASIO_PRIVATE_ASYNC_RESULT_DEF(n) \
  734. template <typename Allocator, \
  735. typename Result, BOOST_ASIO_VARIADIC_TPARAMS(n)> \
  736. class async_result<use_future_t<Allocator>, \
  737. Result(BOOST_ASIO_VARIADIC_TARGS(n))> \
  738. : public detail::promise_async_result< \
  739. void(BOOST_ASIO_VARIADIC_DECAY(n)), Allocator> \
  740. { \
  741. public: \
  742. explicit async_result( \
  743. typename detail::promise_async_result< \
  744. void(BOOST_ASIO_VARIADIC_DECAY(n)), \
  745. Allocator>::completion_handler_type& h) \
  746. : detail::promise_async_result< \
  747. void(BOOST_ASIO_VARIADIC_DECAY(n)), Allocator>(h) \
  748. { \
  749. } \
  750. }; \
  751. \
  752. template <typename Function, typename Allocator, \
  753. typename Result, BOOST_ASIO_VARIADIC_TPARAMS(n)> \
  754. class async_result<detail::packaged_token<Function, Allocator>, \
  755. Result(BOOST_ASIO_VARIADIC_TARGS(n))> \
  756. : public detail::packaged_async_result<Function, Allocator, \
  757. typename result_of<Function(BOOST_ASIO_VARIADIC_TARGS(n))>::type> \
  758. { \
  759. public: \
  760. explicit async_result( \
  761. typename detail::packaged_async_result<Function, Allocator, \
  762. typename result_of<Function(BOOST_ASIO_VARIADIC_TARGS(n))>::type \
  763. >::completion_handler_type& h) \
  764. : detail::packaged_async_result<Function, Allocator, \
  765. typename result_of<Function(BOOST_ASIO_VARIADIC_TARGS(n))>::type>(h) \
  766. { \
  767. } \
  768. }; \
  769. /**/
  770. BOOST_ASIO_VARIADIC_GENERATE(BOOST_ASIO_PRIVATE_ASYNC_RESULT_DEF)
  771. #undef BOOST_ASIO_PRIVATE_ASYNC_RESULT_DEF
  772. #endif // defined(BOOST_ASIO_HAS_VARIADIC_TEMPLATES)
  773. #if !defined(BOOST_ASIO_NO_DEPRECATED)
  774. template <typename Allocator, typename Signature>
  775. struct handler_type<use_future_t<Allocator>, Signature>
  776. {
  777. typedef typename async_result<use_future_t<Allocator>,
  778. Signature>::completion_handler_type type;
  779. };
  780. template <typename Signature, typename Allocator>
  781. class async_result<detail::promise_handler<Signature, Allocator> >
  782. : public detail::promise_async_result<Signature, Allocator>
  783. {
  784. public:
  785. typedef typename detail::promise_async_result<
  786. Signature, Allocator>::return_type type;
  787. explicit async_result(
  788. typename detail::promise_async_result<
  789. Signature, Allocator>::completion_handler_type& h)
  790. : detail::promise_async_result<Signature, Allocator>(h)
  791. {
  792. }
  793. };
  794. template <typename Function, typename Allocator, typename Signature>
  795. struct handler_type<detail::packaged_token<Function, Allocator>, Signature>
  796. {
  797. typedef typename async_result<detail::packaged_token<Function, Allocator>,
  798. Signature>::completion_handler_type type;
  799. };
  800. template <typename Function, typename Allocator, typename Result>
  801. class async_result<detail::packaged_handler<Function, Allocator, Result> >
  802. : public detail::packaged_async_result<Function, Allocator, Result>
  803. {
  804. public:
  805. typedef typename detail::packaged_async_result<
  806. Function, Allocator, Result>::return_type type;
  807. explicit async_result(
  808. typename detail::packaged_async_result<
  809. Function, Allocator, Result>::completion_handler_type& h)
  810. : detail::packaged_async_result<Function, Allocator, Result>(h)
  811. {
  812. }
  813. };
  814. #endif // !defined(BOOST_ASIO_NO_DEPRECATED)
  815. #endif // !defined(GENERATING_DOCUMENTATION)
  816. } // namespace asio
  817. } // namespace boost
  818. #include <boost/asio/detail/pop_options.hpp>
  819. #endif // BOOST_ASIO_IMPL_USE_FUTURE_HPP