3:15 p.m.
[
https://issues.jboss.org/browse/ISPN-2287?page=com.atlassian.jira.plugin....
]
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