在C++actors框架中在类型化参与者之间转发消息的最佳实践

Best practice for forwarding messages between typed actors in the C++ Actors Framework?

本文关键字：消息 最佳 转发 之间 C++actors 框架 类型化 参与者      更新时间：2023-10-16

我正试图将一些工作从一个类型化的演员交给另一个类型。CAF用户手册指出，这可以使用forward_to方法来完成。该方法看起来只适用于显式为event_based_actor类型的参与者。然而，forward_to似乎是对forward_current_message方法的精简包装，该方法是为local_actor类型的所有参与者定义的。因此，我认为可以直接调用forward_current_message吗？

此外，为了让消息转发与键入的参与者一起工作，我仍然必须返回中间参与者的响应。那个演员的反应似乎被忽视了，这很好，但我做错了什么吗？或者，真的有必要支付构建一个不会使用的响应的（通常是最低的）成本吗？

以下是一些工作示例代码，演示了我尝试使用类型化参与者进行消息转发：

#include <iostream>
#include "caf/all.hpp"
using namespace caf;
using namespace std;
using a_type = typed_actor<replies_to<int>::with<bool>>;
using b_type = typed_actor<replies_to<int>::with<bool>>;
actor worker()
{
    return spawn(
        [](event_based_actor *self) -> behavior
        {
            return
            {
                [self](int index)
                {
                    aout(self) << "Worker: " << index << endl;
                    return index;
                }
            };
        });
}
b_type::behavior_type bBehavior(b_type::pointer self)
{
    return
    {
        [self](int value)
        {
            // Create blocking actor
            scoped_actor blockingActor;
            // Spawn pool workers and send each a message
            auto pool = actor_pool::make(value, worker, actor_pool::round_robin());
            for(int i = 0; i < value; ++i)
            {
                blockingActor->send(pool, i);
            }
            // Wait for completion
            vector<int> results;
            int i = 0;
            blockingActor->receive_for(i, value) (
                [&results](int value)
                {
                    results.push_back(value);
                });
            blockingActor->send_exit(pool, exit_reason::user_shutdown);
            self->quit();
            return (value == results.size());
        }
    };
}
class A : public a_type::base
{
protected:
    behavior_type make_behavior() override
    {
        return
        {
            [this](int value) -> bool
            {
                aout(this) << "Number of tasks: " << value << endl;
                b_type forwardDestination = spawn(bBehavior);
                auto castDestination = actor_cast<actor>(forwardDestination);
                this->forward_current_message(castDestination);
                this->quit();
                return false;
            }
        };
    }
};

void tester()
{
    a_type testeeActor = spawn<A>();
    scoped_actor self;
    self->sync_send(testeeActor, 5).await(
        [testeeActor, &self](bool success)
        {
            aout(self) << "All workers completed? " << (success ? "Yes!" : "No :(") << endl;
        });
}
int main()
{
    tester();
    await_all_actors_done();
    shutdown();
    cout << "Press Enter to continue" << endl;
    cin.get();
}

因此，我认为可以直接调用forward_current_message吗？

不，forward_current_message不是CAF中公共API的一部分（因此未在Doxygen中列出）。这意味着成员函数可以随时重命名、删除或设置为protected/private。

将消息转发给类型化参与者的最佳实践是delegate。这是一个新功能（在0.14.1中引入），不幸的是，手册中尚未提及。目前可用的最好的"文档"是它在类型化参与者的单元测试中的使用。

简短的版本是：delegate是转发请求责任的send的替代方案。在键入的actor中，您可以从消息处理程序返回delegated<T>而不是T，以指示其他actor将使用T响应原始发件人。

在您的情况下，类A的实现方式如下：

class A : public a_type::base
{
protected:
    behavior_type make_behavior() override {
        return {
            [this](int value) {
                aout(this) << "Number of tasks: " << value << endl;
                auto forwardDestination = spawn(bBehavior);
                this->quit();
                return delegate(forwardDestination, value);
            }
        };
    }
};
相关文章：