[infinispan-issues] [JBoss JIRA] (ISPN-2287) Introduce DistributedTask abstraction enhancement for distributed executors

Introduce DistributedTask abstraction enhancement for distributed executors ------------------------------------------------------------------------------ Key: ISPN-2287 URL: https://issues.jboss.org/browse/ISPN-2287 Project: Infinispan Issue Type: Enhancement Components: Distributed Execution and Map/Reduce Affects Versions: 5.2.0.Alpha3 Reporter: Vladimir Blagojevic Assignee: Vladimir Blagojevic Fix For: 5.2.0.Beta1 As we have requirements to add timeout, pluggable fail over policies, topology aware target selection policies to distributed executors we have to create a new abstraction DistributedTask that users can submit to DistributedExecutorService. We will provide builder for DistributedTask, keep the existing four submit methods in DistributedExecutorService and add four new methods with DistributedTask abstraction in place of Callable. See below: {code} interface DistributedExecutorService { … existing methods … <T> List<Future<T>> submitEverywhere(DistributedTask<T> callable); } class DistributedTaskBuilder<T> { DistributedTaskBuilder<T> callable(Callable<T> callable); DistributedTaskBuilder<T> timeout(long t, TimeUnit tu); DistributedTaskBuilder<T> executionPolicy(DistributedExecutionPolicy p); DistributedTask<T> build(); } {code}