geph5-client 0.2.71

Geph5 client
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

use std::collections::VecDeque;

use once_cell::sync::Lazy;
use parking_lot::Mutex;
use smol::Task;

static TASK_POOL: Lazy<Mutex<VecDeque<Task<anyhow::Result<()>>>>> =
    Lazy::new(|| Mutex::new(VecDeque::new()));

/// Add a task to the task pool. If the pool is full, the oldest task will be removed.
pub fn add_task(task_limit: u32, task: Task<anyhow::Result<()>>) {
    let mut pool = TASK_POOL.lock();
    if pool.len() >= task_limit as usize {
        pool.pop_front();
    }
    pool.push_back(task);
}