|
A11 (C++ runtime)
Native C++ implementation of the A11 streaming action runtime
|
Utilities for running independent work concurrently. More...
#include <cstddef>#include <utility>#include <vector>#include <absl/functional/any_invocable.h>#include <absl/status/status.h>#include <absl/status/statusor.h>#include <absl/time/time.h>#include "a11/concurrency/executor.h"#include "a11/concurrency/future.h"#include "thread/concurrency.h"Go to the source code of this file.
Namespaces | |
| namespace | a11 |
Functions | |
| template<typename T > | |
| std::vector< absl::StatusOr< T > > | a11::AwaitAll (const std::vector< Future< T > > &futures, absl::Time deadline=absl::InfiniteFuture()) |
| Awaits futures that are already running, and returns every result. | |
| 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. | |
Utilities for running independent work concurrently.