Какие знаешь классы для многопоточности в Java?

Основные классы для многопоточности в Java

В Java многопоточность реализована через java.lang.Thread и поддержку java.util.concurrent (JUC), которая предоставляет высокоуровневые инструменты для параллельного программирования. Рассмотрим ключевые классы по категориям.

Базовые механизмы и синхронизация

Thread — фундаментальный класс для создания и управления потоками.

Thread thread = new Thread(() -> System.out.println("Выполняется в потоке"));
thread.start();

Runnable — интерфейс для определения задачи, выполняемой в потоке.

synchronized — ключевое слово для синхронизации методов или блоков кода, обеспечивающее взаимное исключение.

Классы из пакета java.util.concurrent.locks

ReentrantLock — альтернатива synchronized с дополнительными возможностями (например, честная блокировка, прерываемое ожидание).

Lock lock = new ReentrantLock();
lock.lock();
try {
    // критическая секция
} finally {
    lock.unlock();
}

ReentrantReadWriteLock — разделяет блокировки на чтение (могут выполняться параллельно) и запись (эксклюзивная).

StampedLock — оптимистичные блокировки с контролем версий, часто эффективнее для read-heavy сценариев.

Примитивы синхронизации

Semaphore — ограничивает количество потоков, одновременно получающих доступ к ресурсу.

Semaphore semaphore = new Semaphore(5); // максимум 5 потоков
semaphore.acquire();
// доступ к ресурсу
semaphore.release();

CountDownLatch — позволяет потоку ждать завершения операций в других потоках.

CyclicBarrier — синхронизирует группу потоков в общей точке, после чего они продолжают выполнение.

Phaser — гибкий барьер для многофазной синхронизации.

Атомарные классы (java.util.concurrent.atomic)

Обеспечивают атомарные операции без явной синхронизации, используя compare-and-swap (CAS).

AtomicInteger, AtomicLong, AtomicBoolean — для примитивных типов.

AtomicReference — для атомарных операций с объектами.

AtomicIntegerArray, AtomicLongArray — для массивов.

LongAdder и DoubleAdder — высокопроизводительные альтернативы для счётчиков при высокой конкуренции.

Коллекции для многопоточности

ConcurrentHashMap — потокобезопасная хэш-таблица с сегментированием, обеспечивающая высокую производительность при конкурентном доступе.

CopyOnWriteArrayList — список, где изменения создают новую копию, идеален для read-heavy сценариев.

BlockingQueue — интерфейс для блокирующих очередей (например, ArrayBlockingQueue, LinkedBlockingQueue).

ConcurrentLinkedQueue — неблокирующая потокобезопасная очередь на основе CAS.

Пул потоков и Executors

ExecutorService — интерфейс для управления пулами потоков.

ThreadPoolExecutor — гибкая реализация пула потоков.

Executors — фабричные методы для создания пулов:

• newFixedThreadPool — фиксированное количество потоков.
• newCachedThreadPool — кэширующий пул с динамическим размером.
• newSingleThreadExecutor — один поток.
• newScheduledThreadPool — планировщик для отложенного или периодического выполнения.

ForkJoinPool — пул для задач типа fork/join, оптимизированный для рекурсивного разделения задач.

Future и асинхронные вычисления

Future — интерфейс для представления результата асинхронной операции.

CompletableFuture (Java 8+) — мощный API для асинхронного программирования с цепочками вызовов, комбинированием результатов и обработкой исключений.

CompletableFuture.supplyAsync(() -> "Результат")
    .thenApplyAsync(String::toUpperCase)
    .thenAccept(System.out::println);

Дополнительные утилиты

Exchanger — позволяет двум потокам обмениваться данными в точке встречи.

ThreadLocal — предоставляет локальную переменную для каждого потока.

Важные замечания

1. Классы из java.util.concurrent обычно предпочтительнее низкоуровневых конструкций (wait/notify, synchronized), так как они предлагают лучшую производительность, контроль и уменьшают вероятность ошибок.
2. При использовании ForkJoinPool важно правильно разделять задачи для эффективного использования рабочих потоков.
3. CompletableFuture стал стандартом для асинхронного программирования в современном Java благодаря своей гибкости.

Выбор конкретного класса зависит от задачи: для простой синхронизации достаточно synchronized, для сложных сценариев — ReentrantLock, для коллекций — ConcurrentHashMap, для асинхронных операций — CompletableFuture. Понимание этих инструментов позволяет создавать эффективные, масштабируемые и надёжные многопоточные приложения.