Невозможно многопоточность ConcurrentHashMap с использованием параллельного потока [дубликат]

Для тех, кто задается вопросом, где другие потоки, ссылающиеся на класс Deadlock, Java lambdas ведут себя так, как вы написали это:

public class Deadlock {
    public static int lambda1(int i) {
        return i;
    }
    static {
        IntStream.range(0, 10000).parallel().map(new IntUnaryOperator() {
            @Override
            public int applyAsInt(int operand) {
                return lambda1(operand);
            }
        }).count();
        System.out.println("done");
    }
    public static void main(final String[] args) {}
}

С обычными анонимными классами нет взаимоблокировки:

public class Deadlock {
    static {
        IntStream.range(0, 10000).parallel().map(new IntUnaryOperator() {
            @Override
            public int applyAsInt(int operand) {
                return operand;
            }
        }).count();
        System.out.println("done");
    }
    public static void main(final String[] args) {}
}

Существует прекрасное объяснение этой проблемы Andrei Pangin , датированное 07 апреля 2015 года. Здесь доступно , но оно написано на русском языке (я предлагаю просмотрите образцы кода в любом случае - они являются международными). Общая проблема - это блокировка во время инициализации класса.

Вот некоторые цитаты из статьи:

Согласно JLS , каждый класс имеет уникальную блокировку инициализации который фиксируется во время инициализации. Когда другой поток пытается получить доступ к этому классу во время инициализации, он будет заблокирован в блокировке до завершения инициализации. Когда классы инициализируются одновременно, можно получить тупик.

Я написал простую программу, которая вычисляет сумму целых чисел, что она должна печатать?

public class StreamSum {
    static final int SUM = IntStream.range(0, 100).parallel().reduce((n, m) -> n + m).getAsInt();

    public static void main(String[] args) {
        System.out.println(SUM);
    }
} 

Теперь удалите parallel() или заменить лямбда на вызов Integer::sum - что изменится?

Здесь мы снова увидим тупик [были некоторые примеры блокировок в инициализаторах класса, ранее описанных в этой статье]. Из-за операций потока parallel() выполняется в отдельном пуле потоков. Эти потоки пытаются выполнить тело лямбда, которое записывается в байт-код как метод private static внутри класса StreamSum. Но этот метод не может быть выполнен до завершения статического инициализатора класса, который ждет результатов завершения потока.

Что более разумно: этот код работает по-разному в разных средах. Он будет корректно работать на одном процессоре и, скорее всего, будет работать на многопроцессорной машине. Это различие связано с реализацией пула Fork-Join. Вы можете сами убедиться, что вы изменяете параметр -Djava.util.concurrent.ForkJoinPool.common.parallelism=N