mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-04-28 04:06:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

short-circuit then() if future is ready

Browse Source
This commit is contained in:
Avi Kivity
2014-08-15 01:09:54 +03:00
parent cec55519fe
commit c539cdcbee
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
reactor.hh
View File

@@ -213,6 +213,9 @@ public:
void then(Func&& func,
std::enable_if_t<std::is_same<std::result_of_t<Func(T&&)>, void>::value, void*> = nullptr) {
auto state = _state;
if (state->available()) {
return func(std::move(_state->get()));
}
state->schedule([fut = std::move(*this), func = std::forward<Func>(func)] () mutable {
func(fut.get());
});
@@ -223,6 +226,9 @@ public:
then(Func&& func,
std::enable_if_t<is_future<std::result_of_t<Func(T&&)>>::value, void*> = nullptr) {
auto state = _state;
if (state->available()) {
return func(std::move(_state->get()));
}
using U = typename std::result_of_t<Func(T&&)>::value_type;
promise<U> pr;
auto next_fut = pr.get_future();