#include <ray/api.h>
int Plus(int x, int y) { return x + y; }
RAY_REMOTE(Plus);
class Counter {
public:
int count;
Counter(int init) { count = init; }
static Counter *FactoryCreate(int init) { return new Counter(init); }
int Add(int x) {
count += x;
return count;
}
};
RAY_REMOTE(Counter::FactoryCreate, &Counter::Add);
int main(int argc, char **argv) {
ray::Init();
auto object = ray::Put(100);
auto put_get_result = *(ray::Get(object));
std::cout << "put_get_result = " << put_get_result << std::endl;
auto task_object = ray::Task(Plus).Remote(1, 2);
int task_result = *(ray::Get(task_object));
std::cout << "task_result = " << task_result << std::endl;
ray::ActorHandle<Counter> actor = ray::Actor(Counter::FactoryCreate).Remote(0);
auto actor_object = actor.Task(&Counter::Add).Remote(3);
int actor_task_result = *(ray::Get(actor_object));
std::cout << "actor_task_result = " << actor_task_result << std::endl;
auto actor_object2 = actor.Task(&Counter::Add).Remote(task_object);
int actor_task_result2 = *(ray::Get(actor_object2));
std::cout << "actor_task_result2 = " << actor_task_result2 << std::endl;
ray::Shutdown();
return 0;
}