C++ åèæå
- C++11
- C++14
- C++17
- C++20
- C++ ç¼è¯å¨æ¯ææ åµè¡¨
- ç¬ç«ä¸å®¿ä¸»å®ç°
- C++ è¯è¨
- C++ å ³é®è¯
- é¢å¤çå¨
- C++ æ ååºå¤´æä»¶
- å ·åè¦æ±
- åè½ç¹æ§æµè¯ (C++20)
- å·¥å ·åº
- ç±»åæ¯æï¼åºæ¬ç±»åãRTTIãç±»åç¹æ§ï¼
- æ¦å¿µåº (C++20)
- é误å¤ç
- 卿å å管ç
- æ¥æåæ¶é´å·¥å ·
- å符串åº
- 容å¨åº
- è¿ä»£å¨åº
- èå´åº (C++20)
- ç®æ³åº
- æ°å¼åº
- è¾å ¥/è¾åºåº
- æä»¶ç³»ç»åº
- æ¬å°ååº
- æ£å表达å¼åº
- ååæä½åº
- çº¿ç¨æ¯æåº
- std::thread
- std::stop_token
- std::stop_source
- std::stop_callback
- std::this_thread::get_id
- std::shared_timed_mutex
- std::shared_lock
- std::lock_guard
- std::hardware_destructive_interference_size, std::hardware_constructive_interference_size
- std::counting_semaphore, std::binary_semaphore
- std::jthread
- cpp/thread/barrier
- std::future
- std::this_thread::yield
- std::this_thread::sleep_for
- std::this_thread::sleep_until
- std::mutex
- std::recursive_mutex
- std::shared_mutex
- std::timed_mutex
- std::recursive_timed_mutex
- std::scoped_lock
- std::unique_lock
- std::defer_lock_t, std::try_to_lock_t, std::adopt_lock_t
- std::lock
- std::try_lock
- std::defer_lock, std::try_to_lock, std::adopt_lock
- std::once_flag
- std::call_once
- std::condition_variable
- std::condition_variable_any
- std::notify_all_at_thread_exit
- std::cv_status
- std::latch
- std::promise
- std::shared_future
- std::packaged_task
- std::async
- std::launch
- std::future_status
- std::future_error
- std::future_category
- std::future_errc
- 注é
- å®éªæ§ C++ ç¹æ§
- æç¨çèµæº
- ç´¢å¼
- std 符å·ç´¢å¼
- åç¨æ¯æ (C++20)
- C++ å ³é®è¯
ä½ç½®ï¼é¦é¡µ > C++ åèæå >çº¿ç¨æ¯æåº > std::future
std::future
| å®ä¹äºå¤´æä»¶ <future>
|
||
| template< class T > class future; |
(1) | (C++11 èµ·) |
| template< class T > class future<T&>; |
(2) | (C++11 èµ·) |
| template<> Â Â Â Â Â class future<void>; |
(3) | (C++11 èµ·) |
ç±»æ¨¡æ¿ std::future æä¾è®¿é®å¼æ¥æä½ç»æçæºå¶ï¼
- ï¼éè¿ std::async ã std::packaged_task æ std::promise å建çï¼å¼æ¥æä½è½æä¾ä¸ä¸ª
std::future对象ç»è¯¥å¼æ¥æä½çå建è ã
- ç¶åï¼å¼æ¥æä½çå建è
è½ç¨åç§æ¹æ³æ¥è¯¢ãçå¾
æä»
std::futureæåå¼ãè¥å¼æ¥æä½ä»æªæä¾å¼ï¼åè¿äºæ¹æ³å¯è½é»å¡ã
- 弿¥æä½åå¤å¥½åéç»æç»å建è
æ¶ï¼å®è½éè¿ä¿®æ¹é¾æ¥å°å建è
ç
std::futureçå ±äº«ç¶æï¼ä¾å¦ std::promise::set_value ï¼è¿è¡ã
注æï¼ std::future æå¼ç¨çå
±äº«ç¶æä¸ä¸å¦ä¸å¼æ¥è¿å对象å
±äº«ï¼ä¸ std::shared_future ç¸åï¼ã
æå彿°
| æé future 对象 (å ¬å¼æå彿°) | |
| ææ future 对象 (å ¬å¼æå彿°) | |
| ç§»å¨future对象 (å ¬å¼æå彿°) | |
ä» *this 转移å
±äº«ç¶æç» shared_future å¹¶è¿åå® (å ¬å¼æå彿°) | |
è·åç»æ | |
| è¿åç»æ (å ¬å¼æå彿°) | |
ç¶æ | |
| æ£æ¥ future æ¯å¦æ¥æå
±äº«ç¶æ (å ¬å¼æå彿°) | |
| çå¾
ç»æåå¾å¯ç¨ (å ¬å¼æå彿°) | |
| çå¾
ç»æï¼å¦æå¨æå®çè¶
æ¶é´éåä»ç¶æ æ³å¾å°ç»æï¼åè¿åã (å ¬å¼æå彿°) | |
| çå¾
ç»æï¼å¦æå¨å·²ç»å°è¾¾æå®çæ¶é´ç¹æ¶ä»ç¶æ æ³å¾å°ç»æï¼åè¿åã (å ¬å¼æå彿°) | |
示ä¾
è¿è¡æ¤ä»£ç
#include <iostream> #include <future> #include <thread>  int main() { // æ¥èª packaged_task ç future std::packaged_task<int()> task([](){ return 7; }); // å è£ å½æ° std::future<int> f1 = task.get_future(); // è·å future std::thread(std::move(task)).detach(); // å¨çº¿ç¨ä¸è¿è¡  // æ¥èª async() ç future std::future<int> f2 = std::async(std::launch::async, [](){ return 8; });  // æ¥èª promise ç future std::promise<int> p; std::future<int> f3 = p.get_future(); std::thread( [&p]{ p.set_value_at_thread_exit(9); }).detach();  std::cout << "Waiting..." << std::flush; f1.wait(); f2.wait(); f3.wait(); std::cout << "Done!\nResults are: " << f1.get() << ' ' << f2.get() << ' ' << f3.get() << '\n'; }
è¾åºï¼
Waiting...Done! Results are: 7 8 9
åé
| (C++11) |
弿¥è¿è¡ä¸ä¸ªå½æ°ï¼æå¯è½å¨æ°çº¿ç¨ä¸æ§è¡ï¼ï¼å¹¶è¿åä¿æå
¶ç»æç std::future (彿°æ¨¡æ¿) |
| (C++11) |
çå¾
è¢«å¼æ¥è®¾ç½®çå¼ï¼å¯è½ä¸ºå
¶ä» future æå¼ç¨ï¼ (类模æ¿) |