Mojo struct
ConsumerPipeline
@register_passable(trivial)
struct ConsumerPipeline[number_of_stages: Int]
Fields
- mbar (
LegacyUnsafePointer[SharedMemBarrier, address_space=AddressSpace.SHARED]): - state (
PipelineState[ConsumerPipeline[number_of_stages].num_stages]):
Implemented traits
AnyType,
Copyable,
ImplicitlyCopyable,
Movable,
UnknownDestructibility
Aliases
__copyinit__is_trivial
comptime __copyinit__is_trivial = True
__del__is_trivial
comptime __del__is_trivial = True
__moveinit__is_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) -> LegacyUnsafePointer[SharedMemBarrier, address_space=AddressSpace.SHARED]
Returns:
consumer_mbar
consumer_mbar(self) -> LegacyUnsafePointer[SharedMemBarrier, address_space=AddressSpace.SHARED]
Returns:
wait
wait(self)
release
release(mut self)
step
step(mut self)
Was this page helpful?
Thank you! We'll create more content like this.
Thank you for helping us improve!