Java - 線程調度器

你好，未來的Java巫師們！今天，我們將進入Java線程調度器的精彩世界。如果你是編程新手，也別擔心——我將成為你的友好指南，我們將一步一步地解決這個主題。所以，拿起你的虛擬魔杖（鍵盤），我們一起深入探險吧！

Java - Thread Scheduler

線程調度是什麼？

在我們深入細節之前，讓我們先了解線程調度是關於什麼的。想象一下，你是一個馬戲團的環場主持人（那就是Java運行時），你有多個表演者（線程）等待展示他們的節目。你的工作是決定哪個表演者上台以及上台多久。這基本上就是線程調度在Java中的工作——它管理多個線程，並決定哪個線程何時運行。

為什麼我們需要線程調度？

你可能在想，“為什麼不能讓所有線程想運行就運行呢？”嗯，想象一下如果所有馬戲團表演者都試圖同時表演——那將是混亂的！線程調度有助於維持秩序，確保公平的资源分配，並提高整體系統性能。

Java的線程調度器

Java有一個內置的線程調度器，可以為我們處理這項複雜的任務。它結合了操作系統級别的調度和自己的算法來有效地管理線程。

線程狀態

在我們深入調度之前，讓我們快速複習一下線程可能處於的不同狀態：

新建
可運行
執行中
阻塞/等待
結束

調度器負責在這些狀態之間移動線程。

基本線程創建和調度

讓我們從一個簡單的例子開始，看看Java是如何創建和調度線程的：

public class SimpleThreadExample {
public static void main(String[] args) {
Thread thread1 = new Thread(() -> {
for (int i = 0; i < 5; i++) {
System.out.println("Thread 1: " + i);
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
});

Thread thread2 = new Thread(() -> {
for (int i = 0; i < 5; i++) {
System.out.println("Thread 2: " + i);
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
});

thread1.start();
thread2.start();
}
}

在這個例子中，我們創建了兩個線程，它們打印從0到4的數字。Thread.sleep(1000)調用使每個線程在打印之間暫停1秒。

當你運行這個程序時，你會注意到輸出可能不是完美交替的順序。這是因為Java調度器正在決定何時在線程之間切換！

線程優先級

Java允許我們給調度器提示哪些線程更重要。我們可以使用setPriority()方法設置線程優先級。讓我們修改我們之前的例子：

public class ThreadPriorityExample {
public static void main(String[] args) {
Thread thread1 = new Thread(() -> {
for (int i = 0; i < 5; i++) {
System.out.println("低優先級線程: " + i);
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
});

Thread thread2 = new Thread(() -> {
for (int i = 0; i < 5; i++) {
System.out.println("高優先級線程: " + i);
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
});

thread1.setPriority(Thread.MIN_PRIORITY);
thread2.setPriority(Thread.MAX_PRIORITY);

thread1.start();
thread2.start();
}
}

在這個例子中，我們將thread1設置為最低優先級，將thread2設置為最高優先級。雖然這不能保證thread2總是首先運行或運行得更頻繁，但它確實給調度器一個提示，在可能的情況下應優先考慮thread2。

ScheduledExecutorService

現在，讓我們看看如何使用ScheduledExecutorService以更先進的方式調度線程。這個強大的工具允許我們安排任務在延遲後運行或以固定的間隔運行。

import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

public class ScheduledExecutorExample {
public static void main(String[] args) {
ScheduledExecutorService executor = Executors.newScheduledThreadPool(2);

Runnable task1 = () -> System.out.println("任務1在: " + System.currentTimeMillis() + "執行");
Runnable task2 = () -> System.out.println("任務2在: " + System.currentTimeMillis() + "執行");

executor.schedule(task1, 5, TimeUnit.SECONDS);
executor.scheduleAtFixedRate(task2, 0, 2, TimeUnit.SECONDS);

try {
Thread.sleep(10000);
} catch (InterruptedException e) {
e.printStackTrace();
}

executor.shutdown();
}
}

在這個例子中：

我們創建了一個具有2個線程的ScheduledExecutorService。
task1被安排在5秒延遲後運行一次。
task2被安排從0秒開始每2秒運行一次。
我們讓程序運行10秒後關閉執行器。

這演示了我們如何精確控制任務何時以及多頻繁地運行。

ScheduledExecutorService方法

以下是ScheduledExecutorService提供的主要方法：

方法	描述
`schedule(Runnable, long, TimeUnit)`	安排一個一次性任務在指定的延遲後運行
`scheduleAtFixedRate(Runnable, long, long, TimeUnit)`	安排一個任務定期運行，每次執行之間有固定的延遲
`scheduleWithFixedDelay(Runnable, long, long, TimeUnit)`	安排一個任務定期運行，每次執行結束和下一次開始之間有固定的延遲

結論

就是這樣，各位！我們已經走過了Java線程調度的基礎，從簡單的線程創建到使用ScheduledExecutorService的先進調度。請記住，線程調度就像指揮交響樂團一樣——都是關於和諧與時機。

當你繼續你的Java冒險時，你將發現更多調整線程行為的方法。但現在，為你自己鼓掌——你已經邁出了並發編程世界的巨大一步！

繼續練習，保持好奇心，最重要的是，編程愉快！誰知道呢，也許有一天你將會編寫下一代Java線程調度器。在那之前，編鸺"}

Credits: Image by storyset