Can someone help me out
package com.codegym.task.task28.task2812;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
/*
shutdownNow!
*/
public class Solution {
public static void main(String[] args) throws InterruptedException {
ExecutorService executor = Executors.newFixedThreadPool(5);
List<Future<String>> list = new ArrayList<>();
for (int i = 1; i <= 10; i++) {
final int localId = i;
Future future = executor.submit(new Runnable() {
public void run() {
doExpensiveOperation(localId);
}
});
list.add(future);
}
executor.shutdownNow();
//executor.awaitTermination(5, TimeUnit.SECONDS);
for(Future<String> future: list){
if(!future.isDone())System.out.println(future.toString().split("\\[" )[0]+ " was not completed");
}
}
private static void doExpensiveOperation(int localId) {
System.out.println(Thread.currentThread().getName() + ", localId="+localId);
}
}
//pool-1-thread-1, localId=1
//pool-1-thread-2, localId=2
//pool-1-thread-3, localId=3
//pool-1-thread-4, localId=4
//pool-1-thread-5, localId=5
//java.util.concurrent.FutureTask@7e6cbb7a was not completed
//java.util.concurrent.FutureTask@7c3df479 was not completed
//java.util.concurrent.FutureTask@7106e68e was not completed
//java.util.concurrent.FutureTask@7eda2dbb was not completed
//java.util.concurrent.FutureTask@6576fe71 was not completed