A11 (C++ runtime)
Native C++ implementation of the A11 action and streaming runtime
Loading...
Searching...
No Matches
executor.h File Reference
#include <exception>
#include <functional>
#include <utility>
#include <absl/functional/any_invocable.h>
#include <absl/status/status.h>
#include <absl/status/status_macros.h>
#include <absl/status/statusor.h>
#include "a11/concurrency/future.h"
This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Namespaces

namespace  a11
 

Functions

void a11::Schedule (absl::AnyInvocable< void() && > work, thread::TreeOptions tree_options={})
 Schedule work on A11's fiber pool without returning a completion handle.
 
std::function< void()> a11::ScheduleCancelable (absl::AnyInvocable< void() && > work, thread::TreeOptions tree_options={})
 Schedule work and return an idempotent cooperative-cancellation function.
 
template<typename T >
Future< T > a11::SubmitWithCancellationHook (absl::AnyInvocable< absl::StatusOr< T >() && > work, std::function< void()> cancellation_hook, thread::TreeOptions tree_options={})
 Run work on A11's fiber pool with application-specific cancellation.
 
template<typename T >
Future< Ta11::Submit (absl::AnyInvocable< absl::StatusOr< T >() && > work, thread::TreeOptions tree_options)
 Run status-returning work on the fiber pool and expose its Future.
 
Task a11::SubmitTask (absl::AnyInvocable< absl::Status() && > work, thread::TreeOptions tree_options={})
 Run an operation that returns only a completion status.