157 lines · cpp
1//===----------------------------------------------------------------------===//2//3// Part of the LLVM Project, under the Apache License v2.0 with LLVM Exceptions.4// See https://llvm.org/LICENSE.txt for license information.5// SPDX-License-Identifier: Apache-2.0 WITH LLVM-exception6//7//===----------------------------------------------------------------------===//8//9// UNSUPPORTED: no-threads10// UNSUPPORTED: c++0311 12// <future>13 14// class shared_future<R>15 16// const R& shared_future::get();17// R& shared_future<R&>::get();18// void shared_future<void>::get();19 20#include <future>21#include <cassert>22 23#include "make_test_thread.h"24#include "test_macros.h"25 26void func1(std::promise<int> p)27{28 std::this_thread::sleep_for(std::chrono::milliseconds(500));29 p.set_value(3);30}31 32void func2(std::promise<int> p)33{34 std::this_thread::sleep_for(std::chrono::milliseconds(500));35 p.set_exception(std::make_exception_ptr(3));36}37 38int j = 0;39 40void func3(std::promise<int&> p)41{42 std::this_thread::sleep_for(std::chrono::milliseconds(500));43 j = 5;44 p.set_value(j);45}46 47void func4(std::promise<int&> p)48{49 std::this_thread::sleep_for(std::chrono::milliseconds(500));50 p.set_exception(std::make_exception_ptr(3.5));51}52 53void func5(std::promise<void> p)54{55 std::this_thread::sleep_for(std::chrono::milliseconds(500));56 p.set_value();57}58 59void func6(std::promise<void> p)60{61 std::this_thread::sleep_for(std::chrono::milliseconds(500));62 p.set_exception(std::make_exception_ptr('c'));63}64 65int main(int, char**)66{67 {68 typedef int T;69 {70 std::promise<T> p;71 std::shared_future<T> f = p.get_future();72 support::make_test_thread(func1, std::move(p)).detach();73 assert(f.valid());74 assert(f.get() == 3);75 assert(f.valid());76 }77#ifndef TEST_HAS_NO_EXCEPTIONS78 {79 std::promise<T> p;80 std::shared_future<T> f = p.get_future();81 support::make_test_thread(func2, std::move(p)).detach();82 try83 {84 assert(f.valid());85 assert(f.get() == 3);86 assert(false);87 }88 catch (int i)89 {90 assert(i == 3);91 }92 assert(f.valid());93 }94#endif95 }96 {97 typedef int& T;98 {99 std::promise<T> p;100 std::shared_future<T> f = p.get_future();101 support::make_test_thread(func3, std::move(p)).detach();102 assert(f.valid());103 assert(f.get() == 5);104 assert(f.valid());105 }106#ifndef TEST_HAS_NO_EXCEPTIONS107 {108 std::promise<T> p;109 std::shared_future<T> f = p.get_future();110 support::make_test_thread(func4, std::move(p)).detach();111 try112 {113 assert(f.valid());114 assert(f.get() == 3);115 assert(false);116 }117 catch (double i)118 {119 assert(i == 3.5);120 }121 assert(f.valid());122 }123#endif124 }125 {126 typedef void T;127 {128 std::promise<T> p;129 std::shared_future<T> f = p.get_future();130 support::make_test_thread(func5, std::move(p)).detach();131 assert(f.valid());132 f.get();133 assert(f.valid());134 }135#ifndef TEST_HAS_NO_EXCEPTIONS136 {137 std::promise<T> p;138 std::shared_future<T> f = p.get_future();139 support::make_test_thread(func6, std::move(p)).detach();140 try141 {142 assert(f.valid());143 f.get();144 assert(false);145 }146 catch (char i)147 {148 assert(i == 'c');149 }150 assert(f.valid());151 }152#endif153 }154 155 return 0;156}157