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
CvtToMMAPipeline
struct CvtToMMAPipeline[num_stages: Int, num_producer: Int, num_consumer: Int]
Fields
- producer_mbars (
MBarType): - consumer_mbars (
MBarType): - state (
PipelineState[num_stages]):
Implemented traits
AnyType,
Copyable,
ImplicitlyCopyable,
ImplicitlyDeletable,
Movable,
RegisterPassable,
TrivialRegisterPassable
Methods
__init__
def __init__(producer_mbars: UnsafePointer[SharedMemBarrier, MutAnyOrigin, address_space=AddressSpace.SHARED], consumer_mbars: UnsafePointer[SharedMemBarrier, MutAnyOrigin, address_space=AddressSpace.SHARED]) -> Self
init
def init(self)
producer_mbar
def producer_mbar(self) -> MBarType
Returns:
MBarType
consumer_mbar
def consumer_mbar(self) -> MBarType
Returns:
MBarType
producer_acquire
def producer_acquire(self)
consumer_wait
def consumer_wait(self)
producer_commit
def producer_commit(mut self)
consumer_release
def consumer_release(mut self, elect: Int32)
step
def step(mut self)
Was this page helpful?
Thank you! We'll create more content like this.
Thank you for helping us improve!