-
Notifications
You must be signed in to change notification settings - Fork 270
Expand file tree
/
Copy pathhello_world.cpp
More file actions
39 lines (33 loc) · 1.23 KB
/
Copy pathhello_world.cpp
File metadata and controls
39 lines (33 loc) · 1.23 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
/*
* Copyright (c) 2021-2022 NVIDIA Corporation
*
* Licensed under the Apache License Version 2.0 with LLVM Exceptions
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* https://llvm.org/LICENSE.txt
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#include <cstdio>
#include <stdexec/execution.hpp>
namespace ex = stdexec;
int main()
{
auto sched = ex::get_parallel_scheduler();
auto square = [](int i)
{
return i * i;
};
// Build a lazy pipeline: three squares, computed in parallel.
auto work = ex::when_all(ex::on(sched, ex::just(0) | ex::then(square)),
ex::on(sched, ex::just(1) | ex::then(square)),
ex::on(sched, ex::just(2) | ex::then(square)));
// Launch the work and wait for the result.
auto [i, j, k] = ex::sync_wait(std::move(work)).value();
std::printf("%d %d %d\n", i, j, k); // prints "0 1 4"
}