<dependency>
<groupId>com.timely</groupId>
<artifactId>timely-core</artifactId>
<version>1.0.0</version>
</dependency>
import com.timely.TimelyTask;
public class ConcurrentSumTask extends TimelyTask<Integer, Integer> {
private final List<Integer> numbers;
public ConcurrentSumTask(List<Integer> numbers) {
super("SumTask");
this.numbers = numbers;
}
@Override
protected Integer compute() throws Exception {
int sum = 0;
for (Integer number : numbers) {
sum += number;
}
return sum;
}
}
import com.timely.TimelyExecutor;
public class Main {
public static void main(String[] args) {
TimelyExecutor executor = new TimelyExecutor();
List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);
ConcurrentSumTask sumTask = new ConcurrentSumTask(numbers);
Future<Integer> future = executor.submit(sumTask);
try {
e.printStackTrace();
}
executor.shutdown();
}
}
import com.timely.TimelyExecutor;
import com.timely.config.TimelyConfig;
public class Main {
public static void main(String[] args) {
TimelyConfig config = new TimelyConfig();
config.setThreadPoolSize(10);
config.setTaskTimeout(1000);
TimelyExecutor executor = new TimelyExecutor(config);
// ...
}
}
