|
A11 (C++ runtime)
Native C++ implementation of the A11 streaming action runtime
|
#include "a11/concurrency/parallel.h"#include <cstddef>#include <utility>#include <vector>#include <absl/functional/any_invocable.h>#include <absl/status/status.h>#include "a11/concurrency/executor.h"#include "a11/concurrency/future.h"#include "thread/concurrency.h"Namespaces | |
| namespace | a11 |
Functions | |
| absl::Status | a11::RunAllToCompletion (std::vector< absl::AnyInvocable< absl::Status() && > > work, size_t stack_size=256 *1024) |
| Runs each callable on its own fiber and waits for all of them. | |