[infinispan-dev] Distributed execution framework - API proposal(s)
Vladimir Blagojevic
vblagoje at redhat.com
Wed Jan 12 12:42:29 EST 2011
>
> 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);
> And - not trying to confuse you, promise! - here's some scope for
> additional work later on as well: network classloaders to deal with
> non-homogenous deployments with remote tasks like these. ;)
>
There are tons of other things to finish!
Cheers,
Vladimir
More information about the infinispan-dev
mailing list