Hey Manik and all,
https://github.com/vblagoje/infinispan/tree/2ce49c49ea2cb8ba8d0e7d3e4829b...
Let me know if you have comments. The plan is to go forward with this
proposal for ALPHA2 tomorrow.
Regards,
Vladimir
On 11-01-12 2:42 PM, Vladimir Blagojevic wrote:
> Also, wrt. names and methods on the API on the Distributed Exec
part
> of things, wdyt about aligning it with JDK executors (see separate
> email from me)?
>
What exactly are you referring to? API like this one:
DistributedForkJoinPool p = cacheManager.newDistributedForkJoinPool();
result = p.invoke(new DistributedTask() { ... });
Do we need an executor service? We invoke tasks directly with execute
and executeAsync while MapReduceTask is invoked with:
R result = new
MapReduceTask(cache).on(K...).mappedWith(mapper).reducedWith(reducer).collate(collator);