songzhi

use axum::{
    extract::ws::{Message, WebSocket, WebSocketUpgrade},
    response::IntoResponse,
    routing::get,
    Router,
};
use once_cell::sync::Lazy;
use std::{future::Future, net::SocketAddr, time::Duration};
use tokio::{
    io::{AsyncReadExt, AsyncWriteExt},

songzhi

/// 
/// ## Examples
/// ```
/// enum Foo {
///     Path(String),
///     Count(usize),
/// }
/// let foo = Foo::Path(1);
/// let f: Option<String> = try_match!(foo, Foo::Path(x)=> x);
/// ```

songzhi

//! Inspired by [this](http://concurrencyfreaks.blogspot.com/2013/08/concurrency-pattern-distributed-cache.html).

use cache_padded::CachePadded;
use std::sync::atomic::{AtomicUsize, Ordering};

pub struct DistributedCacheLineCounter {
    counters: Box<[CachePadded<AtomicUsize>]>,
    num_counters: usize,
}