For the complete documentation index, see llms.txt. Markdown versions of all pages are available by appending .md to any URL (e.g. /max/get-started.md).
Mojo struct
MBarPipeline
struct MBarPipeline[number_of_stages: Int]
Manages a paired set of producer/consumer mbarriers for pipeline synchronization.
Parameters
- number_of_stages (
Int): Number of double-buffered pipeline stages, each with one producer and one consumer mbarrier.
Fields
- mbar (
MBarType): - state (
PipelineState[number_of_stages]):
Implemented traits
AnyType,
Copyable,
ImplicitlyCopyable,
ImplicitlyDeletable,
Movable,
RegisterPassable,
TrivialRegisterPassable
comptime members
num_stages
comptime num_stages = number_of_stages
Methods
__init__
def __init__(mbar: Pointer[SharedMemBarrier, MutAnyOrigin, address_space=AddressSpace.SHARED, _safe=False]) -> Self
init
def init[*, num_producer: UInt32 = UInt32(1), num_consumer: UInt32 = UInt32(1)](self)
num_mbars
Was this page helpful?
Thank you! We'll create more content like this.
Thank you for helping us improve!