Mojo struct

ConsumerPipeline

@register_passable(trivial) struct ConsumerPipeline[number_of_stages: Int]

Fields

mbar (MBarType):
state (PipelineState[ConsumerPipeline[number_of_stages].num_stages]):

Implemented traits

AnyType, Copyable, ImplicitlyCopyable, Movable, UnknownDestructibility

`comptime` members

`copyinitis_trivial`

comptime __copyinit__is_trivial = True

`delis_trivial`

comptime __del__is_trivial = True

`moveinitis_trivial`

comptime __moveinit__is_trivial = True

`num_stages`

comptime num_stages = number_of_stages

Methods

`init`

__init__(mbar: LegacyUnsafePointer[SharedMemBarrier, address_space=AddressSpace.SHARED]) -> Self

`producer_mbar`

producer_mbar(self) -> MBarType

Returns:

MBarType

`consumer_mbar`

consumer_mbar(self) -> MBarType

Returns:

MBarType

`wait`

wait(self)

`release`

release(mut self)

`step`

step(mut self)

Fields​

Implemented traits​

comptime members​

__copyinit__is_trivial​

__del__is_trivial​

__moveinit__is_trivial​

num_stages​

Methods​

__init__​

producer_mbar​

consumer_mbar​

wait​

release​

step​