Mojo struct

ProducerPipeline

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

Fields

mbar (MBarType):
state (PipelineState[ProducerPipeline[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

`acquire`

acquire(self)

`commit`

commit(mut self)

`commit_mma`

commit_mma(self)

commit_mma(self, elect: Int32)

`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​

acquire​

commit​

commit_mma​

step​