mirror of
https://github.com/freebsd/freebsd-src.git
synced 2026-10-30 12:25:10 +01:00
Dimitry Andric
e8948c9522
MFC r309126 (by emaste):
Correct lld llvm-tblgen dependency file name
MFC r309169:
Get rid of separate Subversion mergeinfo properties for llvm-dwarfdump
and llvm-lto. The mergeinfo confuses Subversion enormously, and these
directories will just use the mergeinfo for llvm itself.
MFC r312765:
Pull in r276136 from upstream llvm trunk (by Wei Mi):
Use ValueOffsetPair to enhance value reuse during SCEV expansion.
In D12090, the ExprValueMap was added to reuse existing value during
SCEV expansion. However, const folding and sext/zext distribution can
make the reuse still difficult.
A simplified case is: suppose we know S1 expands to V1 in
ExprValueMap, and
S1 = S2 + C_a
S3 = S2 + C_b
where C_a and C_b are different SCEVConstants. Then we'd like to
expand S3 as V1 - C_a + C_b instead of expanding S2 literally. It is
helpful when S2 is a complex SCEV expr and S2 has no entry in
ExprValueMap, which is usually caused by the fact that S3 is
generated from S1 after const folding.
In order to do that, we represent ExprValueMap as a mapping from SCEV
to ValueOffsetPair. We will save both S1->{V1, 0} and S2->{V1, C_a}
into the ExprValueMap when we create SCEV for V1. When S3 is
expanded, it will first expand S2 to V1 - C_a because of S2->{V1,
C_a} in the map, then expand S3 to V1 - C_a + C_b.
Differential Revision: https://reviews.llvm.org/D21313
This should fix assertion failures when building OpenCV >= 3.1.
PR: 215649
MFC r312831:
Revert r312765 for now, since it causes assertions when building
lang/spidermonkey24.
Reported by: antoine
PR: 215649
MFC r316511 (by jhb):
Add an implementation of __ffssi2() derived from __ffsdi2().
Newer versions of GCC include an __ffssi2() symbol in libgcc and the
compiler can emit calls to it in generated code. This is true for at
least GCC 6.2 when compiling world for mips and mips64.
Reviewed by: jmallett, dim
Sponsored by: DARPA / AFRL
Differential Revision: https://reviews.freebsd.org/D10086
MFC r318601 (by adrian):
[libcompiler-rt] add bswapdi2/bswapsi2
This is required for mips gcc 6.3 userland to build/run.
Reviewed by: emaste, dim
Approved by: emaste
Differential Revision: https://reviews.freebsd.org/D10838
MFC r318884 (by emaste):
lldb: map TRAP_CAP to a trace trap
In the absense of a more specific handler for TRAP_CAP (generated by
ENOTCAPABLE or ECAPMODE while in capability mode) treat it as a trace
trap.
Example usage (testing the bug in PR219173):
% proccontrol -m trapcap lldb usr.bin/hexdump/obj/hexdump -- -Cv -s 1 /bin/ls
...
(lldb) run
Process 12980 launching
Process 12980 launched: '.../usr.bin/hexdump/obj/hexdump' (x86_64)
Process 12980 stopped
* thread #1, stop reason = trace
frame #0: 0x0000004b80c65f1a libc.so.7`__sys_lseek + 10
...
In the future we should have LLDB control the trapcap procctl itself
(as it does with ASLR), as well as report a specific stop reason.
This change eliminates an assertion failure from LLDB for now.
MFC r319796:
Remove a few unneeded files from libllvm, libclang and liblldb.
MFC r319885 (by emaste):
lld: ELF: Fix ICF crash on absolute symbol relocations.
If two sections contained relocations to absolute symbols with the same
value we would crash when trying to access their sections. Add a check that
both symbols point to sections before accessing their sections, and treat
absolute symbols as equal if their values are equal.
Obtained from: LLD commit r292578
MFC r319918:
Revert r319796 for now, it can cause undefined references when linking
in some circumstances.
Reported by: Shawn Webb <[email protected]>
MFC r319957 (by emaste):
lld: Add armelf emulation mode
Obtained from: LLD r305375
MFC r321369:
Upgrade our copies of clang, llvm, lld, lldb, compiler-rt and libc++ to
5.0.0 (trunk r308421). Upstream has branched for the 5.0.0 release,
which should be in about a month. Please report bugs and regressions,
so we can get them into the release.
Please note that from 3.5.0 onwards, clang, llvm and lldb require C++11
support to build; see UPDATING for more information.
MFC r321420:
Add a few more object files to liblldb, which should solve errors when
linking the lldb executable in some cases. In particular, when the
-ffunction-sections -fdata-sections options are turned off, or
ineffective.
Reported by: Shawn Webb, Mark Millard
MFC r321433:
Cleanup stale Options.inc files from the previous libllvm build for
clang 4.0.0. Otherwise, these can get included before the two newly
generated ones (which are different) for clang 5.0.0.
Reported by: Mark Millard
MFC r321439 (by bdrewery):
Move llvm Options.inc hack from r321433 for NO_CLEAN to lib/clang/libllvm.
The files are only ever generated to .OBJDIR, not to WORLDTMP (as a
sysroot) and are only ever included from a compilation. So using
a beforebuild target here removes the file before the compilation
tries to include it.
MFC r321664:
Pull in r308891 from upstream llvm trunk (by Benjamin Kramer):
[CodeGenPrepare] Cut off FindAllMemoryUses if there are too many uses.
This avoids excessive compile time. The case I'm looking at is
Function.cpp from an old version of LLVM that still had the giant
memcmp string matcher in it. Before r308322 this compiled in about 2
minutes, after it, clang takes infinite* time to compile it. With
this patch we're at 5 min, which is still bad but this is a
pathological case.
The cut off at 20 uses was chosen by looking at other cut-offs in LLVM
for user scanning. It's probably too high, but does the job and is
very unlikely to regress anything.
Fixes PR33900.
* I'm impatient and aborted after 15 minutes, on the bug report it was
killed after 2h.
Pull in r308986 from upstream llvm trunk (by Simon Pilgrim):
[X86][CGP] Reduce memcmp() expansion to 2 load pairs (PR33914)
D35067/rL308322 attempted to support up to 4 load pairs for memcmp
inlining which resulted in regressions for some optimized libc memcmp
implementations (PR33914).
Until we can match these more optimal cases, this patch reduces the
memcmp expansion to a maximum of 2 load pairs (which matches what we
do for -Os).
This patch should be considered for the 5.0.0 release branch as well
Differential Revision: https://reviews.llvm.org/D35830
These fix a hang (or extremely long compile time) when building older
LLVM ports.
Reported by: antoine
PR: 219139
MFC r321719:
Pull in r309503 from upstream clang trunk (by Richard Smith):
PR33902: Invalidate line number cache when adding more text to
existing buffer.
This led to crashes as the line number cache would report a bogus
line number for a line of code, and we'd try to find a nonexistent
column within the line when printing diagnostics.
This fixes an assertion when building the graphics/champlain port.
Reported by: antoine, kwm
PR: 219139
MFC r321723:
Upgrade our copies of clang, llvm, lld and lldb to r309439 from the
upstream release_50 branch. This is just after upstream's 5.0.0-rc1.
MFC r322320:
Upgrade our copies of clang, llvm and libc++ to r310316 from the
upstream release_50 branch.
MFC r322326 (by emaste):
lldb: Make i386-*-freebsd expression work on JIT path
* Enable i386 ABI creation for freebsd
* Added an extra argument in ABISysV_i386::PrepareTrivialCall for mmap
syscall
* Unlike linux, the last argument of mmap is actually 64-bit(off_t).
This requires us to push an additional word for the higher order bits.
* Prior to this change, ktrace dump will show mmap failures due to
invalid argument coming from the 6th mmap argument.
Submitted by: Karnajit Wangkhem
Differential Revision: https://reviews.llvm.org/D34776
MFC r322360 (by emaste):
lldb: Report inferior signals as signals, not exceptions, on FreeBSD
This is the FreeBSD equivalent of LLVM r238549.
This serves 2 purposes:
* LLDB should handle inferior process signals SIGSEGV/SIGILL/SIGBUS/
SIGFPE the way it is suppose to be handled. Prior to this fix these
signals will neither create a coredump, nor exit from the debugger
or work for signal handling scenario.
* eInvalidCrashReason need not report "unknown crash reason" if we have
a valid si_signo
llvm.org/pr23699
Patch by Karnajit Wangkhem
Differential Revision: https://reviews.llvm.org/D35223
Submitted by: Karnajit Wangkhem
Obtained from: LLVM r310591
MFC r322474 (by emaste):
lld: Add `-z muldefs` option.
Obtained from: LLVM r310757
MFC r322740:
Upgrade our copies of clang, llvm, lld and libc++ to r311219 from the
upstream release_50 branch.
MFC r322855:
Upgrade our copies of clang, llvm, lldb and compiler-rt to r311606 from
the upstream release_50 branch.
As of this version, lib/msun's trig test should also work correctly
again (see bug 220989 for more information).
PR: 220989
MFC r323112:
Upgrade our copies of clang, llvm, lldb and compiler-rt to r312293 from
the upstream release_50 branch. This corresponds to 5.0.0 rc4.
As of this version, the cad/stepcode port should now compile in a more
reasonable time on i386 (see bug 221836 for more information).
PR: 221836
MFC r323245:
Upgrade our copies of clang, llvm, lld, lldb, compiler-rt and libc++ to
5.0.0 release (upstream r312559).
Release notes for llvm, clang and lld will be available here soon:
<http://releases.llvm.org/5.0.0/docs/ReleaseNotes.html>
<http://releases.llvm.org/5.0.0/tools/clang/docs/ReleaseNotes.html>
<http://releases.llvm.org/5.0.0/tools/lld/docs/ReleaseNotes.html>
Relnotes: yes
2618 lines
71 KiB
C++
2618 lines
71 KiB
C++
// -*- C++ -*-
|
|
//===--------------------------- future -----------------------------------===//
|
|
//
|
|
// The LLVM Compiler Infrastructure
|
|
//
|
|
// This file is dual licensed under the MIT and the University of Illinois Open
|
|
// Source Licenses. See LICENSE.TXT for details.
|
|
//
|
|
//===----------------------------------------------------------------------===//
|
|
|
|
#ifndef _LIBCPP_FUTURE
|
|
#define _LIBCPP_FUTURE
|
|
|
|
/*
|
|
future synopsis
|
|
|
|
namespace std
|
|
{
|
|
|
|
enum class future_errc
|
|
{
|
|
future_already_retrieved = 1,
|
|
promise_already_satisfied,
|
|
no_state,
|
|
broken_promise
|
|
};
|
|
|
|
enum class launch
|
|
{
|
|
async = 1,
|
|
deferred = 2,
|
|
any = async | deferred
|
|
};
|
|
|
|
enum class future_status
|
|
{
|
|
ready,
|
|
timeout,
|
|
deferred
|
|
};
|
|
|
|
template <> struct is_error_code_enum<future_errc> : public true_type { };
|
|
error_code make_error_code(future_errc e) noexcept;
|
|
error_condition make_error_condition(future_errc e) noexcept;
|
|
|
|
const error_category& future_category() noexcept;
|
|
|
|
class future_error
|
|
: public logic_error
|
|
{
|
|
public:
|
|
future_error(error_code ec); // exposition only
|
|
explicit future_error(future_errc); // C++17
|
|
const error_code& code() const noexcept;
|
|
const char* what() const noexcept;
|
|
};
|
|
|
|
template <class R>
|
|
class promise
|
|
{
|
|
public:
|
|
promise();
|
|
template <class Allocator>
|
|
promise(allocator_arg_t, const Allocator& a);
|
|
promise(promise&& rhs) noexcept;
|
|
promise(const promise& rhs) = delete;
|
|
~promise();
|
|
|
|
// assignment
|
|
promise& operator=(promise&& rhs) noexcept;
|
|
promise& operator=(const promise& rhs) = delete;
|
|
void swap(promise& other) noexcept;
|
|
|
|
// retrieving the result
|
|
future<R> get_future();
|
|
|
|
// setting the result
|
|
void set_value(const R& r);
|
|
void set_value(R&& r);
|
|
void set_exception(exception_ptr p);
|
|
|
|
// setting the result with deferred notification
|
|
void set_value_at_thread_exit(const R& r);
|
|
void set_value_at_thread_exit(R&& r);
|
|
void set_exception_at_thread_exit(exception_ptr p);
|
|
};
|
|
|
|
template <class R>
|
|
class promise<R&>
|
|
{
|
|
public:
|
|
promise();
|
|
template <class Allocator>
|
|
promise(allocator_arg_t, const Allocator& a);
|
|
promise(promise&& rhs) noexcept;
|
|
promise(const promise& rhs) = delete;
|
|
~promise();
|
|
|
|
// assignment
|
|
promise& operator=(promise&& rhs) noexcept;
|
|
promise& operator=(const promise& rhs) = delete;
|
|
void swap(promise& other) noexcept;
|
|
|
|
// retrieving the result
|
|
future<R&> get_future();
|
|
|
|
// setting the result
|
|
void set_value(R& r);
|
|
void set_exception(exception_ptr p);
|
|
|
|
// setting the result with deferred notification
|
|
void set_value_at_thread_exit(R&);
|
|
void set_exception_at_thread_exit(exception_ptr p);
|
|
};
|
|
|
|
template <>
|
|
class promise<void>
|
|
{
|
|
public:
|
|
promise();
|
|
template <class Allocator>
|
|
promise(allocator_arg_t, const Allocator& a);
|
|
promise(promise&& rhs) noexcept;
|
|
promise(const promise& rhs) = delete;
|
|
~promise();
|
|
|
|
// assignment
|
|
promise& operator=(promise&& rhs) noexcept;
|
|
promise& operator=(const promise& rhs) = delete;
|
|
void swap(promise& other) noexcept;
|
|
|
|
// retrieving the result
|
|
future<void> get_future();
|
|
|
|
// setting the result
|
|
void set_value();
|
|
void set_exception(exception_ptr p);
|
|
|
|
// setting the result with deferred notification
|
|
void set_value_at_thread_exit();
|
|
void set_exception_at_thread_exit(exception_ptr p);
|
|
};
|
|
|
|
template <class R> void swap(promise<R>& x, promise<R>& y) noexcept;
|
|
|
|
template <class R, class Alloc>
|
|
struct uses_allocator<promise<R>, Alloc> : public true_type {};
|
|
|
|
template <class R>
|
|
class future
|
|
{
|
|
public:
|
|
future() noexcept;
|
|
future(future&&) noexcept;
|
|
future(const future& rhs) = delete;
|
|
~future();
|
|
future& operator=(const future& rhs) = delete;
|
|
future& operator=(future&&) noexcept;
|
|
shared_future<R> share() noexcept;
|
|
|
|
// retrieving the value
|
|
R get();
|
|
|
|
// functions to check state
|
|
bool valid() const noexcept;
|
|
|
|
void wait() const;
|
|
template <class Rep, class Period>
|
|
future_status
|
|
wait_for(const chrono::duration<Rep, Period>& rel_time) const;
|
|
template <class Clock, class Duration>
|
|
future_status
|
|
wait_until(const chrono::time_point<Clock, Duration>& abs_time) const;
|
|
};
|
|
|
|
template <class R>
|
|
class future<R&>
|
|
{
|
|
public:
|
|
future() noexcept;
|
|
future(future&&) noexcept;
|
|
future(const future& rhs) = delete;
|
|
~future();
|
|
future& operator=(const future& rhs) = delete;
|
|
future& operator=(future&&) noexcept;
|
|
shared_future<R&> share() noexcept;
|
|
|
|
// retrieving the value
|
|
R& get();
|
|
|
|
// functions to check state
|
|
bool valid() const noexcept;
|
|
|
|
void wait() const;
|
|
template <class Rep, class Period>
|
|
future_status
|
|
wait_for(const chrono::duration<Rep, Period>& rel_time) const;
|
|
template <class Clock, class Duration>
|
|
future_status
|
|
wait_until(const chrono::time_point<Clock, Duration>& abs_time) const;
|
|
};
|
|
|
|
template <>
|
|
class future<void>
|
|
{
|
|
public:
|
|
future() noexcept;
|
|
future(future&&) noexcept;
|
|
future(const future& rhs) = delete;
|
|
~future();
|
|
future& operator=(const future& rhs) = delete;
|
|
future& operator=(future&&) noexcept;
|
|
shared_future<void> share() noexcept;
|
|
|
|
// retrieving the value
|
|
void get();
|
|
|
|
// functions to check state
|
|
bool valid() const noexcept;
|
|
|
|
void wait() const;
|
|
template <class Rep, class Period>
|
|
future_status
|
|
wait_for(const chrono::duration<Rep, Period>& rel_time) const;
|
|
template <class Clock, class Duration>
|
|
future_status
|
|
wait_until(const chrono::time_point<Clock, Duration>& abs_time) const;
|
|
};
|
|
|
|
template <class R>
|
|
class shared_future
|
|
{
|
|
public:
|
|
shared_future() noexcept;
|
|
shared_future(const shared_future& rhs);
|
|
shared_future(future<R>&&) noexcept;
|
|
shared_future(shared_future&& rhs) noexcept;
|
|
~shared_future();
|
|
shared_future& operator=(const shared_future& rhs);
|
|
shared_future& operator=(shared_future&& rhs) noexcept;
|
|
|
|
// retrieving the value
|
|
const R& get() const;
|
|
|
|
// functions to check state
|
|
bool valid() const noexcept;
|
|
|
|
void wait() const;
|
|
template <class Rep, class Period>
|
|
future_status
|
|
wait_for(const chrono::duration<Rep, Period>& rel_time) const;
|
|
template <class Clock, class Duration>
|
|
future_status
|
|
wait_until(const chrono::time_point<Clock, Duration>& abs_time) const;
|
|
};
|
|
|
|
template <class R>
|
|
class shared_future<R&>
|
|
{
|
|
public:
|
|
shared_future() noexcept;
|
|
shared_future(const shared_future& rhs);
|
|
shared_future(future<R&>&&) noexcept;
|
|
shared_future(shared_future&& rhs) noexcept;
|
|
~shared_future();
|
|
shared_future& operator=(const shared_future& rhs);
|
|
shared_future& operator=(shared_future&& rhs) noexcept;
|
|
|
|
// retrieving the value
|
|
R& get() const;
|
|
|
|
// functions to check state
|
|
bool valid() const noexcept;
|
|
|
|
void wait() const;
|
|
template <class Rep, class Period>
|
|
future_status
|
|
wait_for(const chrono::duration<Rep, Period>& rel_time) const;
|
|
template <class Clock, class Duration>
|
|
future_status
|
|
wait_until(const chrono::time_point<Clock, Duration>& abs_time) const;
|
|
};
|
|
|
|
template <>
|
|
class shared_future<void>
|
|
{
|
|
public:
|
|
shared_future() noexcept;
|
|
shared_future(const shared_future& rhs);
|
|
shared_future(future<void>&&) noexcept;
|
|
shared_future(shared_future&& rhs) noexcept;
|
|
~shared_future();
|
|
shared_future& operator=(const shared_future& rhs);
|
|
shared_future& operator=(shared_future&& rhs) noexcept;
|
|
|
|
// retrieving the value
|
|
void get() const;
|
|
|
|
// functions to check state
|
|
bool valid() const noexcept;
|
|
|
|
void wait() const;
|
|
template <class Rep, class Period>
|
|
future_status
|
|
wait_for(const chrono::duration<Rep, Period>& rel_time) const;
|
|
template <class Clock, class Duration>
|
|
future_status
|
|
wait_until(const chrono::time_point<Clock, Duration>& abs_time) const;
|
|
};
|
|
|
|
template <class F, class... Args>
|
|
future<typename result_of<typename decay<F>::type(typename decay<Args>::type...)>::type>
|
|
async(F&& f, Args&&... args);
|
|
|
|
template <class F, class... Args>
|
|
future<typename result_of<typename decay<F>::type(typename decay<Args>::type...)>::type>
|
|
async(launch policy, F&& f, Args&&... args);
|
|
|
|
template <class> class packaged_task; // undefined
|
|
|
|
template <class R, class... ArgTypes>
|
|
class packaged_task<R(ArgTypes...)>
|
|
{
|
|
public:
|
|
typedef R result_type; // extension
|
|
|
|
// construction and destruction
|
|
packaged_task() noexcept;
|
|
template <class F>
|
|
explicit packaged_task(F&& f);
|
|
template <class F, class Allocator>
|
|
packaged_task(allocator_arg_t, const Allocator& a, F&& f);
|
|
~packaged_task();
|
|
|
|
// no copy
|
|
packaged_task(const packaged_task&) = delete;
|
|
packaged_task& operator=(const packaged_task&) = delete;
|
|
|
|
// move support
|
|
packaged_task(packaged_task&& other) noexcept;
|
|
packaged_task& operator=(packaged_task&& other) noexcept;
|
|
void swap(packaged_task& other) noexcept;
|
|
|
|
bool valid() const noexcept;
|
|
|
|
// result retrieval
|
|
future<R> get_future();
|
|
|
|
// execution
|
|
void operator()(ArgTypes... );
|
|
void make_ready_at_thread_exit(ArgTypes...);
|
|
|
|
void reset();
|
|
};
|
|
|
|
template <class R>
|
|
void swap(packaged_task<R(ArgTypes...)&, packaged_task<R(ArgTypes...)>&) noexcept;
|
|
|
|
template <class R, class Alloc> struct uses_allocator<packaged_task<R>, Alloc>;
|
|
|
|
} // std
|
|
|
|
*/
|
|
|
|
#include <__config>
|
|
#include <system_error>
|
|
#include <memory>
|
|
#include <chrono>
|
|
#include <exception>
|
|
#include <mutex>
|
|
#include <thread>
|
|
|
|
#if !defined(_LIBCPP_HAS_NO_PRAGMA_SYSTEM_HEADER)
|
|
#pragma GCC system_header
|
|
#endif
|
|
|
|
#ifdef _LIBCPP_HAS_NO_THREADS
|
|
#error <future> is not supported on this single threaded system
|
|
#else // !_LIBCPP_HAS_NO_THREADS
|
|
|
|
_LIBCPP_BEGIN_NAMESPACE_STD
|
|
|
|
//enum class future_errc
|
|
_LIBCPP_DECLARE_STRONG_ENUM(future_errc)
|
|
{
|
|
future_already_retrieved = 1,
|
|
promise_already_satisfied,
|
|
no_state,
|
|
broken_promise
|
|
};
|
|
_LIBCPP_DECLARE_STRONG_ENUM_EPILOG(future_errc)
|
|
|
|
template <>
|
|
struct _LIBCPP_TEMPLATE_VIS is_error_code_enum<future_errc> : public true_type {};
|
|
|
|
#ifdef _LIBCPP_HAS_NO_STRONG_ENUMS
|
|
template <>
|
|
struct _LIBCPP_TEMPLATE_VIS is_error_code_enum<future_errc::__lx> : public true_type { };
|
|
#endif
|
|
|
|
//enum class launch
|
|
_LIBCPP_DECLARE_STRONG_ENUM(launch)
|
|
{
|
|
async = 1,
|
|
deferred = 2,
|
|
any = async | deferred
|
|
};
|
|
_LIBCPP_DECLARE_STRONG_ENUM_EPILOG(launch)
|
|
|
|
#ifndef _LIBCPP_HAS_NO_STRONG_ENUMS
|
|
|
|
#ifdef _LIBCXX_UNDERLYING_TYPE
|
|
typedef underlying_type<launch>::type __launch_underlying_type;
|
|
#else
|
|
typedef int __launch_underlying_type;
|
|
#endif
|
|
|
|
inline _LIBCPP_INLINE_VISIBILITY
|
|
_LIBCPP_CONSTEXPR
|
|
launch
|
|
operator&(launch __x, launch __y)
|
|
{
|
|
return static_cast<launch>(static_cast<__launch_underlying_type>(__x) &
|
|
static_cast<__launch_underlying_type>(__y));
|
|
}
|
|
|
|
inline _LIBCPP_INLINE_VISIBILITY
|
|
_LIBCPP_CONSTEXPR
|
|
launch
|
|
operator|(launch __x, launch __y)
|
|
{
|
|
return static_cast<launch>(static_cast<__launch_underlying_type>(__x) |
|
|
static_cast<__launch_underlying_type>(__y));
|
|
}
|
|
|
|
inline _LIBCPP_INLINE_VISIBILITY
|
|
_LIBCPP_CONSTEXPR
|
|
launch
|
|
operator^(launch __x, launch __y)
|
|
{
|
|
return static_cast<launch>(static_cast<__launch_underlying_type>(__x) ^
|
|
static_cast<__launch_underlying_type>(__y));
|
|
}
|
|
|
|
inline _LIBCPP_INLINE_VISIBILITY
|
|
_LIBCPP_CONSTEXPR
|
|
launch
|
|
operator~(launch __x)
|
|
{
|
|
return static_cast<launch>(~static_cast<__launch_underlying_type>(__x) & 3);
|
|
}
|
|
|
|
inline _LIBCPP_INLINE_VISIBILITY
|
|
launch&
|
|
operator&=(launch& __x, launch __y)
|
|
{
|
|
__x = __x & __y; return __x;
|
|
}
|
|
|
|
inline _LIBCPP_INLINE_VISIBILITY
|
|
launch&
|
|
operator|=(launch& __x, launch __y)
|
|
{
|
|
__x = __x | __y; return __x;
|
|
}
|
|
|
|
inline _LIBCPP_INLINE_VISIBILITY
|
|
launch&
|
|
operator^=(launch& __x, launch __y)
|
|
{
|
|
__x = __x ^ __y; return __x;
|
|
}
|
|
|
|
#endif // !_LIBCPP_HAS_NO_STRONG_ENUMS
|
|
|
|
//enum class future_status
|
|
_LIBCPP_DECLARE_STRONG_ENUM(future_status)
|
|
{
|
|
ready,
|
|
timeout,
|
|
deferred
|
|
};
|
|
_LIBCPP_DECLARE_STRONG_ENUM_EPILOG(future_status)
|
|
|
|
_LIBCPP_FUNC_VIS
|
|
const error_category& future_category() _NOEXCEPT;
|
|
|
|
inline _LIBCPP_INLINE_VISIBILITY
|
|
error_code
|
|
make_error_code(future_errc __e) _NOEXCEPT
|
|
{
|
|
return error_code(static_cast<int>(__e), future_category());
|
|
}
|
|
|
|
inline _LIBCPP_INLINE_VISIBILITY
|
|
error_condition
|
|
make_error_condition(future_errc __e) _NOEXCEPT
|
|
{
|
|
return error_condition(static_cast<int>(__e), future_category());
|
|
}
|
|
|
|
class _LIBCPP_EXCEPTION_ABI _LIBCPP_AVAILABILITY_FUTURE_ERROR future_error
|
|
: public logic_error
|
|
{
|
|
error_code __ec_;
|
|
public:
|
|
future_error(error_code __ec);
|
|
#if _LIBCPP_STD_VERS > 14
|
|
explicit future_error(future_errc _Ev) : logic_error(), __ec_(make_error_code(_Ev)) {}
|
|
#endif
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
const error_code& code() const _NOEXCEPT {return __ec_;}
|
|
|
|
virtual ~future_error() _NOEXCEPT;
|
|
};
|
|
|
|
_LIBCPP_NORETURN inline _LIBCPP_ALWAYS_INLINE
|
|
#ifndef _LIBCPP_NO_EXCEPTIONS
|
|
_LIBCPP_AVAILABILITY_FUTURE_ERROR
|
|
#endif
|
|
void __throw_future_error(future_errc _Ev)
|
|
{
|
|
#ifndef _LIBCPP_NO_EXCEPTIONS
|
|
throw future_error(make_error_code(_Ev));
|
|
#else
|
|
((void)_Ev);
|
|
_VSTD::abort();
|
|
#endif
|
|
}
|
|
|
|
class _LIBCPP_TYPE_VIS _LIBCPP_AVAILABILITY_FUTURE __assoc_sub_state
|
|
: public __shared_count
|
|
{
|
|
protected:
|
|
exception_ptr __exception_;
|
|
mutable mutex __mut_;
|
|
mutable condition_variable __cv_;
|
|
unsigned __state_;
|
|
|
|
virtual void __on_zero_shared() _NOEXCEPT;
|
|
void __sub_wait(unique_lock<mutex>& __lk);
|
|
public:
|
|
enum
|
|
{
|
|
__constructed = 1,
|
|
__future_attached = 2,
|
|
ready = 4,
|
|
deferred = 8
|
|
};
|
|
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
__assoc_sub_state() : __state_(0) {}
|
|
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
bool __has_value() const
|
|
{return (__state_ & __constructed) || (__exception_ != nullptr);}
|
|
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
void __set_future_attached()
|
|
{
|
|
lock_guard<mutex> __lk(__mut_);
|
|
__state_ |= __future_attached;
|
|
}
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
bool __has_future_attached() const {return (__state_ & __future_attached) != 0;}
|
|
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
void __set_deferred() {__state_ |= deferred;}
|
|
|
|
void __make_ready();
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
bool __is_ready() const {return (__state_ & ready) != 0;}
|
|
|
|
void set_value();
|
|
void set_value_at_thread_exit();
|
|
|
|
void set_exception(exception_ptr __p);
|
|
void set_exception_at_thread_exit(exception_ptr __p);
|
|
|
|
void copy();
|
|
|
|
void wait();
|
|
template <class _Rep, class _Period>
|
|
future_status
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
wait_for(const chrono::duration<_Rep, _Period>& __rel_time) const;
|
|
template <class _Clock, class _Duration>
|
|
_LIBCPP_METHOD_TEMPLATE_IMPLICIT_INSTANTIATION_VIS
|
|
future_status
|
|
wait_until(const chrono::time_point<_Clock, _Duration>& __abs_time) const;
|
|
|
|
virtual void __execute();
|
|
};
|
|
|
|
template <class _Clock, class _Duration>
|
|
future_status
|
|
__assoc_sub_state::wait_until(const chrono::time_point<_Clock, _Duration>& __abs_time) const
|
|
{
|
|
unique_lock<mutex> __lk(__mut_);
|
|
if (__state_ & deferred)
|
|
return future_status::deferred;
|
|
while (!(__state_ & ready) && _Clock::now() < __abs_time)
|
|
__cv_.wait_until(__lk, __abs_time);
|
|
if (__state_ & ready)
|
|
return future_status::ready;
|
|
return future_status::timeout;
|
|
}
|
|
|
|
template <class _Rep, class _Period>
|
|
inline
|
|
future_status
|
|
__assoc_sub_state::wait_for(const chrono::duration<_Rep, _Period>& __rel_time) const
|
|
{
|
|
return wait_until(chrono::steady_clock::now() + __rel_time);
|
|
}
|
|
|
|
template <class _Rp>
|
|
class _LIBCPP_AVAILABILITY_FUTURE __assoc_state
|
|
: public __assoc_sub_state
|
|
{
|
|
typedef __assoc_sub_state base;
|
|
typedef typename aligned_storage<sizeof(_Rp), alignment_of<_Rp>::value>::type _Up;
|
|
protected:
|
|
_Up __value_;
|
|
|
|
virtual void __on_zero_shared() _NOEXCEPT;
|
|
public:
|
|
|
|
template <class _Arg>
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
void set_value(_Arg&& __arg);
|
|
#else
|
|
void set_value(_Arg& __arg);
|
|
#endif
|
|
|
|
template <class _Arg>
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
void set_value_at_thread_exit(_Arg&& __arg);
|
|
#else
|
|
void set_value_at_thread_exit(_Arg& __arg);
|
|
#endif
|
|
|
|
_Rp move();
|
|
typename add_lvalue_reference<_Rp>::type copy();
|
|
};
|
|
|
|
template <class _Rp>
|
|
void
|
|
__assoc_state<_Rp>::__on_zero_shared() _NOEXCEPT
|
|
{
|
|
if (this->__state_ & base::__constructed)
|
|
reinterpret_cast<_Rp*>(&__value_)->~_Rp();
|
|
delete this;
|
|
}
|
|
|
|
template <class _Rp>
|
|
template <class _Arg>
|
|
_LIBCPP_AVAILABILITY_FUTURE
|
|
void
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
__assoc_state<_Rp>::set_value(_Arg&& __arg)
|
|
#else
|
|
__assoc_state<_Rp>::set_value(_Arg& __arg)
|
|
#endif
|
|
{
|
|
unique_lock<mutex> __lk(this->__mut_);
|
|
if (this->__has_value())
|
|
__throw_future_error(future_errc::promise_already_satisfied);
|
|
::new(&__value_) _Rp(_VSTD::forward<_Arg>(__arg));
|
|
this->__state_ |= base::__constructed | base::ready;
|
|
__cv_.notify_all();
|
|
}
|
|
|
|
template <class _Rp>
|
|
template <class _Arg>
|
|
void
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
__assoc_state<_Rp>::set_value_at_thread_exit(_Arg&& __arg)
|
|
#else
|
|
__assoc_state<_Rp>::set_value_at_thread_exit(_Arg& __arg)
|
|
#endif
|
|
{
|
|
unique_lock<mutex> __lk(this->__mut_);
|
|
if (this->__has_value())
|
|
__throw_future_error(future_errc::promise_already_satisfied);
|
|
::new(&__value_) _Rp(_VSTD::forward<_Arg>(__arg));
|
|
this->__state_ |= base::__constructed;
|
|
__thread_local_data()->__make_ready_at_thread_exit(this);
|
|
}
|
|
|
|
template <class _Rp>
|
|
_Rp
|
|
__assoc_state<_Rp>::move()
|
|
{
|
|
unique_lock<mutex> __lk(this->__mut_);
|
|
this->__sub_wait(__lk);
|
|
if (this->__exception_ != nullptr)
|
|
rethrow_exception(this->__exception_);
|
|
return _VSTD::move(*reinterpret_cast<_Rp*>(&__value_));
|
|
}
|
|
|
|
template <class _Rp>
|
|
typename add_lvalue_reference<_Rp>::type
|
|
__assoc_state<_Rp>::copy()
|
|
{
|
|
unique_lock<mutex> __lk(this->__mut_);
|
|
this->__sub_wait(__lk);
|
|
if (this->__exception_ != nullptr)
|
|
rethrow_exception(this->__exception_);
|
|
return *reinterpret_cast<_Rp*>(&__value_);
|
|
}
|
|
|
|
template <class _Rp>
|
|
class _LIBCPP_AVAILABILITY_FUTURE __assoc_state<_Rp&>
|
|
: public __assoc_sub_state
|
|
{
|
|
typedef __assoc_sub_state base;
|
|
typedef _Rp* _Up;
|
|
protected:
|
|
_Up __value_;
|
|
|
|
virtual void __on_zero_shared() _NOEXCEPT;
|
|
public:
|
|
|
|
void set_value(_Rp& __arg);
|
|
void set_value_at_thread_exit(_Rp& __arg);
|
|
|
|
_Rp& copy();
|
|
};
|
|
|
|
template <class _Rp>
|
|
void
|
|
__assoc_state<_Rp&>::__on_zero_shared() _NOEXCEPT
|
|
{
|
|
delete this;
|
|
}
|
|
|
|
template <class _Rp>
|
|
void
|
|
__assoc_state<_Rp&>::set_value(_Rp& __arg)
|
|
{
|
|
unique_lock<mutex> __lk(this->__mut_);
|
|
if (this->__has_value())
|
|
__throw_future_error(future_errc::promise_already_satisfied);
|
|
__value_ = _VSTD::addressof(__arg);
|
|
this->__state_ |= base::__constructed | base::ready;
|
|
__cv_.notify_all();
|
|
}
|
|
|
|
template <class _Rp>
|
|
void
|
|
__assoc_state<_Rp&>::set_value_at_thread_exit(_Rp& __arg)
|
|
{
|
|
unique_lock<mutex> __lk(this->__mut_);
|
|
if (this->__has_value())
|
|
__throw_future_error(future_errc::promise_already_satisfied);
|
|
__value_ = _VSTD::addressof(__arg);
|
|
this->__state_ |= base::__constructed;
|
|
__thread_local_data()->__make_ready_at_thread_exit(this);
|
|
}
|
|
|
|
template <class _Rp>
|
|
_Rp&
|
|
__assoc_state<_Rp&>::copy()
|
|
{
|
|
unique_lock<mutex> __lk(this->__mut_);
|
|
this->__sub_wait(__lk);
|
|
if (this->__exception_ != nullptr)
|
|
rethrow_exception(this->__exception_);
|
|
return *__value_;
|
|
}
|
|
|
|
template <class _Rp, class _Alloc>
|
|
class _LIBCPP_AVAILABILITY_FUTURE __assoc_state_alloc
|
|
: public __assoc_state<_Rp>
|
|
{
|
|
typedef __assoc_state<_Rp> base;
|
|
_Alloc __alloc_;
|
|
|
|
virtual void __on_zero_shared() _NOEXCEPT;
|
|
public:
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
explicit __assoc_state_alloc(const _Alloc& __a)
|
|
: __alloc_(__a) {}
|
|
};
|
|
|
|
template <class _Rp, class _Alloc>
|
|
void
|
|
__assoc_state_alloc<_Rp, _Alloc>::__on_zero_shared() _NOEXCEPT
|
|
{
|
|
if (this->__state_ & base::__constructed)
|
|
reinterpret_cast<_Rp*>(_VSTD::addressof(this->__value_))->~_Rp();
|
|
typedef typename __allocator_traits_rebind<_Alloc, __assoc_state_alloc>::type _Al;
|
|
typedef allocator_traits<_Al> _ATraits;
|
|
typedef pointer_traits<typename _ATraits::pointer> _PTraits;
|
|
_Al __a(__alloc_);
|
|
this->~__assoc_state_alloc();
|
|
__a.deallocate(_PTraits::pointer_to(*this), 1);
|
|
}
|
|
|
|
template <class _Rp, class _Alloc>
|
|
class _LIBCPP_AVAILABILITY_FUTURE __assoc_state_alloc<_Rp&, _Alloc>
|
|
: public __assoc_state<_Rp&>
|
|
{
|
|
typedef __assoc_state<_Rp&> base;
|
|
_Alloc __alloc_;
|
|
|
|
virtual void __on_zero_shared() _NOEXCEPT;
|
|
public:
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
explicit __assoc_state_alloc(const _Alloc& __a)
|
|
: __alloc_(__a) {}
|
|
};
|
|
|
|
template <class _Rp, class _Alloc>
|
|
void
|
|
__assoc_state_alloc<_Rp&, _Alloc>::__on_zero_shared() _NOEXCEPT
|
|
{
|
|
typedef typename __allocator_traits_rebind<_Alloc, __assoc_state_alloc>::type _Al;
|
|
typedef allocator_traits<_Al> _ATraits;
|
|
typedef pointer_traits<typename _ATraits::pointer> _PTraits;
|
|
_Al __a(__alloc_);
|
|
this->~__assoc_state_alloc();
|
|
__a.deallocate(_PTraits::pointer_to(*this), 1);
|
|
}
|
|
|
|
template <class _Alloc>
|
|
class _LIBCPP_AVAILABILITY_FUTURE __assoc_sub_state_alloc
|
|
: public __assoc_sub_state
|
|
{
|
|
typedef __assoc_sub_state base;
|
|
_Alloc __alloc_;
|
|
|
|
virtual void __on_zero_shared() _NOEXCEPT;
|
|
public:
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
explicit __assoc_sub_state_alloc(const _Alloc& __a)
|
|
: __alloc_(__a) {}
|
|
};
|
|
|
|
template <class _Alloc>
|
|
void
|
|
__assoc_sub_state_alloc<_Alloc>::__on_zero_shared() _NOEXCEPT
|
|
{
|
|
typedef typename __allocator_traits_rebind<_Alloc, __assoc_sub_state_alloc>::type _Al;
|
|
typedef allocator_traits<_Al> _ATraits;
|
|
typedef pointer_traits<typename _ATraits::pointer> _PTraits;
|
|
_Al __a(__alloc_);
|
|
this->~__assoc_sub_state_alloc();
|
|
__a.deallocate(_PTraits::pointer_to(*this), 1);
|
|
}
|
|
|
|
template <class _Rp, class _Fp>
|
|
class _LIBCPP_AVAILABILITY_FUTURE __deferred_assoc_state
|
|
: public __assoc_state<_Rp>
|
|
{
|
|
typedef __assoc_state<_Rp> base;
|
|
|
|
_Fp __func_;
|
|
|
|
public:
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
explicit __deferred_assoc_state(_Fp&& __f);
|
|
#endif
|
|
|
|
virtual void __execute();
|
|
};
|
|
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
|
|
template <class _Rp, class _Fp>
|
|
inline
|
|
__deferred_assoc_state<_Rp, _Fp>::__deferred_assoc_state(_Fp&& __f)
|
|
: __func_(_VSTD::forward<_Fp>(__f))
|
|
{
|
|
this->__set_deferred();
|
|
}
|
|
|
|
#endif // _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
|
|
template <class _Rp, class _Fp>
|
|
void
|
|
__deferred_assoc_state<_Rp, _Fp>::__execute()
|
|
{
|
|
#ifndef _LIBCPP_NO_EXCEPTIONS
|
|
try
|
|
{
|
|
#endif // _LIBCPP_NO_EXCEPTIONS
|
|
this->set_value(__func_());
|
|
#ifndef _LIBCPP_NO_EXCEPTIONS
|
|
}
|
|
catch (...)
|
|
{
|
|
this->set_exception(current_exception());
|
|
}
|
|
#endif // _LIBCPP_NO_EXCEPTIONS
|
|
}
|
|
|
|
template <class _Fp>
|
|
class _LIBCPP_AVAILABILITY_FUTURE __deferred_assoc_state<void, _Fp>
|
|
: public __assoc_sub_state
|
|
{
|
|
typedef __assoc_sub_state base;
|
|
|
|
_Fp __func_;
|
|
|
|
public:
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
explicit __deferred_assoc_state(_Fp&& __f);
|
|
#endif
|
|
|
|
virtual void __execute();
|
|
};
|
|
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
|
|
template <class _Fp>
|
|
inline
|
|
__deferred_assoc_state<void, _Fp>::__deferred_assoc_state(_Fp&& __f)
|
|
: __func_(_VSTD::forward<_Fp>(__f))
|
|
{
|
|
this->__set_deferred();
|
|
}
|
|
|
|
#endif // _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
|
|
template <class _Fp>
|
|
void
|
|
__deferred_assoc_state<void, _Fp>::__execute()
|
|
{
|
|
#ifndef _LIBCPP_NO_EXCEPTIONS
|
|
try
|
|
{
|
|
#endif // _LIBCPP_NO_EXCEPTIONS
|
|
__func_();
|
|
this->set_value();
|
|
#ifndef _LIBCPP_NO_EXCEPTIONS
|
|
}
|
|
catch (...)
|
|
{
|
|
this->set_exception(current_exception());
|
|
}
|
|
#endif // _LIBCPP_NO_EXCEPTIONS
|
|
}
|
|
|
|
template <class _Rp, class _Fp>
|
|
class _LIBCPP_AVAILABILITY_FUTURE __async_assoc_state
|
|
: public __assoc_state<_Rp>
|
|
{
|
|
typedef __assoc_state<_Rp> base;
|
|
|
|
_Fp __func_;
|
|
|
|
virtual void __on_zero_shared() _NOEXCEPT;
|
|
public:
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
explicit __async_assoc_state(_Fp&& __f);
|
|
#endif
|
|
|
|
virtual void __execute();
|
|
};
|
|
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
|
|
template <class _Rp, class _Fp>
|
|
inline
|
|
__async_assoc_state<_Rp, _Fp>::__async_assoc_state(_Fp&& __f)
|
|
: __func_(_VSTD::forward<_Fp>(__f))
|
|
{
|
|
}
|
|
|
|
#endif // _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
|
|
template <class _Rp, class _Fp>
|
|
void
|
|
__async_assoc_state<_Rp, _Fp>::__execute()
|
|
{
|
|
#ifndef _LIBCPP_NO_EXCEPTIONS
|
|
try
|
|
{
|
|
#endif // _LIBCPP_NO_EXCEPTIONS
|
|
this->set_value(__func_());
|
|
#ifndef _LIBCPP_NO_EXCEPTIONS
|
|
}
|
|
catch (...)
|
|
{
|
|
this->set_exception(current_exception());
|
|
}
|
|
#endif // _LIBCPP_NO_EXCEPTIONS
|
|
}
|
|
|
|
template <class _Rp, class _Fp>
|
|
void
|
|
__async_assoc_state<_Rp, _Fp>::__on_zero_shared() _NOEXCEPT
|
|
{
|
|
this->wait();
|
|
base::__on_zero_shared();
|
|
}
|
|
|
|
template <class _Fp>
|
|
class _LIBCPP_AVAILABILITY_FUTURE __async_assoc_state<void, _Fp>
|
|
: public __assoc_sub_state
|
|
{
|
|
typedef __assoc_sub_state base;
|
|
|
|
_Fp __func_;
|
|
|
|
virtual void __on_zero_shared() _NOEXCEPT;
|
|
public:
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
explicit __async_assoc_state(_Fp&& __f);
|
|
#endif
|
|
|
|
virtual void __execute();
|
|
};
|
|
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
|
|
template <class _Fp>
|
|
inline
|
|
__async_assoc_state<void, _Fp>::__async_assoc_state(_Fp&& __f)
|
|
: __func_(_VSTD::forward<_Fp>(__f))
|
|
{
|
|
}
|
|
|
|
#endif // _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
|
|
template <class _Fp>
|
|
void
|
|
__async_assoc_state<void, _Fp>::__execute()
|
|
{
|
|
#ifndef _LIBCPP_NO_EXCEPTIONS
|
|
try
|
|
{
|
|
#endif // _LIBCPP_NO_EXCEPTIONS
|
|
__func_();
|
|
this->set_value();
|
|
#ifndef _LIBCPP_NO_EXCEPTIONS
|
|
}
|
|
catch (...)
|
|
{
|
|
this->set_exception(current_exception());
|
|
}
|
|
#endif // _LIBCPP_NO_EXCEPTIONS
|
|
}
|
|
|
|
template <class _Fp>
|
|
void
|
|
__async_assoc_state<void, _Fp>::__on_zero_shared() _NOEXCEPT
|
|
{
|
|
this->wait();
|
|
base::__on_zero_shared();
|
|
}
|
|
|
|
template <class _Rp> class _LIBCPP_TEMPLATE_VIS promise;
|
|
template <class _Rp> class _LIBCPP_TEMPLATE_VIS shared_future;
|
|
|
|
// future
|
|
|
|
template <class _Rp> class _LIBCPP_TEMPLATE_VIS future;
|
|
|
|
template <class _Rp, class _Fp>
|
|
future<_Rp>
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
__make_deferred_assoc_state(_Fp&& __f);
|
|
#else
|
|
__make_deferred_assoc_state(_Fp __f);
|
|
#endif
|
|
|
|
template <class _Rp, class _Fp>
|
|
future<_Rp>
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
__make_async_assoc_state(_Fp&& __f);
|
|
#else
|
|
__make_async_assoc_state(_Fp __f);
|
|
#endif
|
|
|
|
template <class _Rp>
|
|
class _LIBCPP_TEMPLATE_VIS _LIBCPP_AVAILABILITY_FUTURE future
|
|
{
|
|
__assoc_state<_Rp>* __state_;
|
|
|
|
explicit future(__assoc_state<_Rp>* __state);
|
|
|
|
template <class> friend class promise;
|
|
template <class> friend class shared_future;
|
|
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
template <class _R1, class _Fp>
|
|
friend future<_R1> __make_deferred_assoc_state(_Fp&& __f);
|
|
template <class _R1, class _Fp>
|
|
friend future<_R1> __make_async_assoc_state(_Fp&& __f);
|
|
#else
|
|
template <class _R1, class _Fp>
|
|
friend future<_R1> __make_deferred_assoc_state(_Fp __f);
|
|
template <class _R1, class _Fp>
|
|
friend future<_R1> __make_async_assoc_state(_Fp __f);
|
|
#endif
|
|
|
|
public:
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
future() _NOEXCEPT : __state_(nullptr) {}
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
future(future&& __rhs) _NOEXCEPT
|
|
: __state_(__rhs.__state_) {__rhs.__state_ = nullptr;}
|
|
future(const future&) = delete;
|
|
future& operator=(const future&) = delete;
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
future& operator=(future&& __rhs) _NOEXCEPT
|
|
{
|
|
future(std::move(__rhs)).swap(*this);
|
|
return *this;
|
|
}
|
|
#else // _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
private:
|
|
future(const future&);
|
|
future& operator=(const future&);
|
|
public:
|
|
#endif // _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
~future();
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
shared_future<_Rp> share() _NOEXCEPT;
|
|
|
|
// retrieving the value
|
|
_Rp get();
|
|
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
void swap(future& __rhs) _NOEXCEPT {_VSTD::swap(__state_, __rhs.__state_);}
|
|
|
|
// functions to check state
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
bool valid() const _NOEXCEPT {return __state_ != nullptr;}
|
|
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
void wait() const {__state_->wait();}
|
|
template <class _Rep, class _Period>
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
future_status
|
|
wait_for(const chrono::duration<_Rep, _Period>& __rel_time) const
|
|
{return __state_->wait_for(__rel_time);}
|
|
template <class _Clock, class _Duration>
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
future_status
|
|
wait_until(const chrono::time_point<_Clock, _Duration>& __abs_time) const
|
|
{return __state_->wait_until(__abs_time);}
|
|
};
|
|
|
|
template <class _Rp>
|
|
future<_Rp>::future(__assoc_state<_Rp>* __state)
|
|
: __state_(__state)
|
|
{
|
|
if (__state_->__has_future_attached())
|
|
__throw_future_error(future_errc::future_already_retrieved);
|
|
__state_->__add_shared();
|
|
__state_->__set_future_attached();
|
|
}
|
|
|
|
struct __release_shared_count
|
|
{
|
|
void operator()(__shared_count* p) {p->__release_shared();}
|
|
};
|
|
|
|
template <class _Rp>
|
|
future<_Rp>::~future()
|
|
{
|
|
if (__state_)
|
|
__state_->__release_shared();
|
|
}
|
|
|
|
template <class _Rp>
|
|
_Rp
|
|
future<_Rp>::get()
|
|
{
|
|
unique_ptr<__shared_count, __release_shared_count> __(__state_);
|
|
__assoc_state<_Rp>* __s = __state_;
|
|
__state_ = nullptr;
|
|
return __s->move();
|
|
}
|
|
|
|
template <class _Rp>
|
|
class _LIBCPP_TEMPLATE_VIS _LIBCPP_AVAILABILITY_FUTURE future<_Rp&>
|
|
{
|
|
__assoc_state<_Rp&>* __state_;
|
|
|
|
explicit future(__assoc_state<_Rp&>* __state);
|
|
|
|
template <class> friend class promise;
|
|
template <class> friend class shared_future;
|
|
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
template <class _R1, class _Fp>
|
|
friend future<_R1> __make_deferred_assoc_state(_Fp&& __f);
|
|
template <class _R1, class _Fp>
|
|
friend future<_R1> __make_async_assoc_state(_Fp&& __f);
|
|
#else
|
|
template <class _R1, class _Fp>
|
|
friend future<_R1> __make_deferred_assoc_state(_Fp __f);
|
|
template <class _R1, class _Fp>
|
|
friend future<_R1> __make_async_assoc_state(_Fp __f);
|
|
#endif
|
|
|
|
public:
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
future() _NOEXCEPT : __state_(nullptr) {}
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
future(future&& __rhs) _NOEXCEPT
|
|
: __state_(__rhs.__state_) {__rhs.__state_ = nullptr;}
|
|
future(const future&) = delete;
|
|
future& operator=(const future&) = delete;
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
future& operator=(future&& __rhs) _NOEXCEPT
|
|
{
|
|
future(std::move(__rhs)).swap(*this);
|
|
return *this;
|
|
}
|
|
#else // _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
private:
|
|
future(const future&);
|
|
future& operator=(const future&);
|
|
public:
|
|
#endif // _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
~future();
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
shared_future<_Rp&> share() _NOEXCEPT;
|
|
|
|
// retrieving the value
|
|
_Rp& get();
|
|
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
void swap(future& __rhs) _NOEXCEPT {_VSTD::swap(__state_, __rhs.__state_);}
|
|
|
|
// functions to check state
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
bool valid() const _NOEXCEPT {return __state_ != nullptr;}
|
|
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
void wait() const {__state_->wait();}
|
|
template <class _Rep, class _Period>
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
future_status
|
|
wait_for(const chrono::duration<_Rep, _Period>& __rel_time) const
|
|
{return __state_->wait_for(__rel_time);}
|
|
template <class _Clock, class _Duration>
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
future_status
|
|
wait_until(const chrono::time_point<_Clock, _Duration>& __abs_time) const
|
|
{return __state_->wait_until(__abs_time);}
|
|
};
|
|
|
|
template <class _Rp>
|
|
future<_Rp&>::future(__assoc_state<_Rp&>* __state)
|
|
: __state_(__state)
|
|
{
|
|
if (__state_->__has_future_attached())
|
|
__throw_future_error(future_errc::future_already_retrieved);
|
|
__state_->__add_shared();
|
|
__state_->__set_future_attached();
|
|
}
|
|
|
|
template <class _Rp>
|
|
future<_Rp&>::~future()
|
|
{
|
|
if (__state_)
|
|
__state_->__release_shared();
|
|
}
|
|
|
|
template <class _Rp>
|
|
_Rp&
|
|
future<_Rp&>::get()
|
|
{
|
|
unique_ptr<__shared_count, __release_shared_count> __(__state_);
|
|
__assoc_state<_Rp&>* __s = __state_;
|
|
__state_ = nullptr;
|
|
return __s->copy();
|
|
}
|
|
|
|
template <>
|
|
class _LIBCPP_TYPE_VIS _LIBCPP_AVAILABILITY_FUTURE future<void>
|
|
{
|
|
__assoc_sub_state* __state_;
|
|
|
|
explicit future(__assoc_sub_state* __state);
|
|
|
|
template <class> friend class promise;
|
|
template <class> friend class shared_future;
|
|
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
template <class _R1, class _Fp>
|
|
friend future<_R1> __make_deferred_assoc_state(_Fp&& __f);
|
|
template <class _R1, class _Fp>
|
|
friend future<_R1> __make_async_assoc_state(_Fp&& __f);
|
|
#else
|
|
template <class _R1, class _Fp>
|
|
friend future<_R1> __make_deferred_assoc_state(_Fp __f);
|
|
template <class _R1, class _Fp>
|
|
friend future<_R1> __make_async_assoc_state(_Fp __f);
|
|
#endif
|
|
|
|
public:
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
future() _NOEXCEPT : __state_(nullptr) {}
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
future(future&& __rhs) _NOEXCEPT
|
|
: __state_(__rhs.__state_) {__rhs.__state_ = nullptr;}
|
|
future(const future&) = delete;
|
|
future& operator=(const future&) = delete;
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
future& operator=(future&& __rhs) _NOEXCEPT
|
|
{
|
|
future(std::move(__rhs)).swap(*this);
|
|
return *this;
|
|
}
|
|
#else // _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
private:
|
|
future(const future&);
|
|
future& operator=(const future&);
|
|
public:
|
|
#endif // _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
~future();
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
shared_future<void> share() _NOEXCEPT;
|
|
|
|
// retrieving the value
|
|
void get();
|
|
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
void swap(future& __rhs) _NOEXCEPT {_VSTD::swap(__state_, __rhs.__state_);}
|
|
|
|
// functions to check state
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
bool valid() const _NOEXCEPT {return __state_ != nullptr;}
|
|
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
void wait() const {__state_->wait();}
|
|
template <class _Rep, class _Period>
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
future_status
|
|
wait_for(const chrono::duration<_Rep, _Period>& __rel_time) const
|
|
{return __state_->wait_for(__rel_time);}
|
|
template <class _Clock, class _Duration>
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
future_status
|
|
wait_until(const chrono::time_point<_Clock, _Duration>& __abs_time) const
|
|
{return __state_->wait_until(__abs_time);}
|
|
};
|
|
|
|
template <class _Rp>
|
|
inline _LIBCPP_INLINE_VISIBILITY
|
|
void
|
|
swap(future<_Rp>& __x, future<_Rp>& __y) _NOEXCEPT
|
|
{
|
|
__x.swap(__y);
|
|
}
|
|
|
|
// promise<R>
|
|
|
|
template <class _Callable> class packaged_task;
|
|
|
|
template <class _Rp>
|
|
class _LIBCPP_TEMPLATE_VIS _LIBCPP_AVAILABILITY_FUTURE promise
|
|
{
|
|
__assoc_state<_Rp>* __state_;
|
|
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
explicit promise(nullptr_t) _NOEXCEPT : __state_(nullptr) {}
|
|
|
|
template <class> friend class packaged_task;
|
|
public:
|
|
promise();
|
|
template <class _Alloc>
|
|
promise(allocator_arg_t, const _Alloc& __a);
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
promise(promise&& __rhs) _NOEXCEPT
|
|
: __state_(__rhs.__state_) {__rhs.__state_ = nullptr;}
|
|
promise(const promise& __rhs) = delete;
|
|
#else // _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
private:
|
|
promise(const promise& __rhs);
|
|
public:
|
|
#endif // _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
~promise();
|
|
|
|
// assignment
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
promise& operator=(promise&& __rhs) _NOEXCEPT
|
|
{
|
|
promise(std::move(__rhs)).swap(*this);
|
|
return *this;
|
|
}
|
|
promise& operator=(const promise& __rhs) = delete;
|
|
#else // _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
private:
|
|
promise& operator=(const promise& __rhs);
|
|
public:
|
|
#endif // _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
void swap(promise& __rhs) _NOEXCEPT {_VSTD::swap(__state_, __rhs.__state_);}
|
|
|
|
// retrieving the result
|
|
future<_Rp> get_future();
|
|
|
|
// setting the result
|
|
void set_value(const _Rp& __r);
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
void set_value(_Rp&& __r);
|
|
#endif
|
|
void set_exception(exception_ptr __p);
|
|
|
|
// setting the result with deferred notification
|
|
void set_value_at_thread_exit(const _Rp& __r);
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
void set_value_at_thread_exit(_Rp&& __r);
|
|
#endif
|
|
void set_exception_at_thread_exit(exception_ptr __p);
|
|
};
|
|
|
|
template <class _Rp>
|
|
promise<_Rp>::promise()
|
|
: __state_(new __assoc_state<_Rp>)
|
|
{
|
|
}
|
|
|
|
template <class _Rp>
|
|
template <class _Alloc>
|
|
promise<_Rp>::promise(allocator_arg_t, const _Alloc& __a0)
|
|
{
|
|
typedef __assoc_state_alloc<_Rp, _Alloc> _State;
|
|
typedef typename __allocator_traits_rebind<_Alloc, _State>::type _A2;
|
|
typedef __allocator_destructor<_A2> _D2;
|
|
_A2 __a(__a0);
|
|
unique_ptr<_State, _D2> __hold(__a.allocate(1), _D2(__a, 1));
|
|
::new(static_cast<void*>(_VSTD::addressof(*__hold.get()))) _State(__a0);
|
|
__state_ = _VSTD::addressof(*__hold.release());
|
|
}
|
|
|
|
template <class _Rp>
|
|
promise<_Rp>::~promise()
|
|
{
|
|
if (__state_)
|
|
{
|
|
if (!__state_->__has_value() && __state_->use_count() > 1)
|
|
__state_->set_exception(make_exception_ptr(
|
|
future_error(make_error_code(future_errc::broken_promise))
|
|
));
|
|
__state_->__release_shared();
|
|
}
|
|
}
|
|
|
|
template <class _Rp>
|
|
future<_Rp>
|
|
promise<_Rp>::get_future()
|
|
{
|
|
if (__state_ == nullptr)
|
|
__throw_future_error(future_errc::no_state);
|
|
return future<_Rp>(__state_);
|
|
}
|
|
|
|
template <class _Rp>
|
|
void
|
|
promise<_Rp>::set_value(const _Rp& __r)
|
|
{
|
|
if (__state_ == nullptr)
|
|
__throw_future_error(future_errc::no_state);
|
|
__state_->set_value(__r);
|
|
}
|
|
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
|
|
template <class _Rp>
|
|
void
|
|
promise<_Rp>::set_value(_Rp&& __r)
|
|
{
|
|
if (__state_ == nullptr)
|
|
__throw_future_error(future_errc::no_state);
|
|
__state_->set_value(_VSTD::move(__r));
|
|
}
|
|
|
|
#endif // _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
|
|
template <class _Rp>
|
|
void
|
|
promise<_Rp>::set_exception(exception_ptr __p)
|
|
{
|
|
_LIBCPP_ASSERT( __p != nullptr, "promise::set_exception: received nullptr" );
|
|
if (__state_ == nullptr)
|
|
__throw_future_error(future_errc::no_state);
|
|
__state_->set_exception(__p);
|
|
}
|
|
|
|
template <class _Rp>
|
|
void
|
|
promise<_Rp>::set_value_at_thread_exit(const _Rp& __r)
|
|
{
|
|
if (__state_ == nullptr)
|
|
__throw_future_error(future_errc::no_state);
|
|
__state_->set_value_at_thread_exit(__r);
|
|
}
|
|
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
|
|
template <class _Rp>
|
|
void
|
|
promise<_Rp>::set_value_at_thread_exit(_Rp&& __r)
|
|
{
|
|
if (__state_ == nullptr)
|
|
__throw_future_error(future_errc::no_state);
|
|
__state_->set_value_at_thread_exit(_VSTD::move(__r));
|
|
}
|
|
|
|
#endif // _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
|
|
template <class _Rp>
|
|
void
|
|
promise<_Rp>::set_exception_at_thread_exit(exception_ptr __p)
|
|
{
|
|
_LIBCPP_ASSERT( __p != nullptr, "promise::set_exception_at_thread_exit: received nullptr" );
|
|
if (__state_ == nullptr)
|
|
__throw_future_error(future_errc::no_state);
|
|
__state_->set_exception_at_thread_exit(__p);
|
|
}
|
|
|
|
// promise<R&>
|
|
|
|
template <class _Rp>
|
|
class _LIBCPP_TEMPLATE_VIS _LIBCPP_AVAILABILITY_FUTURE promise<_Rp&>
|
|
{
|
|
__assoc_state<_Rp&>* __state_;
|
|
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
explicit promise(nullptr_t) _NOEXCEPT : __state_(nullptr) {}
|
|
|
|
template <class> friend class packaged_task;
|
|
|
|
public:
|
|
promise();
|
|
template <class _Allocator>
|
|
promise(allocator_arg_t, const _Allocator& __a);
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
promise(promise&& __rhs) _NOEXCEPT
|
|
: __state_(__rhs.__state_) {__rhs.__state_ = nullptr;}
|
|
promise(const promise& __rhs) = delete;
|
|
#else // _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
private:
|
|
promise(const promise& __rhs);
|
|
public:
|
|
#endif // _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
~promise();
|
|
|
|
// assignment
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
promise& operator=(promise&& __rhs) _NOEXCEPT
|
|
{
|
|
promise(std::move(__rhs)).swap(*this);
|
|
return *this;
|
|
}
|
|
promise& operator=(const promise& __rhs) = delete;
|
|
#else // _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
private:
|
|
promise& operator=(const promise& __rhs);
|
|
public:
|
|
#endif // _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
void swap(promise& __rhs) _NOEXCEPT {_VSTD::swap(__state_, __rhs.__state_);}
|
|
|
|
// retrieving the result
|
|
future<_Rp&> get_future();
|
|
|
|
// setting the result
|
|
void set_value(_Rp& __r);
|
|
void set_exception(exception_ptr __p);
|
|
|
|
// setting the result with deferred notification
|
|
void set_value_at_thread_exit(_Rp&);
|
|
void set_exception_at_thread_exit(exception_ptr __p);
|
|
};
|
|
|
|
template <class _Rp>
|
|
promise<_Rp&>::promise()
|
|
: __state_(new __assoc_state<_Rp&>)
|
|
{
|
|
}
|
|
|
|
template <class _Rp>
|
|
template <class _Alloc>
|
|
promise<_Rp&>::promise(allocator_arg_t, const _Alloc& __a0)
|
|
{
|
|
typedef __assoc_state_alloc<_Rp&, _Alloc> _State;
|
|
typedef typename __allocator_traits_rebind<_Alloc, _State>::type _A2;
|
|
typedef __allocator_destructor<_A2> _D2;
|
|
_A2 __a(__a0);
|
|
unique_ptr<_State, _D2> __hold(__a.allocate(1), _D2(__a, 1));
|
|
::new(static_cast<void*>(_VSTD::addressof(*__hold.get()))) _State(__a0);
|
|
__state_ = _VSTD::addressof(*__hold.release());
|
|
}
|
|
|
|
template <class _Rp>
|
|
promise<_Rp&>::~promise()
|
|
{
|
|
if (__state_)
|
|
{
|
|
if (!__state_->__has_value() && __state_->use_count() > 1)
|
|
__state_->set_exception(make_exception_ptr(
|
|
future_error(make_error_code(future_errc::broken_promise))
|
|
));
|
|
__state_->__release_shared();
|
|
}
|
|
}
|
|
|
|
template <class _Rp>
|
|
future<_Rp&>
|
|
promise<_Rp&>::get_future()
|
|
{
|
|
if (__state_ == nullptr)
|
|
__throw_future_error(future_errc::no_state);
|
|
return future<_Rp&>(__state_);
|
|
}
|
|
|
|
template <class _Rp>
|
|
void
|
|
promise<_Rp&>::set_value(_Rp& __r)
|
|
{
|
|
if (__state_ == nullptr)
|
|
__throw_future_error(future_errc::no_state);
|
|
__state_->set_value(__r);
|
|
}
|
|
|
|
template <class _Rp>
|
|
void
|
|
promise<_Rp&>::set_exception(exception_ptr __p)
|
|
{
|
|
_LIBCPP_ASSERT( __p != nullptr, "promise::set_exception: received nullptr" );
|
|
if (__state_ == nullptr)
|
|
__throw_future_error(future_errc::no_state);
|
|
__state_->set_exception(__p);
|
|
}
|
|
|
|
template <class _Rp>
|
|
void
|
|
promise<_Rp&>::set_value_at_thread_exit(_Rp& __r)
|
|
{
|
|
if (__state_ == nullptr)
|
|
__throw_future_error(future_errc::no_state);
|
|
__state_->set_value_at_thread_exit(__r);
|
|
}
|
|
|
|
template <class _Rp>
|
|
void
|
|
promise<_Rp&>::set_exception_at_thread_exit(exception_ptr __p)
|
|
{
|
|
_LIBCPP_ASSERT( __p != nullptr, "promise::set_exception_at_thread_exit: received nullptr" );
|
|
if (__state_ == nullptr)
|
|
__throw_future_error(future_errc::no_state);
|
|
__state_->set_exception_at_thread_exit(__p);
|
|
}
|
|
|
|
// promise<void>
|
|
|
|
template <>
|
|
class _LIBCPP_TYPE_VIS _LIBCPP_AVAILABILITY_FUTURE promise<void>
|
|
{
|
|
__assoc_sub_state* __state_;
|
|
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
explicit promise(nullptr_t) _NOEXCEPT : __state_(nullptr) {}
|
|
|
|
template <class> friend class packaged_task;
|
|
|
|
public:
|
|
promise();
|
|
template <class _Allocator>
|
|
_LIBCPP_METHOD_TEMPLATE_IMPLICIT_INSTANTIATION_VIS
|
|
promise(allocator_arg_t, const _Allocator& __a);
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
promise(promise&& __rhs) _NOEXCEPT
|
|
: __state_(__rhs.__state_) {__rhs.__state_ = nullptr;}
|
|
promise(const promise& __rhs) = delete;
|
|
#else // _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
private:
|
|
promise(const promise& __rhs);
|
|
public:
|
|
#endif // _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
~promise();
|
|
|
|
// assignment
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
promise& operator=(promise&& __rhs) _NOEXCEPT
|
|
{
|
|
promise(std::move(__rhs)).swap(*this);
|
|
return *this;
|
|
}
|
|
promise& operator=(const promise& __rhs) = delete;
|
|
#else // _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
private:
|
|
promise& operator=(const promise& __rhs);
|
|
public:
|
|
#endif // _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
void swap(promise& __rhs) _NOEXCEPT {_VSTD::swap(__state_, __rhs.__state_);}
|
|
|
|
// retrieving the result
|
|
future<void> get_future();
|
|
|
|
// setting the result
|
|
void set_value();
|
|
void set_exception(exception_ptr __p);
|
|
|
|
// setting the result with deferred notification
|
|
void set_value_at_thread_exit();
|
|
void set_exception_at_thread_exit(exception_ptr __p);
|
|
};
|
|
|
|
template <class _Alloc>
|
|
promise<void>::promise(allocator_arg_t, const _Alloc& __a0)
|
|
{
|
|
typedef __assoc_sub_state_alloc<_Alloc> _State;
|
|
typedef typename __allocator_traits_rebind<_Alloc, _State>::type _A2;
|
|
typedef __allocator_destructor<_A2> _D2;
|
|
_A2 __a(__a0);
|
|
unique_ptr<_State, _D2> __hold(__a.allocate(1), _D2(__a, 1));
|
|
::new(static_cast<void*>(_VSTD::addressof(*__hold.get()))) _State(__a0);
|
|
__state_ = _VSTD::addressof(*__hold.release());
|
|
}
|
|
|
|
template <class _Rp>
|
|
inline _LIBCPP_INLINE_VISIBILITY
|
|
void
|
|
swap(promise<_Rp>& __x, promise<_Rp>& __y) _NOEXCEPT
|
|
{
|
|
__x.swap(__y);
|
|
}
|
|
|
|
template <class _Rp, class _Alloc>
|
|
struct _LIBCPP_TEMPLATE_VIS uses_allocator<promise<_Rp>, _Alloc>
|
|
: public true_type {};
|
|
|
|
#ifndef _LIBCPP_HAS_NO_VARIADICS
|
|
|
|
// packaged_task
|
|
|
|
template<class _Fp> class __packaged_task_base;
|
|
|
|
template<class _Rp, class ..._ArgTypes>
|
|
class _LIBCPP_AVAILABILITY_FUTURE __packaged_task_base<_Rp(_ArgTypes...)>
|
|
{
|
|
__packaged_task_base(const __packaged_task_base&);
|
|
__packaged_task_base& operator=(const __packaged_task_base&);
|
|
public:
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
__packaged_task_base() {}
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
virtual ~__packaged_task_base() {}
|
|
virtual void __move_to(__packaged_task_base*) _NOEXCEPT = 0;
|
|
virtual void destroy() = 0;
|
|
virtual void destroy_deallocate() = 0;
|
|
virtual _Rp operator()(_ArgTypes&& ...) = 0;
|
|
};
|
|
|
|
template<class _FD, class _Alloc, class _FB> class __packaged_task_func;
|
|
|
|
template<class _Fp, class _Alloc, class _Rp, class ..._ArgTypes>
|
|
class _LIBCPP_AVAILABILITY_FUTURE __packaged_task_func<_Fp, _Alloc, _Rp(_ArgTypes...)>
|
|
: public __packaged_task_base<_Rp(_ArgTypes...)>
|
|
{
|
|
__compressed_pair<_Fp, _Alloc> __f_;
|
|
public:
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
explicit __packaged_task_func(const _Fp& __f) : __f_(__f) {}
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
explicit __packaged_task_func(_Fp&& __f) : __f_(_VSTD::move(__f)) {}
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
__packaged_task_func(const _Fp& __f, const _Alloc& __a)
|
|
: __f_(__f, __a) {}
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
__packaged_task_func(_Fp&& __f, const _Alloc& __a)
|
|
: __f_(_VSTD::move(__f), __a) {}
|
|
virtual void __move_to(__packaged_task_base<_Rp(_ArgTypes...)>*) _NOEXCEPT;
|
|
virtual void destroy();
|
|
virtual void destroy_deallocate();
|
|
virtual _Rp operator()(_ArgTypes&& ... __args);
|
|
};
|
|
|
|
template<class _Fp, class _Alloc, class _Rp, class ..._ArgTypes>
|
|
void
|
|
__packaged_task_func<_Fp, _Alloc, _Rp(_ArgTypes...)>::__move_to(
|
|
__packaged_task_base<_Rp(_ArgTypes...)>* __p) _NOEXCEPT
|
|
{
|
|
::new (__p) __packaged_task_func(_VSTD::move(__f_.first()), _VSTD::move(__f_.second()));
|
|
}
|
|
|
|
template<class _Fp, class _Alloc, class _Rp, class ..._ArgTypes>
|
|
void
|
|
__packaged_task_func<_Fp, _Alloc, _Rp(_ArgTypes...)>::destroy()
|
|
{
|
|
__f_.~__compressed_pair<_Fp, _Alloc>();
|
|
}
|
|
|
|
template<class _Fp, class _Alloc, class _Rp, class ..._ArgTypes>
|
|
void
|
|
__packaged_task_func<_Fp, _Alloc, _Rp(_ArgTypes...)>::destroy_deallocate()
|
|
{
|
|
typedef typename __allocator_traits_rebind<_Alloc, __packaged_task_func>::type _Ap;
|
|
typedef allocator_traits<_Ap> _ATraits;
|
|
typedef pointer_traits<typename _ATraits::pointer> _PTraits;
|
|
_Ap __a(__f_.second());
|
|
__f_.~__compressed_pair<_Fp, _Alloc>();
|
|
__a.deallocate(_PTraits::pointer_to(*this), 1);
|
|
}
|
|
|
|
template<class _Fp, class _Alloc, class _Rp, class ..._ArgTypes>
|
|
_Rp
|
|
__packaged_task_func<_Fp, _Alloc, _Rp(_ArgTypes...)>::operator()(_ArgTypes&& ... __arg)
|
|
{
|
|
return __invoke(__f_.first(), _VSTD::forward<_ArgTypes>(__arg)...);
|
|
}
|
|
|
|
template <class _Callable> class __packaged_task_function;
|
|
|
|
template<class _Rp, class ..._ArgTypes>
|
|
class _LIBCPP_AVAILABILITY_FUTURE __packaged_task_function<_Rp(_ArgTypes...)>
|
|
{
|
|
typedef __packaged_task_base<_Rp(_ArgTypes...)> __base;
|
|
typename aligned_storage<3*sizeof(void*)>::type __buf_;
|
|
__base* __f_;
|
|
|
|
public:
|
|
typedef _Rp result_type;
|
|
|
|
// construct/copy/destroy:
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
__packaged_task_function() _NOEXCEPT : __f_(nullptr) {}
|
|
template<class _Fp>
|
|
__packaged_task_function(_Fp&& __f);
|
|
template<class _Fp, class _Alloc>
|
|
__packaged_task_function(allocator_arg_t, const _Alloc& __a, _Fp&& __f);
|
|
|
|
__packaged_task_function(__packaged_task_function&&) _NOEXCEPT;
|
|
__packaged_task_function& operator=(__packaged_task_function&&) _NOEXCEPT;
|
|
|
|
__packaged_task_function(const __packaged_task_function&) = delete;
|
|
__packaged_task_function& operator=(const __packaged_task_function&) = delete;
|
|
|
|
~__packaged_task_function();
|
|
|
|
void swap(__packaged_task_function&) _NOEXCEPT;
|
|
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
_Rp operator()(_ArgTypes...) const;
|
|
};
|
|
|
|
template<class _Rp, class ..._ArgTypes>
|
|
__packaged_task_function<_Rp(_ArgTypes...)>::__packaged_task_function(__packaged_task_function&& __f) _NOEXCEPT
|
|
{
|
|
if (__f.__f_ == nullptr)
|
|
__f_ = nullptr;
|
|
else if (__f.__f_ == (__base*)&__f.__buf_)
|
|
{
|
|
__f_ = (__base*)&__buf_;
|
|
__f.__f_->__move_to(__f_);
|
|
}
|
|
else
|
|
{
|
|
__f_ = __f.__f_;
|
|
__f.__f_ = nullptr;
|
|
}
|
|
}
|
|
|
|
template<class _Rp, class ..._ArgTypes>
|
|
template <class _Fp>
|
|
__packaged_task_function<_Rp(_ArgTypes...)>::__packaged_task_function(_Fp&& __f)
|
|
: __f_(nullptr)
|
|
{
|
|
typedef typename remove_reference<typename decay<_Fp>::type>::type _FR;
|
|
typedef __packaged_task_func<_FR, allocator<_FR>, _Rp(_ArgTypes...)> _FF;
|
|
if (sizeof(_FF) <= sizeof(__buf_))
|
|
{
|
|
__f_ = (__base*)&__buf_;
|
|
::new (__f_) _FF(_VSTD::forward<_Fp>(__f));
|
|
}
|
|
else
|
|
{
|
|
typedef allocator<_FF> _Ap;
|
|
_Ap __a;
|
|
typedef __allocator_destructor<_Ap> _Dp;
|
|
unique_ptr<__base, _Dp> __hold(__a.allocate(1), _Dp(__a, 1));
|
|
::new (__hold.get()) _FF(_VSTD::forward<_Fp>(__f), allocator<_FR>(__a));
|
|
__f_ = __hold.release();
|
|
}
|
|
}
|
|
|
|
template<class _Rp, class ..._ArgTypes>
|
|
template <class _Fp, class _Alloc>
|
|
__packaged_task_function<_Rp(_ArgTypes...)>::__packaged_task_function(
|
|
allocator_arg_t, const _Alloc& __a0, _Fp&& __f)
|
|
: __f_(nullptr)
|
|
{
|
|
typedef typename remove_reference<typename decay<_Fp>::type>::type _FR;
|
|
typedef __packaged_task_func<_FR, _Alloc, _Rp(_ArgTypes...)> _FF;
|
|
if (sizeof(_FF) <= sizeof(__buf_))
|
|
{
|
|
__f_ = (__base*)&__buf_;
|
|
::new (__f_) _FF(_VSTD::forward<_Fp>(__f));
|
|
}
|
|
else
|
|
{
|
|
typedef typename __allocator_traits_rebind<_Alloc, _FF>::type _Ap;
|
|
_Ap __a(__a0);
|
|
typedef __allocator_destructor<_Ap> _Dp;
|
|
unique_ptr<__base, _Dp> __hold(__a.allocate(1), _Dp(__a, 1));
|
|
::new (static_cast<void*>(_VSTD::addressof(*__hold.get())))
|
|
_FF(_VSTD::forward<_Fp>(__f), _Alloc(__a));
|
|
__f_ = _VSTD::addressof(*__hold.release());
|
|
}
|
|
}
|
|
|
|
template<class _Rp, class ..._ArgTypes>
|
|
__packaged_task_function<_Rp(_ArgTypes...)>&
|
|
__packaged_task_function<_Rp(_ArgTypes...)>::operator=(__packaged_task_function&& __f) _NOEXCEPT
|
|
{
|
|
if (__f_ == (__base*)&__buf_)
|
|
__f_->destroy();
|
|
else if (__f_)
|
|
__f_->destroy_deallocate();
|
|
__f_ = nullptr;
|
|
if (__f.__f_ == nullptr)
|
|
__f_ = nullptr;
|
|
else if (__f.__f_ == (__base*)&__f.__buf_)
|
|
{
|
|
__f_ = (__base*)&__buf_;
|
|
__f.__f_->__move_to(__f_);
|
|
}
|
|
else
|
|
{
|
|
__f_ = __f.__f_;
|
|
__f.__f_ = nullptr;
|
|
}
|
|
return *this;
|
|
}
|
|
|
|
template<class _Rp, class ..._ArgTypes>
|
|
__packaged_task_function<_Rp(_ArgTypes...)>::~__packaged_task_function()
|
|
{
|
|
if (__f_ == (__base*)&__buf_)
|
|
__f_->destroy();
|
|
else if (__f_)
|
|
__f_->destroy_deallocate();
|
|
}
|
|
|
|
template<class _Rp, class ..._ArgTypes>
|
|
void
|
|
__packaged_task_function<_Rp(_ArgTypes...)>::swap(__packaged_task_function& __f) _NOEXCEPT
|
|
{
|
|
if (__f_ == (__base*)&__buf_ && __f.__f_ == (__base*)&__f.__buf_)
|
|
{
|
|
typename aligned_storage<sizeof(__buf_)>::type __tempbuf;
|
|
__base* __t = (__base*)&__tempbuf;
|
|
__f_->__move_to(__t);
|
|
__f_->destroy();
|
|
__f_ = nullptr;
|
|
__f.__f_->__move_to((__base*)&__buf_);
|
|
__f.__f_->destroy();
|
|
__f.__f_ = nullptr;
|
|
__f_ = (__base*)&__buf_;
|
|
__t->__move_to((__base*)&__f.__buf_);
|
|
__t->destroy();
|
|
__f.__f_ = (__base*)&__f.__buf_;
|
|
}
|
|
else if (__f_ == (__base*)&__buf_)
|
|
{
|
|
__f_->__move_to((__base*)&__f.__buf_);
|
|
__f_->destroy();
|
|
__f_ = __f.__f_;
|
|
__f.__f_ = (__base*)&__f.__buf_;
|
|
}
|
|
else if (__f.__f_ == (__base*)&__f.__buf_)
|
|
{
|
|
__f.__f_->__move_to((__base*)&__buf_);
|
|
__f.__f_->destroy();
|
|
__f.__f_ = __f_;
|
|
__f_ = (__base*)&__buf_;
|
|
}
|
|
else
|
|
_VSTD::swap(__f_, __f.__f_);
|
|
}
|
|
|
|
template<class _Rp, class ..._ArgTypes>
|
|
inline
|
|
_Rp
|
|
__packaged_task_function<_Rp(_ArgTypes...)>::operator()(_ArgTypes... __arg) const
|
|
{
|
|
return (*__f_)(_VSTD::forward<_ArgTypes>(__arg)...);
|
|
}
|
|
|
|
template<class _Rp, class ..._ArgTypes>
|
|
class _LIBCPP_TEMPLATE_VIS _LIBCPP_AVAILABILITY_FUTURE packaged_task<_Rp(_ArgTypes...)>
|
|
{
|
|
public:
|
|
typedef _Rp result_type; // extension
|
|
|
|
private:
|
|
__packaged_task_function<result_type(_ArgTypes...)> __f_;
|
|
promise<result_type> __p_;
|
|
|
|
public:
|
|
// construction and destruction
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
packaged_task() _NOEXCEPT : __p_(nullptr) {}
|
|
template <class _Fp,
|
|
class = typename enable_if
|
|
<
|
|
!is_same<
|
|
typename decay<_Fp>::type,
|
|
packaged_task
|
|
>::value
|
|
>::type
|
|
>
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
explicit packaged_task(_Fp&& __f) : __f_(_VSTD::forward<_Fp>(__f)) {}
|
|
template <class _Fp, class _Allocator,
|
|
class = typename enable_if
|
|
<
|
|
!is_same<
|
|
typename decay<_Fp>::type,
|
|
packaged_task
|
|
>::value
|
|
>::type
|
|
>
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
packaged_task(allocator_arg_t, const _Allocator& __a, _Fp&& __f)
|
|
: __f_(allocator_arg, __a, _VSTD::forward<_Fp>(__f)),
|
|
__p_(allocator_arg, __a) {}
|
|
// ~packaged_task() = default;
|
|
|
|
// no copy
|
|
packaged_task(const packaged_task&) = delete;
|
|
packaged_task& operator=(const packaged_task&) = delete;
|
|
|
|
// move support
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
packaged_task(packaged_task&& __other) _NOEXCEPT
|
|
: __f_(_VSTD::move(__other.__f_)), __p_(_VSTD::move(__other.__p_)) {}
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
packaged_task& operator=(packaged_task&& __other) _NOEXCEPT
|
|
{
|
|
__f_ = _VSTD::move(__other.__f_);
|
|
__p_ = _VSTD::move(__other.__p_);
|
|
return *this;
|
|
}
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
void swap(packaged_task& __other) _NOEXCEPT
|
|
{
|
|
__f_.swap(__other.__f_);
|
|
__p_.swap(__other.__p_);
|
|
}
|
|
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
bool valid() const _NOEXCEPT {return __p_.__state_ != nullptr;}
|
|
|
|
// result retrieval
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
future<result_type> get_future() {return __p_.get_future();}
|
|
|
|
// execution
|
|
void operator()(_ArgTypes... __args);
|
|
void make_ready_at_thread_exit(_ArgTypes... __args);
|
|
|
|
void reset();
|
|
};
|
|
|
|
template<class _Rp, class ..._ArgTypes>
|
|
void
|
|
packaged_task<_Rp(_ArgTypes...)>::operator()(_ArgTypes... __args)
|
|
{
|
|
if (__p_.__state_ == nullptr)
|
|
__throw_future_error(future_errc::no_state);
|
|
if (__p_.__state_->__has_value())
|
|
__throw_future_error(future_errc::promise_already_satisfied);
|
|
#ifndef _LIBCPP_NO_EXCEPTIONS
|
|
try
|
|
{
|
|
#endif // _LIBCPP_NO_EXCEPTIONS
|
|
__p_.set_value(__f_(_VSTD::forward<_ArgTypes>(__args)...));
|
|
#ifndef _LIBCPP_NO_EXCEPTIONS
|
|
}
|
|
catch (...)
|
|
{
|
|
__p_.set_exception(current_exception());
|
|
}
|
|
#endif // _LIBCPP_NO_EXCEPTIONS
|
|
}
|
|
|
|
template<class _Rp, class ..._ArgTypes>
|
|
void
|
|
packaged_task<_Rp(_ArgTypes...)>::make_ready_at_thread_exit(_ArgTypes... __args)
|
|
{
|
|
if (__p_.__state_ == nullptr)
|
|
__throw_future_error(future_errc::no_state);
|
|
if (__p_.__state_->__has_value())
|
|
__throw_future_error(future_errc::promise_already_satisfied);
|
|
#ifndef _LIBCPP_NO_EXCEPTIONS
|
|
try
|
|
{
|
|
#endif // _LIBCPP_NO_EXCEPTIONS
|
|
__p_.set_value_at_thread_exit(__f_(_VSTD::forward<_ArgTypes>(__args)...));
|
|
#ifndef _LIBCPP_NO_EXCEPTIONS
|
|
}
|
|
catch (...)
|
|
{
|
|
__p_.set_exception_at_thread_exit(current_exception());
|
|
}
|
|
#endif // _LIBCPP_NO_EXCEPTIONS
|
|
}
|
|
|
|
template<class _Rp, class ..._ArgTypes>
|
|
void
|
|
packaged_task<_Rp(_ArgTypes...)>::reset()
|
|
{
|
|
if (!valid())
|
|
__throw_future_error(future_errc::no_state);
|
|
__p_ = promise<result_type>();
|
|
}
|
|
|
|
template<class ..._ArgTypes>
|
|
class _LIBCPP_TEMPLATE_VIS _LIBCPP_AVAILABILITY_FUTURE packaged_task<void(_ArgTypes...)>
|
|
{
|
|
public:
|
|
typedef void result_type; // extension
|
|
|
|
private:
|
|
__packaged_task_function<result_type(_ArgTypes...)> __f_;
|
|
promise<result_type> __p_;
|
|
|
|
public:
|
|
// construction and destruction
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
packaged_task() _NOEXCEPT : __p_(nullptr) {}
|
|
template <class _Fp,
|
|
class = typename enable_if
|
|
<
|
|
!is_same<
|
|
typename decay<_Fp>::type,
|
|
packaged_task
|
|
>::value
|
|
>::type
|
|
>
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
explicit packaged_task(_Fp&& __f) : __f_(_VSTD::forward<_Fp>(__f)) {}
|
|
template <class _Fp, class _Allocator,
|
|
class = typename enable_if
|
|
<
|
|
!is_same<
|
|
typename decay<_Fp>::type,
|
|
packaged_task
|
|
>::value
|
|
>::type
|
|
>
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
packaged_task(allocator_arg_t, const _Allocator& __a, _Fp&& __f)
|
|
: __f_(allocator_arg, __a, _VSTD::forward<_Fp>(__f)),
|
|
__p_(allocator_arg, __a) {}
|
|
// ~packaged_task() = default;
|
|
|
|
// no copy
|
|
packaged_task(const packaged_task&) = delete;
|
|
packaged_task& operator=(const packaged_task&) = delete;
|
|
|
|
// move support
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
packaged_task(packaged_task&& __other) _NOEXCEPT
|
|
: __f_(_VSTD::move(__other.__f_)), __p_(_VSTD::move(__other.__p_)) {}
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
packaged_task& operator=(packaged_task&& __other) _NOEXCEPT
|
|
{
|
|
__f_ = _VSTD::move(__other.__f_);
|
|
__p_ = _VSTD::move(__other.__p_);
|
|
return *this;
|
|
}
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
void swap(packaged_task& __other) _NOEXCEPT
|
|
{
|
|
__f_.swap(__other.__f_);
|
|
__p_.swap(__other.__p_);
|
|
}
|
|
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
bool valid() const _NOEXCEPT {return __p_.__state_ != nullptr;}
|
|
|
|
// result retrieval
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
future<result_type> get_future() {return __p_.get_future();}
|
|
|
|
// execution
|
|
void operator()(_ArgTypes... __args);
|
|
void make_ready_at_thread_exit(_ArgTypes... __args);
|
|
|
|
void reset();
|
|
};
|
|
|
|
template<class ..._ArgTypes>
|
|
void
|
|
packaged_task<void(_ArgTypes...)>::operator()(_ArgTypes... __args)
|
|
{
|
|
if (__p_.__state_ == nullptr)
|
|
__throw_future_error(future_errc::no_state);
|
|
if (__p_.__state_->__has_value())
|
|
__throw_future_error(future_errc::promise_already_satisfied);
|
|
#ifndef _LIBCPP_NO_EXCEPTIONS
|
|
try
|
|
{
|
|
#endif // _LIBCPP_NO_EXCEPTIONS
|
|
__f_(_VSTD::forward<_ArgTypes>(__args)...);
|
|
__p_.set_value();
|
|
#ifndef _LIBCPP_NO_EXCEPTIONS
|
|
}
|
|
catch (...)
|
|
{
|
|
__p_.set_exception(current_exception());
|
|
}
|
|
#endif // _LIBCPP_NO_EXCEPTIONS
|
|
}
|
|
|
|
template<class ..._ArgTypes>
|
|
void
|
|
packaged_task<void(_ArgTypes...)>::make_ready_at_thread_exit(_ArgTypes... __args)
|
|
{
|
|
if (__p_.__state_ == nullptr)
|
|
__throw_future_error(future_errc::no_state);
|
|
if (__p_.__state_->__has_value())
|
|
__throw_future_error(future_errc::promise_already_satisfied);
|
|
#ifndef _LIBCPP_NO_EXCEPTIONS
|
|
try
|
|
{
|
|
#endif // _LIBCPP_NO_EXCEPTIONS
|
|
__f_(_VSTD::forward<_ArgTypes>(__args)...);
|
|
__p_.set_value_at_thread_exit();
|
|
#ifndef _LIBCPP_NO_EXCEPTIONS
|
|
}
|
|
catch (...)
|
|
{
|
|
__p_.set_exception_at_thread_exit(current_exception());
|
|
}
|
|
#endif // _LIBCPP_NO_EXCEPTIONS
|
|
}
|
|
|
|
template<class ..._ArgTypes>
|
|
void
|
|
packaged_task<void(_ArgTypes...)>::reset()
|
|
{
|
|
if (!valid())
|
|
__throw_future_error(future_errc::no_state);
|
|
__p_ = promise<result_type>();
|
|
}
|
|
|
|
template <class _Callable>
|
|
inline _LIBCPP_INLINE_VISIBILITY
|
|
void
|
|
swap(packaged_task<_Callable>& __x, packaged_task<_Callable>& __y) _NOEXCEPT
|
|
{
|
|
__x.swap(__y);
|
|
}
|
|
|
|
template <class _Callable, class _Alloc>
|
|
struct _LIBCPP_TEMPLATE_VIS uses_allocator<packaged_task<_Callable>, _Alloc>
|
|
: public true_type {};
|
|
|
|
template <class _Rp, class _Fp>
|
|
future<_Rp>
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
__make_deferred_assoc_state(_Fp&& __f)
|
|
#else
|
|
__make_deferred_assoc_state(_Fp __f)
|
|
#endif
|
|
{
|
|
unique_ptr<__deferred_assoc_state<_Rp, _Fp>, __release_shared_count>
|
|
__h(new __deferred_assoc_state<_Rp, _Fp>(_VSTD::forward<_Fp>(__f)));
|
|
return future<_Rp>(__h.get());
|
|
}
|
|
|
|
template <class _Rp, class _Fp>
|
|
future<_Rp>
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
__make_async_assoc_state(_Fp&& __f)
|
|
#else
|
|
__make_async_assoc_state(_Fp __f)
|
|
#endif
|
|
{
|
|
unique_ptr<__async_assoc_state<_Rp, _Fp>, __release_shared_count>
|
|
__h(new __async_assoc_state<_Rp, _Fp>(_VSTD::forward<_Fp>(__f)));
|
|
_VSTD::thread(&__async_assoc_state<_Rp, _Fp>::__execute, __h.get()).detach();
|
|
return future<_Rp>(__h.get());
|
|
}
|
|
|
|
template <class _Fp, class... _Args>
|
|
class __async_func
|
|
{
|
|
tuple<_Fp, _Args...> __f_;
|
|
|
|
public:
|
|
typedef typename __invoke_of<_Fp, _Args...>::type _Rp;
|
|
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
explicit __async_func(_Fp&& __f, _Args&&... __args)
|
|
: __f_(_VSTD::move(__f), _VSTD::move(__args)...) {}
|
|
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
__async_func(__async_func&& __f) : __f_(_VSTD::move(__f.__f_)) {}
|
|
|
|
_Rp operator()()
|
|
{
|
|
typedef typename __make_tuple_indices<1+sizeof...(_Args), 1>::type _Index;
|
|
return __execute(_Index());
|
|
}
|
|
private:
|
|
template <size_t ..._Indices>
|
|
_Rp
|
|
__execute(__tuple_indices<_Indices...>)
|
|
{
|
|
return __invoke(_VSTD::move(_VSTD::get<0>(__f_)), _VSTD::move(_VSTD::get<_Indices>(__f_))...);
|
|
}
|
|
};
|
|
|
|
inline _LIBCPP_INLINE_VISIBILITY bool __does_policy_contain(launch __policy, launch __value )
|
|
{ return (int(__policy) & int(__value)) != 0; }
|
|
|
|
template <class _Fp, class... _Args>
|
|
future<typename __invoke_of<typename decay<_Fp>::type, typename decay<_Args>::type...>::type>
|
|
async(launch __policy, _Fp&& __f, _Args&&... __args)
|
|
{
|
|
typedef __async_func<typename decay<_Fp>::type, typename decay<_Args>::type...> _BF;
|
|
typedef typename _BF::_Rp _Rp;
|
|
|
|
#ifndef _LIBCPP_NO_EXCEPTIONS
|
|
try
|
|
{
|
|
#endif
|
|
if (__does_policy_contain(__policy, launch::async))
|
|
return _VSTD::__make_async_assoc_state<_Rp>(_BF(__decay_copy(_VSTD::forward<_Fp>(__f)),
|
|
__decay_copy(_VSTD::forward<_Args>(__args))...));
|
|
#ifndef _LIBCPP_NO_EXCEPTIONS
|
|
}
|
|
catch ( ... ) { if (__policy == launch::async) throw ; }
|
|
#endif
|
|
|
|
if (__does_policy_contain(__policy, launch::deferred))
|
|
return _VSTD::__make_deferred_assoc_state<_Rp>(_BF(__decay_copy(_VSTD::forward<_Fp>(__f)),
|
|
__decay_copy(_VSTD::forward<_Args>(__args))...));
|
|
return future<_Rp>{};
|
|
}
|
|
|
|
template <class _Fp, class... _Args>
|
|
inline _LIBCPP_INLINE_VISIBILITY
|
|
future<typename __invoke_of<typename decay<_Fp>::type, typename decay<_Args>::type...>::type>
|
|
async(_Fp&& __f, _Args&&... __args)
|
|
{
|
|
return _VSTD::async(launch::any, _VSTD::forward<_Fp>(__f),
|
|
_VSTD::forward<_Args>(__args)...);
|
|
}
|
|
|
|
#endif // _LIBCPP_HAS_NO_VARIADICS
|
|
|
|
// shared_future
|
|
|
|
template <class _Rp>
|
|
class _LIBCPP_TEMPLATE_VIS shared_future
|
|
{
|
|
__assoc_state<_Rp>* __state_;
|
|
|
|
public:
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
shared_future() _NOEXCEPT : __state_(nullptr) {}
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
shared_future(const shared_future& __rhs) _NOEXCEPT : __state_(__rhs.__state_)
|
|
{if (__state_) __state_->__add_shared();}
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
shared_future(future<_Rp>&& __f) _NOEXCEPT : __state_(__f.__state_)
|
|
{__f.__state_ = nullptr;}
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
shared_future(shared_future&& __rhs) _NOEXCEPT : __state_(__rhs.__state_)
|
|
{__rhs.__state_ = nullptr;}
|
|
#endif // _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
~shared_future();
|
|
shared_future& operator=(const shared_future& __rhs) _NOEXCEPT;
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
shared_future& operator=(shared_future&& __rhs) _NOEXCEPT
|
|
{
|
|
shared_future(std::move(__rhs)).swap(*this);
|
|
return *this;
|
|
}
|
|
#endif // _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
|
|
// retrieving the value
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
const _Rp& get() const {return __state_->copy();}
|
|
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
void swap(shared_future& __rhs) _NOEXCEPT {_VSTD::swap(__state_, __rhs.__state_);}
|
|
|
|
// functions to check state
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
bool valid() const _NOEXCEPT {return __state_ != nullptr;}
|
|
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
void wait() const {__state_->wait();}
|
|
template <class _Rep, class _Period>
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
future_status
|
|
wait_for(const chrono::duration<_Rep, _Period>& __rel_time) const
|
|
{return __state_->wait_for(__rel_time);}
|
|
template <class _Clock, class _Duration>
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
future_status
|
|
wait_until(const chrono::time_point<_Clock, _Duration>& __abs_time) const
|
|
{return __state_->wait_until(__abs_time);}
|
|
};
|
|
|
|
template <class _Rp>
|
|
shared_future<_Rp>::~shared_future()
|
|
{
|
|
if (__state_)
|
|
__state_->__release_shared();
|
|
}
|
|
|
|
template <class _Rp>
|
|
shared_future<_Rp>&
|
|
shared_future<_Rp>::operator=(const shared_future& __rhs) _NOEXCEPT
|
|
{
|
|
if (__rhs.__state_)
|
|
__rhs.__state_->__add_shared();
|
|
if (__state_)
|
|
__state_->__release_shared();
|
|
__state_ = __rhs.__state_;
|
|
return *this;
|
|
}
|
|
|
|
template <class _Rp>
|
|
class _LIBCPP_TEMPLATE_VIS shared_future<_Rp&>
|
|
{
|
|
__assoc_state<_Rp&>* __state_;
|
|
|
|
public:
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
shared_future() _NOEXCEPT : __state_(nullptr) {}
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
shared_future(const shared_future& __rhs) : __state_(__rhs.__state_)
|
|
{if (__state_) __state_->__add_shared();}
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
shared_future(future<_Rp&>&& __f) _NOEXCEPT : __state_(__f.__state_)
|
|
{__f.__state_ = nullptr;}
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
shared_future(shared_future&& __rhs) _NOEXCEPT : __state_(__rhs.__state_)
|
|
{__rhs.__state_ = nullptr;}
|
|
#endif // _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
~shared_future();
|
|
shared_future& operator=(const shared_future& __rhs);
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
shared_future& operator=(shared_future&& __rhs) _NOEXCEPT
|
|
{
|
|
shared_future(std::move(__rhs)).swap(*this);
|
|
return *this;
|
|
}
|
|
#endif // _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
|
|
// retrieving the value
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
_Rp& get() const {return __state_->copy();}
|
|
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
void swap(shared_future& __rhs) _NOEXCEPT {_VSTD::swap(__state_, __rhs.__state_);}
|
|
|
|
// functions to check state
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
bool valid() const _NOEXCEPT {return __state_ != nullptr;}
|
|
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
void wait() const {__state_->wait();}
|
|
template <class _Rep, class _Period>
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
future_status
|
|
wait_for(const chrono::duration<_Rep, _Period>& __rel_time) const
|
|
{return __state_->wait_for(__rel_time);}
|
|
template <class _Clock, class _Duration>
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
future_status
|
|
wait_until(const chrono::time_point<_Clock, _Duration>& __abs_time) const
|
|
{return __state_->wait_until(__abs_time);}
|
|
};
|
|
|
|
template <class _Rp>
|
|
shared_future<_Rp&>::~shared_future()
|
|
{
|
|
if (__state_)
|
|
__state_->__release_shared();
|
|
}
|
|
|
|
template <class _Rp>
|
|
shared_future<_Rp&>&
|
|
shared_future<_Rp&>::operator=(const shared_future& __rhs)
|
|
{
|
|
if (__rhs.__state_)
|
|
__rhs.__state_->__add_shared();
|
|
if (__state_)
|
|
__state_->__release_shared();
|
|
__state_ = __rhs.__state_;
|
|
return *this;
|
|
}
|
|
|
|
template <>
|
|
class _LIBCPP_TYPE_VIS _LIBCPP_AVAILABILITY_FUTURE shared_future<void>
|
|
{
|
|
__assoc_sub_state* __state_;
|
|
|
|
public:
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
shared_future() _NOEXCEPT : __state_(nullptr) {}
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
shared_future(const shared_future& __rhs) : __state_(__rhs.__state_)
|
|
{if (__state_) __state_->__add_shared();}
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
shared_future(future<void>&& __f) _NOEXCEPT : __state_(__f.__state_)
|
|
{__f.__state_ = nullptr;}
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
shared_future(shared_future&& __rhs) _NOEXCEPT : __state_(__rhs.__state_)
|
|
{__rhs.__state_ = nullptr;}
|
|
#endif // _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
~shared_future();
|
|
shared_future& operator=(const shared_future& __rhs);
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
shared_future& operator=(shared_future&& __rhs) _NOEXCEPT
|
|
{
|
|
shared_future(std::move(__rhs)).swap(*this);
|
|
return *this;
|
|
}
|
|
#endif // _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
|
|
// retrieving the value
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
void get() const {__state_->copy();}
|
|
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
void swap(shared_future& __rhs) _NOEXCEPT {_VSTD::swap(__state_, __rhs.__state_);}
|
|
|
|
// functions to check state
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
bool valid() const _NOEXCEPT {return __state_ != nullptr;}
|
|
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
void wait() const {__state_->wait();}
|
|
template <class _Rep, class _Period>
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
future_status
|
|
wait_for(const chrono::duration<_Rep, _Period>& __rel_time) const
|
|
{return __state_->wait_for(__rel_time);}
|
|
template <class _Clock, class _Duration>
|
|
_LIBCPP_INLINE_VISIBILITY
|
|
future_status
|
|
wait_until(const chrono::time_point<_Clock, _Duration>& __abs_time) const
|
|
{return __state_->wait_until(__abs_time);}
|
|
};
|
|
|
|
template <class _Rp>
|
|
inline _LIBCPP_INLINE_VISIBILITY
|
|
void
|
|
swap(shared_future<_Rp>& __x, shared_future<_Rp>& __y) _NOEXCEPT
|
|
{
|
|
__x.swap(__y);
|
|
}
|
|
|
|
template <class _Rp>
|
|
inline
|
|
shared_future<_Rp>
|
|
future<_Rp>::share() _NOEXCEPT
|
|
{
|
|
return shared_future<_Rp>(_VSTD::move(*this));
|
|
}
|
|
|
|
template <class _Rp>
|
|
inline
|
|
shared_future<_Rp&>
|
|
future<_Rp&>::share() _NOEXCEPT
|
|
{
|
|
return shared_future<_Rp&>(_VSTD::move(*this));
|
|
}
|
|
|
|
#ifndef _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
|
|
inline
|
|
shared_future<void>
|
|
future<void>::share() _NOEXCEPT
|
|
{
|
|
return shared_future<void>(_VSTD::move(*this));
|
|
}
|
|
|
|
#endif // _LIBCPP_HAS_NO_RVALUE_REFERENCES
|
|
|
|
_LIBCPP_END_NAMESPACE_STD
|
|
|
|
#endif // !_LIBCPP_HAS_NO_THREADS
|
|
|
|
#endif // _LIBCPP_FUTURE
|