Как работает многопоточность в Java?

Question

Accepted Answer

**Многопоточность** позволяет программе на Java запускать несколько потоков одновременно, обеспечивая параллелизм (использование нескольких ядер CPU) и отзывчивость (выполнение работы без блокировки). Java имеет встроенную поддержку потоков — но общее изменяемое состояние вводит сложность (race conditions), которую необходимо тщательно управлять. ## Создание потоков ```java // 1. Implement Runnable (preferred — separates task from thread) Runnable task = () -> System.out.println("running on " + Thread.currentThread().getName()); Thread t = new Thread(task); t.start(); // start() runs it on a NEW thread (run() would run on the CURRENT thread!) // 2. modern: use an ExecutorService instead of raw threads ExecutorService executor = Executors.newFixedThreadPool(4); executor.submit(task); ``` **Главная ошибка:** вызывайте `start()` (порождает новый поток), а не `run()` (которая просто выполняет код в текущем потоке синхронно). ## Основная проблема: race conditions ```java // ❌ multiple threads modifying shared state → unpredictable results class Counter { int count = 0; void increment() { count++; } // NOT atomic: read → add → write (can interleave) } // 1000 threads each incrementing 1000 times → final count is often < 1,000,000! ``` `count++` на самом деле это три операции (читать, увеличивать, писать). Когда потоки чередуются, обновления теряются — **race condition**. Это центральная проблема параллелизма: общее изменяемое состояние, доступное нескольким потокам без координации. ## Решения для безопасного общего состояния ```java // 1. synchronized — only one thread in the method/block at a time (a lock) synchronized void increment() { count++; } // 2. atomic classes — lock-free atomic operations AtomicInteger count = new AtomicInteger(0); count.incrementAndGet(); // atomic, thread-safe, efficient // 3. concurrent collections — built for multi-threaded access ConcurrentHashMap map = new ConcurrentHashMap<>(); // 4. immutability — immutable objects are inherently thread-safe (nothing to corrupt) ``` ## Синхронизация потоков ```java t.join(); // wait for thread t to finish Thread.sleep(1000); // pause the current thread // also: wait()/notify(), CountDownLatch, locks, etc. for coordination ``` ## Современный подход: не управляйте сырыми потоками ```text ✓ Use ExecutorService / thread pools (not new Thread() per task — expensive) ✓ Use CompletableFuture for async composition ✓ Use concurrent collections and atomic classes over manual synchronization ✓ Java 21+ adds Virtual Threads — millions of lightweight threads for I/O concurrency ``` ## Почему это важно Многопоточность позволяет программам Java использовать несколько ядер и оставаться отзывчивыми, но это также одна из самых сложных областей для правильной реализации — **race conditions** из несинхронизированного общего изменяемого состояния вызывают прерывистые, трудно воспроизводимые ошибки. Понимание того, как работают потоки (`start()` vs `run()`), основной проблемы race conditions (почему `count++` небезопасен) и средств обеспечения безопасности (`synchronized`, атомарные классы, параллельные коллекции, неизменяемость) необходимо для написания правильного параллельного кода. Современная практика отдаёт предпочтение абстракциям более высокого уровня (ExecutorService, CompletableFuture, виртуальные потоки) вместо управления сырыми потоками. Это критические знания для серверной Java и высокопроизводительных приложений, а также глубокая и часто проверяемая тема, которая отличает компетентных разработчиков от экспертов.