Что такое Thread Scheduler?

Thread Scheduler в Java

Thread Scheduler — это механизм операционной системы, который определяет, какой поток (thread) в какой момент времени получит доступ к процессорному ядру. В контексте Java это управляется как JVM, так и ОС.

Как работает Thread Scheduler

Thread Scheduler использует алгоритм временного распределения (time slicing), где каждому потоку выделяется определённый промежуток времени (time quantum или time slice) для выполнения своего кода. После истечения этого времени поток приостанавливается, и процессор переключается на другой поток.

public class ThreadSchedulerExample {
    public static void main(String[] args) {
        // Создание двух потоков с одинаковым приоритетом
        Thread thread1 = new Thread(() -> {
            for (int i = 0; i < 5; i++) {
                System.out.println("Поток 1: " + i);
            }
        });
        
        Thread thread2 = new Thread(() -> {
            for (int i = 0; i < 5; i++) {
                System.out.println("Поток 2: " + i);
            }
        });
        
        thread1.start();
        thread2.start();
    }
}

Приоритеты потоков

Thread Scheduler учитывает приоритет потока при принятии решения о назначении процессорного времени. В Java приоритеты варьируются от 1 (MIN_PRIORITY) до 10 (MAX_PRIORITY), по умолчанию — 5 (NORM_PRIORITY).

public class PriorityExample {
    public static void main(String[] args) {
        Thread highPriority = new Thread(() -> {
            System.out.println("Высокий приоритет");
        });
        
        Thread lowPriority = new Thread(() -> {
            System.out.println("Низкий приоритет");
        });
        
        highPriority.setPriority(Thread.MAX_PRIORITY);
        lowPriority.setPriority(Thread.MIN_PRIORITY);
        
        highPriority.start();
        lowPriority.start();
    }
}

Важно: приоритеты — это всего лишь подсказки для Thread Scheduler. Гарантировать порядок выполнения нельзя.

Состояния потока

Thread Scheduler управляет потоками через их состояния:

• NEW — поток создан, но ещё не запущен
• RUNNABLE — поток готов к выполнению или выполняется
• WAITING — поток ждёт уведомления от другого потока
• TIMED_WAITING — поток ждёт с таймаутом
• BLOCKED — поток ждёт блокировки (монитора)
• TERMINATED — поток завершил работу

Детали реализации в разных ОС

На уровне JVM используется 1:1 threading model, где каждый Java-поток соответствует одному потоку ОС. Это означает, что:

• Решение о переключении потоков принимает операционная система
• JVM не может напрямую контролировать, какой поток выполнится в конкретный момент
• Поведение зависит от планировщика ОС (Linux, Windows, macOS имеют разные алгоритмы)

Проблемы и лучшие практики

Основная проблема — недетерминированность. Нельзя гарантировать порядок выполнения, поэтому нужна синхронизация:

public class SynchronizedExample {
    private static int counter = 0;
    
    public synchronized static void increment() {
        counter++;
    }
    
    public static void main(String[] args) throws InterruptedException {
        Thread t1 = new Thread(() -> {
            for (int i = 0; i < 1000; i++) increment();
        });
        
        Thread t2 = new Thread(() -> {
            for (int i = 0; i < 1000; i++) increment();
        });
        
        t1.start();
        t2.start();
        t1.join();
        t2.join();
        
        System.out.println("Counter: " + counter); // Всегда 2000
    }
}

Заключение

Thread Scheduler — фундаментальный компонент многопоточного программирования в Java. Понимание его работы критично для написания потокобезопасного кода и избежания race conditions и deadlocks.