у меня самый долгий поток не даёт вывести отработавшие фьючерсы, допустим я запускаю метот test в 4 потока первых 3 зависают на 1 сек, а 4й на 10сек и вот пока 4 поток не отработает фьючер ничего не выведет, хотя следующие три потока заполнит работой.
Вывод:
sleep: 1000
sleep: 1000
sleep: 1000
sleep: 10000
sleep: 1000
sleep: 1000
sleep: 1000
sleep: 1000
sleep: 10000
sleep: 1000
sleep: 1000
sleep: 1000
sleep: 1000
а мне бы хотелось узнать, как это можно исправить на такой результат:
sleep: 1000
sleep: 1000
sleep: 1000
sleep: 1000
sleep: 1000
sleep: 1000
sleep: 1000
sleep: 1000
sleep: 1000
sleep: 1000
sleep: 1000
sleep: 10000
sleep: 10000
Немного кода:
public static void main(String[] args) {
TEEE testClass = TEEE.getInstance();
ExecutorService executorService = Executors.newFixedThreadPool(4);
List<Future> futures = new ArrayList<>();
List<Integer> integers = new ArrayList<>();
integers.add(1000);
integers.add(1000);
integers.add(1000);
integers.add(10000);
integers.add(1000);
integers.add(1000);
integers.add(1000);
integers.add(1000);
integers.add(10000);
integers.add(1000);
integers.add(1000);
integers.add(1000);
integers.add(1000);
integers.forEach(x -> futures.add(executorService.submit(() -> testClass.test(x))));
futures.forEach(x -> {
try {
System.out.println("sleep: " + x.get());
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
});
}
public class TEEE {
private static TEEE instance;
public Integer test(Integer in) {
try {
Thread.sleep(Long.valueOf(in));
} catch (InterruptedException e) {
e.printStackTrace();
}
return in;
}
public static TEEE getInstance() {
if (instance == null) {
instance = new TEEE();
}
return instance;
}
}
x.get()