[BAEL-7073] change location of code
This commit is contained in:
parent
596c10de0a
commit
efb0046025
@ -0,0 +1,24 @@
|
|||||||
|
package com.baeldung.concurrent.executorservice;
|
||||||
|
|
||||||
|
import java.util.concurrent.ExecutorService;
|
||||||
|
import java.util.concurrent.Executors;
|
||||||
|
|
||||||
|
public class ExecuteExample {
|
||||||
|
public static void main(String[] args) {
|
||||||
|
ExecutorService executorService = Executors.newFixedThreadPool(2);
|
||||||
|
// Task using Runnable
|
||||||
|
Runnable task = () -> {
|
||||||
|
int[] numbers = { 1, 2, 3, 4, 5 };
|
||||||
|
int sum = 0;
|
||||||
|
for (int num : numbers) {
|
||||||
|
sum += num;
|
||||||
|
}
|
||||||
|
System.out.println("Sum calculated using execute:" + sum);
|
||||||
|
};
|
||||||
|
// Submit the task using execute
|
||||||
|
executorService.execute(task);
|
||||||
|
executorService.shutdown();
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
@ -0,0 +1,31 @@
|
|||||||
|
package com.baeldung.concurrent.executorservice;
|
||||||
|
|
||||||
|
import java.util.concurrent.Callable;
|
||||||
|
import java.util.concurrent.ExecutionException;
|
||||||
|
import java.util.concurrent.ExecutorService;
|
||||||
|
import java.util.concurrent.Executors;
|
||||||
|
import java.util.concurrent.Future;
|
||||||
|
|
||||||
|
public class SubmitExample {
|
||||||
|
public static void main(String[] args) {
|
||||||
|
ExecutorService executorService = Executors.newFixedThreadPool(2);
|
||||||
|
Callable<Integer> task = () -> {
|
||||||
|
int[] numbers = { 1, 2, 3, 4, 5 };
|
||||||
|
int sum = 0;
|
||||||
|
for (int num : numbers) {
|
||||||
|
sum += num;
|
||||||
|
}
|
||||||
|
return sum;
|
||||||
|
};
|
||||||
|
// Submit the task and obtain a Future
|
||||||
|
Future<Integer> result = executorService.submit(task);
|
||||||
|
try {
|
||||||
|
// Get the result
|
||||||
|
int sum = result.get();
|
||||||
|
System.out.println("Sum calculated using submit:" + sum);
|
||||||
|
} catch (InterruptedException | ExecutionException e) {
|
||||||
|
e.printStackTrace();
|
||||||
|
}
|
||||||
|
executorService.shutdown();
|
||||||
|
}
|
||||||
|
}
|
Loading…
x
Reference in New Issue
Block a user