Странное поведение кодового кода

Question

В настоящее время я изучаю параллелизм Java. И я очень удивлен тем, как ведет себя код.

import java.util.concurrent.*; 

public class Exercise { 
    static int counter = 0; 

    static synchronized int getAndIncrement() { 
     return counter++; 
    } 

    static class Improper implements Runnable { 

     @Override 
     public void run() { 
      for (int i = 0; i < 300; i++) { 
       getAndIncrement(); 
      } 
     } 
    } 


    public static void main(String[] args) { 
     ExecutorService executorService = Executors.newFixedThreadPool(3); 
     for (int i = 0; i < 300; i++) { 
      executorService.submit(new Improper()); 
     } 
     executorService.shutdown(); 
     System.out.println(counter); 
    } 
} 

Не должно ли оно выводить 90000 все время? Вместо этого результат различается все время.

Answer 1

1. executorService.shutdown() не дожидаться прекращения службы. Вам нужно позвонить в awaitTermination.

2. Вы получаете доступ к counter от основного метода без блокировки. Я думаю, что вы вряд ли избегаете гонку данных, если вы ожидаете закрытия службы-исполнителя, но будьте предупреждены, что в общем случае вы должны синхронизировать все , обращаясь к общей переменной, а не только к записи, чтобы иметь какие-либо гарантии видимости из модели памяти Java.

Answer 2

Вы не ждите все ваши занесена задачи прекратить см Javadoc для ExecutorService.html#shutdown. Таким образом, получение произвольного результата каждый раз является ожидаемым поведением.

Answer 3

Вам нужно убедиться, что все задачи успели закончить. Использовать awaitTermination

public static void main(String[] args) throws InterruptedException { 
    ExecutorService executorService = Executors.newFixedThreadPool(3); 
    for (int i = 0; i < 300; i++) { 
     executorService.submit(new Improper()); 
    } 
    executorService.shutdown(); 
    executorService.awaitTermination(2, TimeUnit.SECONDS); 
    System.out.println(counter); 
}