| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
1 parent ae238f5 commit 5e736fe
2 files changed
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -75,7 +75,7 @@ void transform_reduce() { | |||
| 75 | 75 | tf::Taskflow tf; | |
| 76 | 76 | auto tmin = std::numeric_limits<int>::max(); | |
| 77 | 77 | tf.transform_reduce(data.begin(), data.end(), tmin, | |
| 78 | - [] (float l, float r) { return std::min(l, r); }, | ||
| 78 | + [] (int l, int r) { return std::min(l, r); }, | ||
| 79 | 79 | [] (const Data& d) { return d.transform(); } | |
| 80 | 80 | ); | |
| 81 | 81 | tf.wait_for_all(); | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -978,18 +978,19 @@ auto BasicFlowBuilder<NodeType>::emplace(C&& c) { | |||
| 978 | 978 | std::promise<R> p; | |
| 979 | 979 | auto fu = p.get_future(); | |
| 980 | 980 | ||
| 981 | - auto& node = _nodes.emplace_front( | ||
| 982 | - [p=MoC(std::move(p)), c=std::forward<C>(c)] () mutable { | ||
| 983 | - if constexpr(std::is_same_v<void, R>) { | ||
| 984 | - c(); | ||
| 985 | - p.get().set_value(); | ||
| 986 | - } | ||
| 987 | - else { | ||
| 988 | - p.get().set_value(c()); | ||
| 989 | - } | ||
| 990 | - } | ||
| 991 | - ); | ||
| 992 | - return std::make_pair(TaskType(node), std::move(fu)); | ||
| 981 | + if constexpr(std::is_same_v<void, R>) { | ||
| 982 | + auto& node = _nodes.emplace_front([p = MoC(std::move(p)), c = std::forward<C>(c)]() mutable { | ||
| 983 | + c(); | ||
| 984 | + p.get().set_value(); | ||
| 985 | + }); | ||
| 986 | + return std::make_pair(TaskType(node), std::move(fu)); | ||
| 987 | + } | ||
| 988 | + else { | ||
| 989 | + auto& node = _nodes.emplace_front([p = MoC(std::move(p)), c = std::forward<C>(c)]() mutable { | ||
| 990 | + p.get().set_value(c()); | ||
| 991 | + }); | ||
| 992 | + return std::make_pair(TaskType(node), std::move(fu)); | ||
| 993 | + } | ||
| 993 | 994 | } | |
| 994 | 995 | else { | |
| 995 | 996 | static_assert(dependent_false_v<C>, "invalid task work type"); | |
| Back | FazBrowse Home | New Git URL |
0 commit comments