выкинул из кода все лишнее:
@RestController
@Scope("prototype")
public class Test {
private static List<DiOr> deliveryOrderList;
private static List<TK> objList;
private static ExecutorService executor;
public Test() {
objList = new ArrayList<TK>();
objList.add(new Obj1());
objList.add(new Obj2());
// неизвестно сколько может быть ...
executor = Executors.newFixedThreadPool(objList.size());
}
@RequestMapping(value = "/test", method = RequestMethod.GET, produces = "application/json;charset=UTF-8")
public synchronized static List<DiOr> getTest() {
deliveryOrderList = new ArrayList<>();
objList.stream().forEach((s) -> {
final TK finalS = s;
executor.submit(() -> {
deliveryOrderList.add(finalS.get());
});
});
executor.shutdown();
executor.awaitTermination(2, TimeUnit.MINUTES);
return deliveryOrderList;
}
}
в итоге хочу добиться, что бы при обращении к урл /test, объекты созданные в конструкторе, запускали один метод (каждый метод выполняется за разное время) в отдельном потоке кого либо пула. после завершения выполнения всех потоков пула, метод возвращал некий json (тут проблем нет).
Поскольку возвращаемый объект статичный, если убрать synchronized static - при одновременном запросе к урл более одного раза, будут возвращаться неверные данные, какой то метод отработает, какой то не успеет и тд.
Когда дописываю synchronized static (как в примере) все выполняется корректно, но как я понимаю образуется очередь на выполнение этих пулов... и при одновременном запросе в данному урл, из за очереди, значительно увеличивается время работы, для тех кто стоит в этой очереди. Для меня это критично...
Как лучше решать такую задачку?
finalS.get()
что делает ?forEach()
нужно заменить наparallelStram().map()