Java: Ожидание завершения пула потоков

import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
 
public class Main {
    
    static final int THREADS_NUMBER = 5;
    
    public static void main(String[] args) {
        final CyclicBarrier barrier = new CyclicBarrier(THREADS_NUMBER, 
                new Runnable() {
                    @Override
                    public void run() {
                        System.out.println("All threads are completed");
                    }
                });
        
        ExecutorService exService = Executors.newFixedThreadPool(THREADS_NUMBER);
        
        for (int i = THREADS_NUMBER; i > 0; i--) {
            Task task = new Task(i, barrier);
            exService.submit(task);
        }
        
        exService.shutdown();
    }
    
    private static class Task implements Runnable {
        
        int i;
        CyclicBarrier barrier;
        
        public Task(int i, CyclicBarrier barrier) {
            this.i = i;
            this.barrier = barrier;
        }
        
        @Override
        public void run() {
            try {
                Thread.sleep(i * 1000);
                System.out.println("Thread #" + i + " is completed");
                barrier.await();
            } catch (InterruptedException e) {
                e.printStackTrace();
            } catch (BrokenBarrierException e) {
                e.printStackTrace();
            }
        }
        
    }
 
}