Struct EventProducer 

pub struct EventProducer<M> { /* private fields */ }

The owning thread’s write handle, stored in a thread_local.

Implementations

impl<M> EventProducer<M>

pub fn push(&self, m: M)

Appends one event: a plain slot store plus a Release publish of the new length. Allocates a fresh chunk every CHUNK_SIZE events.

Examples found in repository

examples/throughput.rs (line 70)

fn produce(producer: usize, lockstep: &Lockstep) {
    for round in 0..ROUNDS {
        for i in 0..BATCH {
            let event = Event {
                producer,
                seq: round * BATCH + i,
                payload: [i as u8; 8],
            };
            let _ = PRODUCER.try_with(|p| p.push(event));
        }
        lockstep.batch_pushed.wait();
        lockstep.sweep_done.wait();
    }
}

Trait Implementations

impl<M> Drop for EventProducer<M>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.