|
A11 (C++ runtime)
Native C++ implementation of the A11 streaming action runtime
|
Re-entry bookkeeping for a pump that may be driven from any thread. More...
#include <cpp/a11/concurrency/inline_pump.h>
Public Attributes | |
| size_t | depth = 0 |
| Live DriveInline() calls for this pump, across all threads. | |
| bool | again = false |
| Set by a call turned away at the cap; a running turn owes it a pass. | |
Re-entry bookkeeping for a pump that may be driven from any thread.
Lives in the pump's own state and is read and written only under the pump's mutex – the same one passed to DriveInline(). It tracks re-entrant drive depth across executing threads and fibers.
| bool a11::InlinePumpState::again = false |
Set by a call turned away at the cap; a running turn owes it a pass.
| size_t a11::InlinePumpState::depth = 0 |
Live DriveInline() calls for this pump, across all threads.