arena-alligator 0.1.0

Lock-free arena allocator producing bytes::Bytes via from_owner
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36

//! Fixed arena: allocate, write, freeze, send.

use std::num::NonZeroUsize;

use arena_alligator::FixedArena;
use bytes::BufMut;

fn main() {
    let arena = FixedArena::builder(
        NonZeroUsize::new(64).unwrap(),
        NonZeroUsize::new(4096).unwrap(),
    )
    .build()
    .unwrap();

    // Buffer implements BufMut.
    let mut buf = arena.allocate().unwrap();
    buf.put_slice(b"GET /index.html HTTP/1.1\r\n");
    buf.put_slice(b"Host: example.com\r\n\r\n");

    // Freeze without copying on the common path.
    let bytes = buf.freeze();

    let handle = std::thread::spawn(move || {
        assert!(bytes.starts_with(b"GET"));
        println!("sent {} bytes to worker", bytes.len());
    });

    handle.join().unwrap();

    let m = arena.metrics();
    println!(
        "allocations: {}, frees: {}, bytes_live: {}",
        m.allocations_ok, m.frees, m.bytes_live
    );
}