tokio-mpmc

A high-performance multi-producer multi-consumer (MPMC) queue implementation based on Tokio.

Features

• Asynchronous implementation based on Tokio
• Support for multi-producer multi-consumer pattern
• Message processing using consumer pool
• Simple and intuitive API
• Complete error handling
• Queue capacity control

Installation

Add the following dependency to your Cargo.toml:

[dependencies]
tokio-mpmc = "0.1"

Usage Example

use tokio_mpmc::Queue;

#[tokio::main]
async fn main() {
    // Create a queue with capacity of 100
    let queue = Queue::new(100);

    // Send a message
    if let Err(e) = queue.send("Hello").await {
        eprintln!("Send failed: {}", e);
    }

    // Receive a message
    match queue.receive().await {
        Ok(Some(msg)) => println!("Received message: {}", msg),
        Ok(None) => println!("Queue is empty"),
        Err(e) => eprintln!("Receive failed: {}", e),
    }

    // Close the queue
    queue.close().await;
}

API Documentation

Main APIs include:

• Queue::new(capacity) - Create a new queue
• Queue::send(value) - Send a message
• Queue::receive() - Receive a message
• Queue::close() - Close the queue
• Queue::len() - Get queue length
• Queue::is_empty() - Check if queue is empty
• Queue::is_full() - Check if queue is full
• Queue::is_closed() - Check if queue is closed

License

This project is licensed under the Apache-2.0 License. See the LICENSE file for details.