命名空间
变体
操作

std::promise<R>::set_value

来自 cppreference.com
< cpp‎ | thread‎ | promise
 
 
并发支持库
线程
(C++11)
(C++20)
this_thread 命名空间
(C++11)
(C++11)
(C++11)
协作取消
互斥
(C++11)
通用锁管理
(C++11)
(C++11)
(C++11)
(C++11)
(C++11)
条件变量
(C++11)
信号量
闩锁和屏障
(C++20)
(C++20)
期货
(C++11)
(C++11)
(C++11)
(C++11)
安全回收
(C++26)
危险指针
原子类型
(C++11)
(C++20)
原子类型初始化
(C++11)(C++20 中已弃用)
(C++11)(C++20 中已弃用)
内存排序
原子操作的自由函数
原子标志的自由函数
 
 
主模板
void set_value( const R& value );
(1) (自 C++11 起)
void set_value( R&& value );
(2) (自 C++11 起)
std::promise<R&> 特化
void set_value( R& value );
(3) (自 C++11 起)
std::promise<void> 特化
void set_value();
(4) (自 C++11 起)
1-3) 原子地将 value 存储到共享状态,并使状态准备就绪。
4) 使状态准备就绪。

此操作的行为就好像 set_valueset_exceptionset_value_at_thread_exitset_exception_at_thread_exit 在更新 promise 对象时获取与 promise 对象关联的单个互斥锁。

对该函数的调用不会对对 get_future 的调用引入数据竞争(因此它们不需要相互同步)。

内容

[编辑] 参数

value - 要存储到共享状态的值

[编辑] 返回值

(无)

[编辑] 异常

在以下条件下,会抛出 std::future_error

此外

1) 由用于复制类型 R 对象的构造函数抛出的任何异常。
2) 由用于移动类型 R 对象的构造函数抛出的任何异常。

[编辑] 示例

此示例展示了如何使用 std::promise<void> 作为线程之间的信号。

#include <algorithm>
#include <cctype>
#include <chrono>
#include <future>
#include <iostream>
#include <iterator>
#include <sstream>
#include <thread>
#include <vector>
 
using namespace std::chrono_literals;
 
int main()
{
    std::istringstream iss_numbers{"3 4 1 42 23 -23 93 2 -289 93"};
    std::istringstream iss_letters{" a 23 b,e a2 k k?a;si,ksa c"};
 
    std::vector<int> numbers;
    std::vector<char> letters;
    std::promise<void> numbers_promise, letters_promise;
 
    auto numbers_ready = numbers_promise.get_future();
    auto letter_ready = letters_promise.get_future();
 
    std::thread value_reader([&]
    {
        // I/O operations
        std::copy(std::istream_iterator<int>{iss_numbers},
                  std::istream_iterator<int>{},
                  std::back_inserter(numbers));
 
        // notify for numbers
        numbers_promise.set_value();
 
        std::copy_if(std::istreambuf_iterator<char>{iss_letters},
                     std::istreambuf_iterator<char>{},
                     std::back_inserter(letters),
                     ::isalpha);
 
        // notify for letters
        letters_promise.set_value();
    });
 
 
    numbers_ready.wait();
 
    std::sort(numbers.begin(), numbers.end());
 
    if (letter_ready.wait_for(1s) == std::future_status::timeout)
    {
        // output the numbers while letters are being obtained
        for (int num : numbers)
            std::cout << num << ' ';
        numbers.clear(); // numbers were already printed
    }
 
    letter_ready.wait();
    std::sort(letters.begin(), letters.end());
 
    // does nothing if numbers were already printed
    for (int num : numbers)
        std::cout << num << ' ';
    std::cout << '\n';
 
    for (char let : letters)
        std::cout << let << ' ';
    std::cout << '\n';
 
    value_reader.join();
}

输出

-289 -23 1 2 3 4 23 42 93 93 
a a a a b c e i k k k s s

[编辑] 缺陷报告

以下行为更改的缺陷报告被追溯地应用于以前发布的 C++ 标准。

DR 应用于 已发布的行为 正确行为
LWG 2098 C++11 重载 (1,2) 只能抛出
分别由 R 的复制/移动
构造函数抛出的异常
它们可以抛出由实际构造函数抛出的异常
用于复制/移动类型 R 的对象
类型 R 的对象

[编辑] 另请参阅

在仅在线程退出时传递通知时,将结果设置为特定值
(公共成员函数) [编辑]
将结果设置为指示异常
(公共成员函数) [编辑]