高并發之——線程與多線程

一、線程與多線程

1.線程

在作業系統中，線程是比程序更小的能夠獨立運作的基本機關。同時，它也是CPU排程的基本機關。線程本身基本上不擁有系統資源，隻是擁有一些在運作時需要用到的系統資源，例如程式計數器，寄存器和棧等。一個程序中的所有線程可以共享程序中的所有資源。

2.多線程

多線程可以了解為在同一個程式中能夠同時運作多個不同的線程來執行不同的任務，這些線程可以同時利用CPU的多個核心運作。多線程程式設計能夠最大限度的利用CPU的資源。如果某一個線程的處理不需要占用CPU資源時（例如IO線程），可以使目前線程讓出CPU資源來讓其他線程能夠擷取到CPU資源，進而能夠執行其他線程對應的任務，達到最大化利用CPU資源的目的。

二、實作線程的方式

在Java中，實作線程的方式大體上分為三種，通過繼承Thread類、實作Runnable接口，實作Callable接口。簡單的示例代碼分别如下所示。

繼承Thread類代碼

package io.binghe.concurrent.executor.test;
 
/**
 * @author binghe
 * @version 1.0.0
 * @description 繼承Thread實作線程
 */
public class ThreadTest extends Thread {
    @Override
    public void run() {
        //TODO 在此寫線上程中執行的業務邏輯
    }
}

實作Runnable接口代碼

package io.binghe.concurrent.executor.test;
 
/**
 * @author binghe
 * @version 1.0.0
 * @description 實作Runnable實作線程
 */
public class RunnableTest implements Runnable {
    @Override
    public void run() {
        //TODO 在此寫線上程中執行的業務邏輯
    }
}

實作Callable接口代碼

package io.binghe.concurrent.executor.test;
 
import java.util.concurrent.Callable;
 
/**
 * @author binghe
 * @version 1.0.0
 * @description 實作Callable實作線程
 */
public class CallableTest implements Callable<String> {
    @Override
    public String call() throws Exception {
        //TODO 在此寫線上程中執行的業務邏輯
        return null;
    }
}

三、線程的生命周期

1.生命周期

一個線程從建立，到最終的消亡，需要經曆多種不同的狀态，而這些不同的線程狀态，由始至終也構成了線程生命周期的不同階段。線程的生命周期可以總結為下圖。

其中，幾個重要的狀态如下所示。

NEW：初始狀态，線程被建構，但是還沒有調用start()方法。
RUNNABLE：可運作狀态，可運作狀态可以包括：運作中狀态和就緒狀态。
BLOCKED：阻塞狀态，處于這個狀态的線程需要等待其他線程釋放鎖或者等待進入synchronized。
WAITING：表示等待狀态，處于該狀态的線程需要等待其他線程對其進行通知或中斷等操作，進而進入下一個狀态。
TIME_WAITING：逾時等待狀态。可以在一定的時間自行傳回。
TERMINATED：終止狀态，目前線程執行完畢。

2.代碼示例

為了更好的了解線程的生命周期，以及生命周期中的各個狀态，接下來使用代碼示例來輸出線程的每個狀态資訊。

WaitingTime

建立WaitingTime類，在while(true)循環中調用TimeUnit.SECONDS.sleep(long)方法來驗證線程的TIMED_WARTING狀态，代碼如下所示。

package io.binghe.concurrent.executor.state;
 
import java.util.concurrent.TimeUnit;
 
/**
 * @author binghe
 * @version 1.0.0
 * @description 線程不斷休眠
 */
public class WaitingTime implements Runnable{
    @Override
    public void run() {
        while (true){
            waitSecond(200);
        }
    }
 
    //線程等待多少秒
    public static final void waitSecond(long seconds){
        try {
            TimeUnit.SECONDS.sleep(seconds);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

WaitingState

建立WaitingState類，此線程會在一個while(true)循環中，擷取目前類Class對象的synchronized鎖，也就是說，這個類無論建立多少個執行個體，synchronized鎖都是同一個，并且線程會處于等待狀态。接下來，在synchronized中使用目前類的Class對象的wait()方法，來驗證線程的WAITING狀态，代碼如下所示。

package io.binghe.concurrent.executor.state;
 
/**
 * @author binghe
 * @version 1.0.0
 * @description 線程在Warting上等待
 */
public class WaitingState implements Runnable {
    @Override
    public void run() {
        while (true){
            synchronized (WaitingState.class){
                try {
                    WaitingState.class.wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

BlockedThread

BlockedThread主要是在synchronized代碼塊中的while(true)循環中調用TimeUnit.SECONDS.sleep(long)方法來驗證線程的BLOCKED狀态。當啟動兩個BlockedThread線程時，首先啟動的線程會處于TIMED_WAITING狀态，後啟動的線程會處于BLOCKED狀态。代碼如下所示。

package io.binghe.concurrent.executor.state;
 
/**
 * @author binghe
 * @version 1.0.0
 * @description 加鎖後不再釋放鎖
 */
public class BlockedThread implements Runnable {
    @Override
    public void run() {
        synchronized (BlockedThread.class){
            while (true){
                WaitingTime.waitSecond(100);
            }
        }
    }
}

ThreadState

啟動各個線程，驗證各個線程輸出的狀态，代碼如下所示。

package io.binghe.concurrent.executor.state;
 
/**
 * @author binghe
 * @version 1.0.0
 * @description 線程的各種狀态，測試線程的生命周期
 */
public class ThreadState {
 
    public static void main(String[] args){
        new Thread(new WaitingTime(), "WaitingTimeThread").start();
        new Thread(new WaitingState(), "WaitingStateThread").start();
 
        //BlockedThread-01線程會搶到鎖，BlockedThread-02線程會阻塞
        new Thread(new BlockedThread(), "BlockedThread-01").start();
        new Thread(new BlockedThread(), "BlockedThread-02").start();
    }
}

運作ThreadState類，如下所示。

可以看到，未輸出任何結果資訊。可以在指令行輸入“jps”指令來檢視運作的Java程序。

c:\>jps
21584 Jps
17828 KotlinCompileDaemon
12284 Launcher
24572
28492 ThreadState

可以看到ThreadSate程序的程序号為28492，接下來，輸入“jstack 28492”來檢視ThreadSate程序棧的資訊，如下所示。

c:\>jstack 28492
2020-02-15 00:27:08
Full thread dump Java HotSpot(TM) 64-Bit Server VM (25.202-b08 mixed mode):
"DestroyJavaVM" #16 prio=5 os_prio=0 tid=0x000000001ca05000 nid=0x1a4 waiting on condition [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE
 
"BlockedThread-02" #15 prio=5 os_prio=0 tid=0x000000001ca04800 nid=0x6eb0 waiting for monitor entry [0x000000001da4f000]
   java.lang.Thread.State: BLOCKED (on object monitor)
        at io.binghe.concurrent.executor.state.BlockedThread.run(BlockedThread.java:28)
        - waiting to lock <0x0000000780a7e4e8> (a java.lang.Class for io.binghe.concurrent.executor.state.BlockedThread)
        at java.lang.Thread.run(Thread.java:748)
 
"BlockedThread-01" #14 prio=5 os_prio=0 tid=0x000000001ca01800 nid=0x6e28 waiting on condition [0x000000001d94f000]
   java.lang.Thread.State: TIMED_WAITING (sleeping)
        at java.lang.Thread.sleep(Native Method)
        at java.lang.Thread.sleep(Thread.java:340)
        at java.util.concurrent.TimeUnit.sleep(TimeUnit.java:386)
        at io.binghe.concurrent.executor.state.WaitingTime.waitSecond(WaitingTime.java:36)
        at io.binghe.concurrent.executor.state.BlockedThread.run(BlockedThread.java:28)
        - locked <0x0000000780a7e4e8> (a java.lang.Class for io.binghe.concurrent.executor.state.BlockedThread)
        at java.lang.Thread.run(Thread.java:748)
 
"WaitingStateThread" #13 prio=5 os_prio=0 tid=0x000000001ca06000 nid=0x6fe4 in Object.wait() [0x000000001d84f000]
   java.lang.Thread.State: WAITING (on object monitor)
        at java.lang.Object.wait(Native Method)
        - waiting on <0x0000000780a7b488> (a java.lang.Class for io.binghe.concurrent.executor.state.WaitingState)
        at java.lang.Object.wait(Object.java:502)
        at io.binghe.concurrent.executor.state.WaitingState.run(WaitingState.java:29)
        - locked <0x0000000780a7b488> (a java.lang.Class for io.binghe.concurrent.executor.state.WaitingState)
        at java.lang.Thread.run(Thread.java:748)
 
"WaitingTimeThread" #12 prio=5 os_prio=0 tid=0x000000001c9f8800 nid=0x3858 waiting on condition [0x000000001d74f000]
   java.lang.Thread.State: TIMED_WAITING (sleeping)
        at java.lang.Thread.sleep(Native Method)
        at java.lang.Thread.sleep(Thread.java:340)
        at java.util.concurrent.TimeUnit.sleep(TimeUnit.java:386)
        at io.binghe.concurrent.executor.state.WaitingTime.waitSecond(WaitingTime.java:36)
        at io.binghe.concurrent.executor.state.WaitingTime.run(WaitingTime.java:29)
        at java.lang.Thread.run(Thread.java:748)
 
"Service Thread" #11 daemon prio=9 os_prio=0 tid=0x000000001c935000 nid=0x6864 runnable [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE
 
"C1 CompilerThread3" #10 daemon prio=9 os_prio=2 tid=0x000000001c88c800 nid=0x6a28 waiting on condition [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE
 
"C2 CompilerThread2" #9 daemon prio=9 os_prio=2 tid=0x000000001c880000 nid=0x6498 waiting on condition [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE
 
"C2 CompilerThread1" #8 daemon prio=9 os_prio=2 tid=0x000000001c87c000 nid=0x693c waiting on condition [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE
 
"C2 CompilerThread0" #7 daemon prio=9 os_prio=2 tid=0x000000001c87b800 nid=0x5d00 waiting on condition [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE
 
"Monitor Ctrl-Break" #6 daemon prio=5 os_prio=0 tid=0x000000001c862000 nid=0x6034 runnable [0x000000001d04e000]
   java.lang.Thread.State: RUNNABLE
        at java.net.SocketInputStream.socketRead0(Native Method)
        at java.net.SocketInputStream.socketRead(SocketInputStream.java:116)
        at java.net.SocketInputStream.read(SocketInputStream.java:171)
        at java.net.SocketInputStream.read(SocketInputStream.java:141)
        at sun.nio.cs.StreamDecoder.readBytes(StreamDecoder.java:284)
        at sun.nio.cs.StreamDecoder.implRead(StreamDecoder.java:326)
        at sun.nio.cs.StreamDecoder.read(StreamDecoder.java:178)
        - locked <0x0000000780b2fd88> (a java.io.InputStreamReader)
        at java.io.InputStreamReader.read(InputStreamReader.java:184)
        at java.io.BufferedReader.fill(BufferedReader.java:161)
        at java.io.BufferedReader.readLine(BufferedReader.java:324)
        - locked <0x0000000780b2fd88> (a java.io.InputStreamReader)
        at java.io.BufferedReader.readLine(BufferedReader.java:389)
        at com.intellij.rt.execution.application.AppMainV2$1.run(AppMainV2.java:64)
 
"Attach Listener" #5 daemon prio=5 os_prio=2 tid=0x000000001c788800 nid=0x6794 waiting on condition [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE
 
"Signal Dispatcher" #4 daemon prio=9 os_prio=2 tid=0x000000001c7e3800 nid=0x3354 runnable [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE
 
"Finalizer" #3 daemon prio=8 os_prio=1 tid=0x000000001c771000 nid=0x6968 in Object.wait() [0x000000001cd4f000]
   java.lang.Thread.State: WAITING (on object monitor)
        at java.lang.Object.wait(Native Method)
        - waiting on <0x0000000780908ed0> (a java.lang.ref.ReferenceQueue$Lock)
        at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:144)
        - locked <0x0000000780908ed0> (a java.lang.ref.ReferenceQueue$Lock)
        at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:165)
        at java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:216)
 
"Reference Handler" #2 daemon prio=10 os_prio=2 tid=0x000000001c770800 nid=0x6590 in Object.wait() [0x000000001cc4f000]
   java.lang.Thread.State: WAITING (on object monitor)
        at java.lang.Object.wait(Native Method)
        - waiting on <0x0000000780906bf8> (a java.lang.ref.Reference$Lock)
        at java.lang.Object.wait(Object.java:502)
        at java.lang.ref.Reference.tryHandlePending(Reference.java:191)
        - locked <0x0000000780906bf8> (a java.lang.ref.Reference$Lock)
        at java.lang.ref.Reference$ReferenceHandler.run(Reference.java:153)
 
"VM Thread" os_prio=2 tid=0x000000001a979800 nid=0x5c2c runnable
 
"GC task thread#0 (ParallelGC)" os_prio=0 tid=0x00000000033b9000 nid=0x4dc0 runnable
 
"GC task thread#1 (ParallelGC)" os_prio=0 tid=0x00000000033ba800 nid=0x6690 runnable
 
"GC task thread#2 (ParallelGC)" os_prio=0 tid=0x00000000033bc000 nid=0x30b0 runnable
 
"GC task thread#3 (ParallelGC)" os_prio=0 tid=0x00000000033be800 nid=0x6f68 runnable
 
"GC task thread#4 (ParallelGC)" os_prio=0 tid=0x00000000033c1000 nid=0x6478 runnable
 
"GC task thread#5 (ParallelGC)" os_prio=0 tid=0x00000000033c2000 nid=0x4fe4 runnable
 
"GC task thread#6 (ParallelGC)" os_prio=0 tid=0x00000000033c5000 nid=0x584 runnable
 
"GC task thread#7 (ParallelGC)" os_prio=0 tid=0x00000000033c6800 nid=0x6988 runnable
 
"VM Periodic Task Thread" os_prio=2 tid=0x000000001c959800 nid=0x645c waiting on condition
 
JNI global references: 12

由以上輸出的資訊可以看出：名稱為WaitingTimeThread的線程處于TIMED_WAITING狀态；名稱為WaitingStateThread的線程處于WAITING狀态；名稱為BlockedThread-01的線程處于TIMED_WAITING狀态；名稱為BlockedThread-02的線程處于BLOCKED狀态。

注意：使用jps結合jstack指令可以分析線上生産環境的Java程序的異常資訊。

也可以直接點選IDEA下圖所示的圖表直接列印出線程的堆棧資訊

輸出的結果資訊與使用“jstack 程序号”指令輸出的資訊基本一緻。

高并發之——線程與多線程

一、線程與多線程

1.線程

2.多線程

二、實作線程的方式

三、線程的生命周期

1.生命周期

2.代碼示例

繼續閱讀

關于Gradle配置的小結

Java小案例——随機數猜測随機數猜測

nginx location中斜線的位置的重要性

27 Best Free Eclipse Plug-ins for Java Developer to be ProductiveCode Quality PluginsText Editor PluginsDependency ManagementVersion Control Integration PluginsFramework Development Continuous Integration Related PluginsOther Utility Plugins

Java String.format方法的簡單使用

neo4j之cypher使用文檔

GitHub連夜封殺！這份阿裡 10W 字内部 Java 字面試手冊到底有多強？

spark/scala關于【資源檔案】加載方法概述外部檔案加載方案測試資源檔案打包入jar包中小結

mybatis_入門程式Mybatis入門

AOP程式設計_Android優雅權限架構(1)概念基礎，2021金三銀四前言正文大綱正文

Effective Java 8:通用程式設計

OOM三種類型

工廠模式-三種類型

【遞歸】高效率求2的n次幂

win10本地scala和spark安裝安裝scala安裝spark

scala (3) Function 和 Method