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

ExecutorService exService = Executors.newFixedThreadPool(5);
 
        for (int i = 0; i < 5; i++) {
 
            GetFullStoryInfo fullStoryInfo = new GetFullStoryInfo(storyNumber,
                    this);
            storyNumber--;
            
                exService.submit(fullStoryInfo);
            
        }
                
        return storyNumber;

exService.shutdown();
        try {
            exService.awaitTermination(10, TimeUnit.SECONDS);
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

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 finished");
                    }
                });
        
        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 + " finished");
                barrier.await();
            } catch (InterruptedException e) {
                e.printStackTrace();
            } catch (BrokenBarrierException e) {
                e.printStackTrace();
            }
        }
        
    }
 
}