job4j.ru - Практика. Ревью. Результат.

💡 Вчера я опубликовал пост о сравнении `Thread` и `Coroutines`. Пример с Java вызвал споры, и некоторые утверждали, что код будет работать корректно. Но писал-то я, и точно знаю, что в этом коде есть ошибка. Поэтому в продолжение темы, давайте разберёмся вместе.

📌 Рассмотрим код:

public static void main(String[] args) throws InterruptedException {
    var flag = new boolean[] { true };
    var job = new Thread(() -> flag[0] = false);
    job.start();
    job.join();
    System.out.println(flag[0]);
}

🤔 Где будет храниться переменная `flag`?

1. Массивы в Java — это объекты. Они создаются в куче (heap), которая общая для всех потоков.
2. Переменная flag — локальная, и её ссылка хранится в стеке метода main. Однако сам массив (объект boolean[]) будет создан в куче.
3. Поток job меняет значение в массиве, который также хранится в куче, доступной обоим потокам.

⚡️ Проблема:

- Гонки данных? ❌ Нет, поток job не зависит от предыдущего состояния.
- Проблема видимости? ✅ Да, потому что массив не синхронизирован. Поток main может не увидеть изменение, сделанное потоком job.

🔍 Может ли решить проблему видимости гарантия `happens-before`?

Чтобы понять, как это работает, вспомним основные случаи happens-before:

1. Прямой порядок внутри потока:
Все действия в одном потоке происходят в том порядке, в котором они написаны в программе. Если действие A предшествует действию B, то "A happens-before B".

2. Синхронизация через `synchronized`:
Разблокировка монитора всегда происходит раньше, чем блокировка тем же монитором другим потоком.

3. Начало и завершение потоков:
- Вызов метода Thread.start() гарантирует, что все действия в вызывающем потоке происходят до любого действия в новом потоке.
- Вызов Thread.join() гарантирует, что все действия в потоке job произойдут до того, как поток main продолжит выполнение после join().

4. Инициализация переменных:
Конструктор объекта гарантирует, что все его действия будут видны всем потокам, которые получают доступ к объекту.

5. Использование `volatile` переменных:
Запись в volatile переменную гарантирует, что это действие происходит до всех последующих чтений этой переменной другими потоками.

Однако, даже несмотря на то, что job.join() заставляет поток main дождаться завершения потока job, операция записи в массив flag[0] может не быть видимой для потока main, так как массив не защищён ни синхронизацией, ни использованием volatile.

📝 Заключение:

Хотя вызов Thread.join() создаёт гарантии happens-before, в многопоточном окружении всегда нужно учитывать особенности модели памяти Java. Особенно это важно при работе с массивами и другими сложными структурами данных. Чтобы избежать проблем с видимостью, всегда стоит использовать дополнительные механизмы синхронизации, такие как volatile или synchronized.

👍5🤩1

827 views10:07