dualcache-ff 1.0.0

A wait-free, high-performance concurrent cache optimized for extreme read-to-write ratios.
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

use core::sync::atomic::{AtomicU64, Ordering};

/// PackedBlackjack holds tuning parameters for Cache Policy in a single atomic U64.
/// [ T0_Hit (16b) | T1_Hit (16b) | T2_Penalty (16b) | Warmup_Threshold (16b) ]
pub struct PackedBlackjack {
    state: AtomicU64,
}

impl PackedBlackjack {
    pub const fn new(t0_hit: u16, t1_hit: u16, t2_penalty: u16, warmup: u16) -> Self {
        let packed = (t0_hit as u64) << 48 | (t1_hit as u64) << 32 | (t2_penalty as u64) << 16 | (warmup as u64);
        Self {
            state: AtomicU64::new(packed),
        }
    }

    #[inline(always)]
    pub fn load_params(&self) -> (u16, u16, u16, u16) {
        let val = self.state.load(Ordering::Relaxed);
        (
            (val >> 48) as u16,
            ((val >> 32) & 0xFFFF) as u16,
            ((val >> 16) & 0xFFFF) as u16,
            (val & 0xFFFF) as u16,
        )
    }

    pub fn store_params(&self, t0_hit: u16, t1_hit: u16, t2_penalty: u16, warmup: u16) {
        let packed = (t0_hit as u64) << 48 | (t1_hit as u64) << 32 | (t2_penalty as u64) << 16 | (warmup as u64);
        self.state.store(packed, Ordering::Relaxed);
    }
}