memkit-async 0.2.0-beta.1

Async-aware memory allocators for memkit
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
37

//! Backpressure policies for async allocators.

use std::time::Duration;

/// Backpressure policy for when allocation would block.
#[derive(Debug, Clone)]
pub enum MkBackpressure {
    /// Wait indefinitely for memory to become available.
    Wait,
    
    /// Fail immediately if no memory available.
    Fail,
    
    /// Wait up to a timeout, then fail.
    Timeout(Duration),
    
    /// Evict least-recently-used items to make room.
    Evict,
}

impl Default for MkBackpressure {
    fn default() -> Self {
        Self::Wait
    }
}

impl MkBackpressure {
    /// Create a timeout policy.
    pub fn timeout(duration: Duration) -> Self {
        Self::Timeout(duration)
    }

    /// Create a timeout policy from milliseconds.
    pub fn timeout_ms(ms: u64) -> Self {
        Self::Timeout(Duration::from_millis(ms))
    }
}