无法使用异步actor

如何解决无法使用异步actor

我正在尝试使用 actix documentation 中记录的演员。但即使是 doc 示例也不适合我。我尝试了以下编译但不打印消息“收到 fibo 消息”的代码

use actix::prelude::*;

// #[derive(Message)]
// #[rtype(Result = "Result<u64,()>")]
// struct Fibonacci(pub u32);

struct Fibonacci(pub u32);
impl Message for Fibonacci {
    type Result = Result<u64,()>;
}

struct SyncActor;

impl Actor for SyncActor {
    // It's important to note that you use "SyncContext" here instead of "Context".
    type Context = SyncContext<Self>;
}

impl Handler<Fibonacci> for SyncActor {
    type Result = Result<u64,()>;

    fn handle(&mut self,msg: Fibonacci,_: &mut Self::Context) -> Self::Result {
        println!("Received fibo message");
        if msg.0 == 0 {
            Err(())
        } else if msg.0 == 1 {
            Ok(1)
        } else {
            let mut i = 0;
            let mut sum = 0;
            let mut last = 0;
            let mut curr = 1;
            while i < msg.0 - 1 {
                sum = last + curr;
                last = curr;
                curr = sum;
                i += 1;
            }
            Ok(sum)
        }
    }
}

fn main() {
    System::new().block_on(async {
        // Start the SyncArbiter with 2 threads,and receive the address of the Actor pool.
        let addr = SyncArbiter::start(2,|| SyncActor);

        // send 5 messages
        for n in 5..10 {
            // As there are 2 threads,there are at least 2 messages always being processed
            // concurrently by the SyncActor.
            println!("Sending fibo message");
            addr.do_send(Fibonacci(n));
        }
    });
}

此程序显示 5 次：

发送 fibo 消息

两点说明，首先我无法使用宏rtype，我使用自己实现Message。然后这行 addr.do_send(Fibonacci(n)) 似乎没有给我的演员发送任何东西。但是，如果我使用 addr.send(Fibonacci(n)).await;，我的消息会在参与者端发送和接收。但由于我正在等待发送函数，它会同步处理消息，而不是使用我理论上定义的 2 个线程。

我也尝试在主循环后使用 thread::sleep 等待，但消息也没有到达。

我可能误解了一些东西，但对我来说似乎很奇怪。

Cargo.toml 文件：

[dependencies]
actix = "0.11.1"
actix-rt = "2.2.0"

解决方法

我终于设法让它工作了，虽然我不明白为什么。简单地使用 tokio 等待 ctrl-C 使我可以调用 do_send/try_send 并并行工作。

fn main() {
    System::new().block_on(async {
        // Start the SyncArbiter with 4 threads,and receive the address of the Actor pool.
        let addr = SyncArbiter::start(4,|| SyncActor);

        // send 15 messages
        for n in 5..20 {
            // As there are 4 threads,there are at least 4 messages always being processed
            // concurrently by the SyncActor.
            println!("Sending fibo message");
            addr.do_send(Fibonacci(n));
        }


        // This does not wotk
        //thread::spawn(move || {
        //    thread::sleep(Duration::from_secs_f32(10f32));
        //}).join();

        // This made it worked
        tokio::signal::ctrl_c().await.unwrap();
        println!("Ctrl-C received,shutting down");
        System::current().stop();

    });
}