Наилучшая практика для пересылки сообщений между типизированными актерами в C ++ Actors Framework?

Question

Наилучшая практика для пересылки сообщений между типизированными актерами в C ++ Actors Framework?

Я пытаюсь передать какую-то работу от одного типизированного актера другому. В руководстве пользователя 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();
}

5

c++c++-actor-framework

Решение

Другие решения

Других решений пока нет …

Источник

Accepted Answer

Поэтому я полагаю, что можно вызывать forward_current_message напрямую?

Нет, forward_current_message не является частью общедоступного API в CAF (и поэтому не указан в Doxygen). Это означает, что функцию-член можно переименовать, удалить или сделать protected/private в любое время.

Лучшая практика для пересылки сообщений типизированным актерам delegate, Это новая функция (введена с 0.14.1) и к сожалению не упоминается в руководстве еще. Лучшая доступная в настоящее время документация — это ее использование в модульный тест для типизированных актеров.

Короткая версия: delegate является альтернативой send что перекладывает ответственность за запрос. В типизированном актере вы можете вернуть delegated<T> вместо T из обработчика сообщений, чтобы указать, что другой субъект ответит 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);
}
};
}
};

5