HydraContext hydra = new HydraContext();
DistributedTask<Integer> task = new DistributedTask<Integer>() {
@Override
public Integer compute() {
return 2 + 2;
}
};
DistributedFuture<Integer> future = hydra.submit(task);
try {
int result = future.get();
e.printStackTrace();
}
hydra.shutdown();
