Java并發(fā)編程進(jìn)階之線程控制篇
一、線程的基本概念
1.并行和并發(fā)
并行：多個CPU核心同時(shí)工作，處理不同的任務(wù)。
并發(fā)：多個任務(wù)交替使用 CPU 核心工作，以提高 CPU 利用率。
2.進(jìn)程和線程
進(jìn)程：程序的一次執(zhí)行。由操作系統(tǒng)創(chuàng)建并分配資源，執(zhí)行一個單獨(dú)的任務(wù)。
進(jìn)程是系統(tǒng)進(jìn)行資源分配和調(diào)度的獨(dú)立單位，每個進(jìn)程都有自己的內(nèi)存空間和系統(tǒng)資源。進(jìn)程內(nèi)所有線程共享堆存儲空間，保存程序中定義的對象和常量池。
Windows系統(tǒng)中，每個運(yùn)行的 Java 程序都是一個獨(dú)立的進(jìn)程。
線程：進(jìn)程內(nèi)的執(zhí)行單元，不分配單獨(dú)的資源，執(zhí)行一個單獨(dú)的子任務(wù)。
線程是進(jìn)程內(nèi)調(diào)度和分派的基本單位，共享進(jìn)程資源。每個線程有自己的獨(dú)立的棧存儲空間，保存線程執(zhí)行的方法以及基本類型的數(shù)據(jù)。
運(yùn)行的 Java 程序內(nèi)含至少一個主線程 main ，用戶可以在 Java 程序中自定義并調(diào)用多個線程。 JVM 垃圾回收線程也是一個獨(dú)立的線程。
二、線程的運(yùn)行狀態(tài)
線程除創(chuàng)建狀態(tài) New 和結(jié)束狀態(tài) Terminate 外，主要有以下幾種運(yùn)行狀態(tài)：
①運(yùn)行(Running) ：CPU 正在執(zhí)行線程。
②就緒(Runnable) ：線程一切就緒，等待 CPU 執(zhí)行。
運(yùn)行/就緒狀態(tài) 統(tǒng)稱為可運(yùn)行狀態(tài) Runnable。 Java 程序中，線程在 運(yùn)行/就緒狀態(tài) 之間的切換由 JVM 自動調(diào)度，開發(fā)者無法獲知。線程之間的調(diào)度采用分優(yōu)先級多隊(duì)列時(shí)間片輪轉(zhuǎn)算法。進(jìn)程在執(zhí)行完 CPU 時(shí)間片切換到就緒狀態(tài)之前會先保存自己的狀態(tài)，下次進(jìn)入運(yùn)行狀態(tài)時(shí)再重新加載。
③阻塞(Blocked) ：線程因缺少其他資源，比如請求資源被上鎖而暫停執(zhí)行。在獲得資源后進(jìn)入就緒狀態(tài)。
④等待(Waitting) ：線程接受了等待指令，釋放資源暫停執(zhí)行。在超時(shí)/接受喚醒指令后進(jìn)入就緒狀態(tài)。
三、線程操作實(shí)踐
Runnable 接口內(nèi)唯一聲明了 run 方法，由 Thread 類實(shí)現(xiàn)。開發(fā)者在 run 方法中定義運(yùn)行時(shí)線程將要執(zhí)行的功能，線程開啟后由Java虛擬機(jī)自動調(diào)用并執(zhí)行。如果開發(fā)者主動調(diào)用 run 方法，則只會當(dāng)作普通方法執(zhí)行。
1.線程兩種定義方法
①繼承 Thread 類，重寫 run 方法。
public class MyThread extends Thread {
@Override
public void run() {
System.out.println(Thread.currentThread().getName());
}
}②實(shí)現(xiàn) Runnable 接口，實(shí)現(xiàn) run 方法。推薦使用，避免了單繼承的局限性。
public class MyThread implements Runnable {
@Override
public void run() {
System.out.println(Thread.currentThread().getName());
}
}2.啟動線程
Thread 類定義了 start 方法。調(diào)用 start 方法后，系統(tǒng)會開啟一個新線程進(jìn)入就緒狀態(tài)：由 JVM 會自動對線程進(jìn)行調(diào)度，在運(yùn)行時(shí)調(diào)用并執(zhí)行線程的 run 方法。一個線程只能啟動一次。
①如果自定義線程類繼承 Thread 類，直接啟動。
public class Main {
public static void main(String[] args) {
MyThread t1 = new MyThread();
MyThread t2 = new MyThread("ThreadName");
t1.start();
t2.start();
}
}②如果自定義線程類實(shí)現(xiàn) Runnable 接口，則需要借助 Thread 類啟動線程。
public class Main {
public static void main(String[] args) {
MyThread mythread = new MyThread();
Thread t1 = new Thread(mythread); // 由系統(tǒng)指定默認(rèn)線程名 Thread-X
Thread t2 = new Thread(mythread, "ThreadName"); // 開發(fā)者自定義線程名
t1.start();
t2.start();
}
}3.同時(shí)定義和啟動線程
通過匿名內(nèi)部類方式，我們可以實(shí)現(xiàn)同時(shí)定義和啟動線程的簡潔寫法。
public class Main {
public static void main(String[] args) {
Thread thread = new Thread(new Runnable(){
public void run(){
System.out.println(Thread.currentThread().getName());
}
}).start();
}
}
class Test {
public void method() {
System.out.println(Thread.currentThread().getName());
}
}4.線程彈出與暫停
Thread 類定義了 yield 方法。當(dāng)前線程執(zhí)行到 Thread.yield() 方法，會停止運(yùn)行進(jìn)入就緒狀態(tài)。但線程切換到就緒狀態(tài)后，什么時(shí)候被 JVM 調(diào)度回運(yùn)行狀態(tài)開發(fā)者無法控制。
public class ThreadDemo {
public static void main(String[] args) {
MyThread mythread = new MyThread();
Thread t1 = new Thread(mythread);
Thread t2 = new Thread(mythread);
t1.start();
t2.start();
}
static class MyThread implements Runnable {
@Override
public void run() {
int count = 0;
for (int i = 0; i < 10000; i++) {
Thread.yield(); // 切換到就緒狀態(tài)
count++;
System.out.println(count);
}
}
}
}Thread 類定義了 sleep 方法。當(dāng)前線程執(zhí)行到 Thread.sleep(1000) 方法，會停止運(yùn)行進(jìn)入阻塞狀態(tài)，但仍會保持對象鎖，其他線程不可訪問其資源。直到超時(shí)后進(jìn)入就緒狀態(tài)。調(diào)用 sleep 方法需要捕獲或拋出 InterruptException 異常。
public class ThreadDemo {
public static void main(String[] args) {
MyThread mythread = new MyThread();
Thread t1 = new Thread(mythread);
Thread t2 = new Thread(mythread);
t1.start();
t2.start();
}
static class MyThread implements Runnable {
@Override
public void run() {
int count = 0;
for (int i = 0; i < 10000; i++) {
try{
Thread.sleep(1000); // 當(dāng)前線程暫停 1s
} catch(InterruptException e){
e.printStackTrace();
}
count++;
System.out.println(count);
}
}
}
}5.線程等待與喚醒
①線程等待
當(dāng)前線程執(zhí)行 obj.wait() 方法，線程會停止運(yùn)行并釋放對象鎖 obj，其他線程可以訪問其資源。同時(shí)線程進(jìn)入 obj 對象的等待池，直到被 notify 方法喚醒進(jìn)入就緒狀態(tài)。調(diào)用 wait 方法需要捕獲或拋出 InterruptException 異常。
wait 方法允許計(jì)時(shí)等待。當(dāng)前線程執(zhí)行 obj.wait(1000) 方法，計(jì)時(shí)結(jié)束后線程會被自動喚醒進(jìn)入就緒狀態(tài)。
②線程喚醒
當(dāng)前線程執(zhí)行 obj.notify() 方法，會隨機(jī)從 obj 對象等待池中選擇一個線程喚醒，使其進(jìn)入就緒狀態(tài)。但是 notify 方法不會釋放當(dāng)前進(jìn)程的對象鎖，如果該線程持有 obj 對象的鎖，當(dāng)前線程釋放鎖后被喚醒的其他線程才能被執(zhí)行。如果想被喚醒線程先執(zhí)行，notify 方法后添加 wait 方法釋放鎖。
當(dāng)前線程執(zhí)行 obj.notifyall() 方法，會將所有 obj 對象等待池中所有線程喚醒。
public class ThreadDemo {
public static void main(String[] args) {
MyThread t = new MyThread("t");
synchronized(t) { // 對 t 設(shè)置對象鎖
try {
t.start();
System.out.println("1");
t.wait(); // 當(dāng)前線程釋放 t 鎖，進(jìn)入 t 對象等待池
System.out.println("4");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
static class MyThread extends Thread {
@Override
public void run() {
synchronized (this) { // 對 t 設(shè)置對象鎖
Thread.sleep(1000);
System.out.println("2");
this.notify(); // 隨機(jī)喚醒一個 t 對象等待池中的線程
System.out.println("3");
}
}
}
}6.線程中斷
調(diào)用 t.stop() 方法可以強(qiáng)制終止線程 t 運(yùn)行，但強(qiáng)制中斷線程可能會造成意想不到的問題，已不推薦使用。
目前主要采用設(shè)置線程中斷標(biāo)志的方式，向線程發(fā)送中止信號。由線程自行終止運(yùn)行：
- 執(zhí)行
t.interrupt()方法，將線程 t 中斷標(biāo)志設(shè)為 true 。 - 執(zhí)行
t.isInterrupted()方法，查看線程 t 中斷標(biāo)志。 - 執(zhí)行
t.interrupted()方法，查看線程 t 中斷標(biāo)志然后將其設(shè)為 false 。
public class ThreadDemo {
public static void main(String[] args) {
MyThread mythread = new MyThread();
Thread t = new Thread(mythread);
t.start();
try {
Thread.sleep(500);
} catch (InterruptedException e) {}
t.interrupt(); // 設(shè)置中斷標(biāo)志為 true
}
static class MyThread implements Runnable {
@Override
public void run() {
while (true) {
System.out.print("hello");
if(this.isInterrupted()){ // 查看中斷標(biāo)志，若為 true 結(jié)束循環(huán)
break;
}
}
}
}
}到此這篇關(guān)于Java并發(fā)編程進(jìn)階之線程控制篇的文章就介紹到這了,更多相關(guān)Java線程控制內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
這篇文章主要介紹了淺談Zookeeper開源客戶端框架Curator的相關(guān)內(nèi)容，具有一定參考價(jià)值，需要的朋友可以了解下。2017-10-10
Java中List對象集合按對象中某字段進(jìn)行排序舉例
這篇文章主要給大家介紹了關(guān)于Java中List對象集合按對象中某字段進(jìn)行排序的相關(guān)資料,我們在日常開發(fā)中也經(jīng)常會用到排序算法,文中通過示例代碼介紹的非常詳細(xì),需要的朋友可以參考下2023-07-07
Java數(shù)據(jù)結(jié)構(gòu)之優(yōu)先級隊(duì)列(PriorityQueue)用法詳解
優(yōu)先級隊(duì)列是一種先進(jìn)先出的數(shù)據(jù)結(jié)構(gòu)，操作的數(shù)據(jù)帶有優(yōu)先級，這種數(shù)據(jù)結(jié)構(gòu)就是優(yōu)先級隊(duì)列（PriorityQueue）。本文將詳細(xì)講講Java優(yōu)先級隊(duì)列的用法，感興趣的可以了解一下2022-07-07
這篇文章主要介紹了Mybatis的動態(tài)Sql組合模式詳情，這篇文章從組合模式的角度分析了Mybatis動態(tài)sql的部分，SqlNode是組合模式的Component接口，更多相關(guān)內(nèi)容需要的小伙伴可以參考一下2022-08-08
這篇文章主要為大家介紹了Java中的四種引用，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下，希望能夠給你帶來幫助2021-12-12
這篇文章主要介紹了Java?獲取Word中所有插入和刪除修訂，在?Word?文檔中啟用跟蹤更改功能后，會記錄文檔中的所有編輯行為，例如插入、刪除、替換和格式更改。對插入或刪除的內(nèi)容，本文介紹獲取方法,需要的朋友可以參考下2022-04-04
Idea?編譯并運(yùn)行?Spark?3.1.1?源碼的方法
這篇文章主要介紹了Idea?編譯并運(yùn)行?Spark?3.1.1源碼,本文給大家介紹的非常詳細(xì)，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2022-11-11
feign調(diào)用中文參數(shù)被encode編譯的問題
這篇文章主要介紹了feign調(diào)用中文參數(shù)被encode編譯的問題，具有很好的參考價(jià)值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-03-03
這篇文章主要介紹了SpringBoot Admin使用及心跳檢測原理分析，具有很好的參考價(jià)值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-11-11
基于Spring接口集成Caffeine+Redis兩級緩存
這篇文章主要介紹了基于Spring接口集成Caffeine+Redis兩級緩存，文章圍繞主題展開詳細(xì)的內(nèi)容介紹，具有一定的參考價(jià)值，需要的小伙伴可以參考一下2022-07-07