Перейти на PRO

Что такое Phaser в Java?

Тип вопроса: Java Core Вероятность: 10% Категория: Java Разработчик

Ответ

Phaser — это гибкий синхронизатор из пакета java.util.concurrent, который управляет выполнением потоков в несколько фаз. В отличие от CountDownLatch и CyclicBarrier, он позволяет динамически изменять количество потоков-участников между фазами.

Основные принципы:

  • Потоки регистрируются в фазере через register() или bulkRegister().
  • Основной метод arriveAndAwaitAdvance() — поток сообщает о прибытии на текущую фазу и блокируется, пока все зарегистрированные потоки не сделают то же самое.
  • Поток может покинуть пул участников, вызвав arriveAndDeregister().
  • Количество фаз (итераций) не ограничено.

Пример использования:

import java.util.concurrent.Phaser;

public class PhaserExample {
    public static void main(String[] args) {
        // Создаем Phaser с 3 зарегистрированными сторонами (потоками)
        Phaser phaser = new Phaser(3);

        for (int i = 0; i < 3; i++) {
            final int threadId = i;
            new Thread(() -> {
                System.out.println("Поток " + threadId + " прибыл на фазу " + phaser.getPhase());
                phaser.arriveAndAwaitAdvance(); // Ждем всех
                System.out.println("Поток " + threadId + " выполняет работу после фазы " + (phaser.getPhase()-1));
                // Второй поток покидает синхронизацию после первой фазы
                if (threadId == 1) {
                    phaser.arriveAndDeregister();
                } else {
                    phaser.arriveAndAwaitAdvance(); // Остальные ждут вторую фазу
                }
            }).start();
        }
    }
}

Когда использовать: Для сложных, многоэтапных задач (например, обработка данных), где количество рабочих потоков может меняться на разных этапах.

Ответ 18+ 🔞

Да ты посмотри, какая хитрая жопа этот Phaser! Это ж как будто барьер, только на стероидах, блядь. Ну представь: CountDownLatch — это разовый выстрел, CyclicBarrier — карусель, а этот уродец — вообще трансформер, ёпта.

В чём прикол, блядь:

  • Потоки туда-сюда шляются, регистрируются через register(), а то и пачками (bulkRegister()), как будто на вечеринку заходят.
  • Главный трюк — arriveAndAwaitAdvance(). Это типа "я пришёл, сука, и буду тут стоять, пока все остальные лохи не подтянутся".
  • А если надоело — arriveAndDeregister() и пошёл нахуй, выбыл из игры. И все остальные дальше синхронизируются уже без тебя!
  • Фаз этих — овердохуища, счётчик просто по кругу идёт.

Смотри, как это в коде выглядит, реальная жизнь:

import java.util.concurrent.Phaser;

public class PhaserExample {
    public static void main(String[] args) {
        // Стартуем с тремя бойцами
        Phaser phaser = new Phaser(3);

        for (int i = 0; i < 3; i++) {
            final int threadId = i;
            new Thread(() -> {
                System.out.println("Поток " + threadId + " прибыл на фазу " + phaser.getPhase());
                phaser.arriveAndAwaitAdvance(); // Тормозим, ждём всех
                System.out.println("Поток " + threadId + " выполняет работу после фазы " + (phaser.getPhase()-1));
                // А вот этот пидарас (поток №1) после первой фазы сваливает!
                if (threadId == 1) {
                    phaser.arriveAndDeregister(); // Всё, я свободен, прощайте!
                } else {
                    phaser.arriveAndAwaitAdvance(); // А мы, лохи, ждём вторую фазу
                }
            }).start();
        }
    }
}

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

© ХакСобесов, 2026
support@hacksobesov.com