vin

一个轻量级、易用且非传统的actor crate。

[dependencies]
vin = "9.1"

概述

Vin的目标是成为一个易用且非传统的actor库。Vin不遵循传统actor库的实现方式，而是尽可能简单，同时通过尽可能多地与tokio集成，提供易用且丰富的接口。每个actor都有自己的任务来轮询消息并执行处理器。其地址通过简单的Arc共享。Vin还提供了一种优雅地关闭所有actor的方法，无需手动操作。actor数据存储在其actor上下文中，可以通过Actor::ctx()进行读取，并通过Actor::ctx_mut()进行写入，这两个方法都会获取数据的RwLock。Vin还提供了一个“任务actor”，它只是一个与Vin的关闭系统同步的tokio任务。

Vin完全依赖于tokio（异步运行时）、log（诊断）和async_trait。

示例

常规actor

vin的基本使用。

use vin::prelude::*;
use std::time::Duration;
use tracing::Level;

#[vin::message]
#[derive(Debug, Clone)]
pub enum Msg {
    Foo,
    Bar,
    Baz,
}

#[vin::message(result = u32, error = String)]
#[derive(Debug, Clone)]
pub struct MsgWithResult;

#[vin::actor]
#[vin::handles(Msg)]
struct MyActor {
    pub number: u32,
}

#[async_trait]
impl vin::Hooks for MyActor {}

#[async_trait]
impl vin::Handler<Msg> for MyActor {
    async fn handle(&self, msg: Msg) -> Result<(), ()> {
        let ctx = self.ctx().await;
        println!("The message is: {:?} and the number is {}", msg, ctx.number);

        Ok(())
    }
}

#[async_trait]
impl vin::Handler<MsgWithResult> for MyActor {
    async fn handle(&self, MsgWithResult(should_err): MsgWithResult) -> Result<u32, String> {
        if should_err { Err("error".to_string()) }
        else { Ok(42) }
    }
}

#[tokio::main]
async fn main() {
    tracing_subscriber::fmt()
        .with_max_level(Level::TRACE)
        .init();

    let ctx = VinContextMyActor { number: 42 };
    let actor = MyActor::start("test", ctx).unwrap();
    actor.send(Msg::Bar).await;
    tokio::time::sleep(Duration::from_millis(500)).await;
    let res = actor.send_and_wait(MsgWithResult(false)).await.unwrap();
    assert_eq!(res, 42);
    vin::shutdown();
    vin::wait_for_shutdowns().await;
}

任务actor

vin中任务actor的基本使用。

use vin::*;
use std::time::Duration;
use tracing::Level;

#[vin::task]
#[derive(Debug, Clone, PartialEq, Eq)]
struct MyTaskActor {
    pub number: u32,
}

#[async_trait]
impl vin::Task for MyTaskActor {
    async fn task(self) -> anyhow::Result<()> {
        for i in 0..self.number {
            log::info!("{}. iteration", i);
        }

        Ok(())
    }
}

#[tokio::main]
async fn main() {
    tracing_subscriber::fmt()
        .with_max_level(Level::TRACE)
        .init();

    let ctx = VinContextMyTaskActor { number: 5 };
    let actor = MyTaskActor::start("test_task", ctx);
    tokio::time::sleep(Duration::from_millis(100)).await;
    actor.close();
    vin::shutdown();
    vin::wait_for_shutdowns().await;
}

许可证

本项目采用MIT许可证。