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

[Vladimir Blagojevic (JIRA)]

     [ https://issues.jboss.org/browse/ISPN-2287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Vladimir Blagojevic updated ISPN-2287:
--------------------------------------

    Description: 
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}

  was:
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:


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


    
> 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}

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira