A11 (C++ runtime)
Native C++ implementation of the A11 streaming action runtime
Loading...
Searching...
No Matches
parallel.h File Reference

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"
This graph shows which files directly or indirectly include this file:

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.
 

Detailed Description

Utilities for running independent work concurrently.