ある型付けされたアクターから別のアクターに作業を引き継ごうとしています。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();
}