symbian::concurrency::WorkerExecutor::State Struct Reference

Inheritance diagram for symbian::concurrency::WorkerExecutor::State:

Classes
struct	Job
struct	Policy

Public Member Functions
	State (std::size_t limit)
absl::Status	Enqueue (Job job)
void	Wake () noexcept
void	Run ()

Public Attributes
const std::size_t	max_outstanding
std::mutex	mu
std::condition_variable	cv
std::deque< Job >	queue
std::size_t	outstanding = 0
std::size_t	wake_sequence = 0
bool	closing = false
Promise< Unit >	finished_promise
Task	finished = finished_promise.future()

Constructor & Destructor Documentation

State()

symbian::concurrency::WorkerExecutor::State::State ( std::size_t  limit )

inlineexplicit

Member Function Documentation

Enqueue()

absl::Status symbian::concurrency::WorkerExecutor::State::Enqueue ( Job  job )

inline

Run()

void symbian::concurrency::WorkerExecutor::State::Run ( )

inline

Wake()

void symbian::concurrency::WorkerExecutor::State::Wake ( )

inlinenoexcept

Member Data Documentation

closing

bool symbian::concurrency::WorkerExecutor::State::closing = false

cv

std::condition_variable symbian::concurrency::WorkerExecutor::State::cv

finished

Task symbian::concurrency::WorkerExecutor::State::finished = finished_promise.future()

finished_promise

Promise<Unit> symbian::concurrency::WorkerExecutor::State::finished_promise

max_outstanding

const std::size_t symbian::concurrency::WorkerExecutor::State::max_outstanding

mu

std::mutex symbian::concurrency::WorkerExecutor::State::mu

outstanding

std::size_t symbian::concurrency::WorkerExecutor::State::outstanding = 0

queue

std::deque<Job> symbian::concurrency::WorkerExecutor::State::queue

wake_sequence

std::size_t symbian::concurrency::WorkerExecutor::State::wake_sequence = 0

---

The documentation for this struct was generated from the following file:

• cpp/symbian/concurrency/guest/symbian/concurrency/worker_executor.cc