[infinispan-dev] Distributed execution framework - API proposal(s)

[Vladimir Blagojevic]

Hey Manik and all,

https://github.com/vblagoje/infinispan/tree/2ce49c49ea2cb8ba8d0e7d3e4829be3ecca42951/core/src/main/java/org/infinispan/distexec

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);