hyperlane 19.1.0

A lightweight, high-performance, and cross-platform Rust HTTP server library built on Tokio. It simplifies modern web service development by providing built-in support for middleware, WebSocket, Server-Sent Events (SSE), and raw TCP communication. With a unified and ergonomic API across Windows, Linux, and MacOS, it enables developers to build robust, scalable, and event-driven network applications with minimal overhead and maximum flexibility.
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

use crate::*;

/// Task manager for handling async tasks across worker threads.
///
/// This structure manages a pool of task senders distributed across
/// multiple worker threads, enabling efficient round-robin task scheduling
/// with event-driven wake-up mechanism.
#[derive(CustomDebug, Data, DisplayDebug)]
pub struct Task {
    /// Pool of unbounded senders for distributing tasks to worker threads.
    #[get_mut(pub(super))]
    #[set(pub(super))]
    pub(super) pool: Vec<UnboundedSender<AsyncTask>>,
    /// Notification handle for waking up worker threads when tasks arrive.
    #[get_mut(pub(super))]
    #[set(pub(super))]
    pub(super) notify: &'static Notify,
    /// Atomic counter for round-robin task distribution across workers.
    #[get_mut(pub(super))]
    #[set(pub(super))]
    pub(super) counter: AtomicUsize,
    /// Flag indicating whether the task pool should shut down.
    #[get_mut(pub(super))]
    #[set(pub(super))]
    pub(super) shutdown: &'static AtomicBool,
}