将分区视为循环中的“状态”可能更有帮助，而不是“发送者”和“接收者”对。事实上，这是库的原始动机——使用分区来表示对象在其生命周期中的状态，允许简单的状态转换，并在需要时允许多个所有者访问。当然，这适用于消息传递，假设分区内部数据可变。

预留

预订表示对某些数据的独家所有权。预订是从分区创建的。一旦可用，就会创建一个预订，该预订持有对请求的对象的独家所有权。这意味着一旦您持有预订，就可以安全地读取和写入这些对象。

一旦预订超出范围或被明确删除，对象的“所有权”将“转移”到下一个逻辑分区。值得注意的是，对于并发分区，可以在一个分区上同时请求多个预订。持有预订仍然保证对预订管理的对象具有独家所有权，但删除预订可能会暂时阻止执行，直到之前的预订也已传递。也就是说，预订遵循先进先出（FIFO）顺序 - 首先创建的预订必须首先删除，然后后续预订将等待直到这是可能的。

如何使用

使用talaria有三个步骤

1. 创建一个通道
2. 获取一个分区
3. 获取一个预订

以下是如何使用talaria在两个线程之间无限传递“Ping/Pong”消息的示例。

use talaria::channel::Channel;

#[derive(Clone)]
enum Message {
    Ping, 
    Pong,
}

fn main() {
    // id of the partition we'll access on the main thread
    const MAIN_PARTITION: usize = 0;
    // id of the partition we'll access on worker thread
    const THREAD_PARTITION: usize = 1;
    
    let channel = Channel::builder()
        .add_exclusive_partition()
        .add_exclusive_partition()
        .build(vec![Message::Ping; 16])
        .unwrap();

    let channel_clone = channel.clone();
    
    // spin up a worker thread
    // it will do what the main thread is doing, but in reverse..
    let thread_handle = std::thread::spawn(move || {
        let mut partition = channel_clone
            .get_exclusive_partition(THREAD_PARTITION)
            .unwrap();
        
        while let Ok(mut reservation) = partition.reserve(1) {
            reservation[0] = match &reservation[0] {
                Message::Pong => Message::Ping,
                Message::Ping => panic!("unexpected message!")
            };
        }
    });

    let mut partition = channel
        .get_exclusive_partition(MAIN_PARTITION)
        .unwrap();

    // reserve an item at a time
    while let Ok(mut reservation) = partition.reserve(1) {
        reservation[0] = match &reservation[0] {
            // if the first (and only) element is a "ping" message,
            // set it to "pong" and forward it
            Message::Ping => Message::Pong,
            //  otherwise we got an unexpected message!
            Message::Pong => panic!("unexpected message!")
        };
    }
    
    thread_handle.join().unwrap();
}

基准测试

talaria使用 Criterion 进行基准测试，只需运行cargo bench即可开始基准测试。

基准测试是为独家和并发双线程分区场景编写的，以及与 std::sync::mpsc 和 crossbeam 的有界通道等效的测试。

以下是在我的机器上（i9-9900k，64Gb 3200mhz RAM）进行的基准测试示例

独家

并发

std::sync::mpsc

crossbeam

正确性测试

talaria附带了一个（相对不完整）的正确性测试套件，使用loom和shuttle。要运行它们，请执行以下操作

Loom

RUSTFLAGS="--cfg loom" cargotest

Shuttle

RUSTFLAGS="--cfg shuttle" cargotest

有些测试是时间限制的，以防止它们无限期运行或运行时间过长。虽然预期测试将花费几分钟，但请期待。