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

import java.util.Arrays;
import java.util.Random;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
 
/**
 * @author mutagen
 */
public class ArrayInThreads {
 
    /**
     * @param args the command line arguments
     */
    public static void main(String[] args) {
        Random r = new Random();
        int[] arr = new int[1000];
        for (int i = 0; i < arr.length; i++) {
            arr[i] = r.nextInt(100);
        }
        System.out.println(Arrays.toString(arr));
        ExecutorService es = Executors.newFixedThreadPool(3);
 
        for (int i = 0; i < arr.length; i += 3) {
            if (i < arr.length) {
                es.submit(new ArrReeader(arr, i));
            }
            if (i + 1 < arr.length) {
                es.submit(new ArrReeader(arr, i + 1));
            }
            if (i + 2 < arr.length) {
                es.submit(new ArrReeader(arr, i + 2));
            }
        }
        es.shutdown();
 
    }
 
    static class ArrReeader implements Runnable {
 
        private int[] arr;
        private int id;
 
        public ArrReeader(int[] arr, int id) {
            this.arr = arr;
            this.id = id;
        }
 
        @Override
        public void run() {
            try {
                Thread.sleep(new Random().nextInt(5000));
            } catch (InterruptedException ex) {
            }
            synchronized (this) {
                System.out.println(Thread.currentThread().getName() + " id: " + id + " value: " + arr[id]);
            }
        }
    }
}

executor.shutdown();
        executor.awaitTermination(1, TimeUnit.HOURS);

es.shutdown();
while (!es.isTerminated()) {}