Spring + многопоточность (воркеры)

 @Scheduled(fixedDelay = 10000L)
    public void controller() {
        Date date = new Date();
        System.out.println("Run controller... [" + dateFormat.format(date) + "]");
 
        ArrayList<Future<String>> re = new ArrayList<Future<String>>();
        for (int i = 0; i < 10; i++) {
            re.add(asyncService.asyncWithReturn("Thread " + Integer.toString(i)));
        }
 
        ArrayList<Future<String>> rem = new ArrayList<Future<String>>();
        System.out.println("START");
        try {
            boolean fl;
            while (true) {
                Thread.sleep(10L);
                fl = true;
 
                for (Future<String> r : re) {
                    if (r.isDone()) {
                        System.out.println("Result: " + r.get());
                        rem.add(r);
                    } else {
                        fl = false;
                    }
                }
                for (Future<String> r : rem) {
                    re.remove(r);
                }
                rem.clear();
 
                if (fl) {
                    System.out.println("END");
                    break;
                }
            }
        } catch (Exception ex) {
            ex.printStackTrace();
        }
    }

    @Test
    public void test() {
        ExecutorService executorService = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors());
        List<Supplier<X>> workers = ...;
        List<CompletableFuture<X>> collect = workers
                .stream()
                .map(worker -> CompletableFuture.supplyAsync(worker, executorService))
                .collect(Collectors.toList());
        CompletableFuture.allOf(collect.toArray(new CompletableFuture[0]))
                .join();
        List<X> values = collect
                .stream()
                .map(CompletableFuture::join)
                .collect(Collectors.toList());
    }