#shared-state #singleton #state-management #shared #container

shared_singleton

shared_singleton特质提供了具有共享容器的单例模式状态管理。

3个不稳定版本

0.2.1 2024年3月3日
0.2.0 2024年3月3日
0.1.0 2020年10月9日

Rust模式中排名第329位

Download history 4/week @ 2024-03-16 38/week @ 2024-03-30 4/week @ 2024-04-06

每月下载量约663次

MIT许可证

11KB
155行代码(不含注释)

Shared Singleton

shared_singleton特质提供了具有共享容器的单例模式状态管理。

可以使用非常短的代码实现单例模式。
您可以从以下共享容器中选择更好的一个:`Rc`, `Rc>`, `Rc>`, `Arc`, `Arc>` 和 `Arc>`。

示例

  • Rc<T>
use shared_singleton::*;

struct Foo(usize);
impl_singleton_rc!(Foo, Foo(1));

let x1 = Foo::singleton();
let x2 = Foo::singleton();

assert_eq!(1, Foo::singleton().0);

assert!(std::rc::Rc::ptr_eq(&x1, &x2));
  • Rc<Cell<T>>
use shared_singleton::*;

#[derive(Clone, Copy)]
struct Foo(usize);
impl_singleton_rc_cell!(Foo, Foo(1));

let x1 = Foo::singleton();
let x2 = Foo::singleton();

assert_eq!(1, x1.get().0);
x2.set(Foo(2));
assert_eq!(2, x1.get().0);

assert!(std::rc::Rc::ptr_eq(&x1, &x2));
  • Rc<RefCell<T>>
use shared_singleton::*;

struct Foo(usize);
impl_singleton_rc_refcell!(Foo, Foo(1));

let x1 = Foo::singleton();
let x2 = Foo::singleton();

assert_eq!(1, x1.borrow().0);
x2.borrow_mut().0 = 2;
assert_eq!(2, x1.borrow().0);

assert!(std::rc::Rc::ptr_eq(&x1, &x2));
  • Arc<T>
use shared_singleton::*;

struct Foo(usize);
impl_singleton_arc!(Foo, Foo(1));

let x1 = Foo::singleton();
let x2 = Foo::singleton();

assert_eq!(1, x1.0);

assert!(std::sync::Arc::ptr_eq(&x1, &x2));
  • Arc<Mutex<T>>
use shared_singleton::*;

struct Foo(usize);
impl_singleton_arc_mutex!(Foo, Foo(1));

let x1 = Foo::singleton();
let x2 = Foo::singleton();

assert!(std::sync::Arc::ptr_eq(&x1, &x2));

let t1 = std::thread::spawn(move || {
    x1.lock().unwrap().0 = 2;
    println!("{}", x1.lock().unwrap().0);
});

let t2 = std::thread::spawn(move || {
    x2.lock().unwrap().0 = 3;
    println!("{}", x2.lock().unwrap().0);
});

t1.join().unwrap();
t2.join().unwrap();
  • Arc<RwLock<T>>
use shared_singleton::*;

struct Foo(usize);
impl_singleton_arc_rwlock!(Foo, Foo(1));

let x1 = Foo::singleton();
let x2 = Foo::singleton();

assert!(std::sync::Arc::ptr_eq(&x1, &x2));

let t1 = std::thread::spawn(move || {
    x1.write().unwrap().0 = 2;
    println!("{}", x1.read().unwrap().0);
});

let t2 = std::thread::spawn(move || {
    x2.write().unwrap().0 = 3;
    println!("{}", x2.read().unwrap().0);
});

t1.join().unwrap();
t2.join().unwrap();

可选特性

tokio

`tokio::sync::Mutex` 和 `tokio::sync::RwLock` 是可用的。

  • tokio::sync::Mutex
use shared_singleton::*;

struct Foo(usize);
impl_singleton_arc_mutex_tokio!(Foo, Foo(1));

#[tokio::main]
async fn main() {
    let x1 = Foo::singleton();
    let x2 = Foo::singleton();

    assert!(std::sync::Arc::ptr_eq(&x1, &x2));

    let t1 = tokio::spawn(async move {
        x1.lock().await.0 = 2;
        println!("{}", x1.lock().await.0);
    });

    let t2 = tokio::spawn(async move {
        x2.lock().await.0 = 3;
        println!("{}", x2.lock().await.0);
    });

    t1.await.unwrap();
    t2.await.unwrap();
}
  • tokio::sync::RwLock
use shared_singleton::*;

struct Foo(usize);
impl_singleton_arc_rwlock_tokio!(Foo, Foo(1));

#[tokio::main]
async fn main() {
    let x1 = Foo::singleton();
    let x2 = Foo::singleton();

    assert!(std::sync::Arc::ptr_eq(&x1, &x2));

    let t1 = tokio::spawn(async move {
        x1.write().await.0 = 2;
        println!("{}", x1.read().await.0);
    });

    let t2 = tokio::spawn(async move {
        x2.write().await.0 = 3;
        println!("{}", x2.read().await.0);
    });

    t1.await.unwrap();
    t2.await.unwrap();
}

依赖项

~0–1.1MB
~19K SLoC