file

file

相信你經(jīng)過集合篇的成長(zhǎng)院仿，已經(jīng)對(duì)JDK源碼的學(xué)習(xí)輕車熟路了。接下來你將一起和我進(jìn)入后半篇的學(xué)習(xí)。讓我們開始吧歹垫！

在接下來10分鐘剥汤，你將學(xué)習(xí)到thread 的源碼原理、線程的狀態(tài)變化排惨、線程的常用場(chǎng)景吭敢。

Thread基礎(chǔ)回顧

<div class="output_wrapper" id="output_wrapper_id" style="width:fit-content;font-size: 16px; color: rgb(62, 62, 62); line-height: 1.6; word-spacing: 0px; letter-spacing: 0px; font-family: 'Helvetica Neue', Helvetica, 'Hiragino Sans GB', 'Microsoft YaHei', Arial, sans-serif;"><h3 id="hdddd" style="width:fit-content;line-height: inherit; margin: 1.5em 0px; font-weight: bold; font-size: 1.3em; margin-bottom: 2em; margin-right: 5px; padding: 8px 15px; letter-spacing: 2px; background-image: linear-gradient(to right bottom, rgb(43,48,70), rgb(43,48,70)); background-color: rgb(63, 81, 181); color: rgb(255, 255, 255); border-left: 10px solid rgb(255,204,0); border-radius: 5px; text-shadow: rgb(102, 102, 102) 1px 1px 1px; box-shadow: rgb(102, 102, 102) 1px 1px 2px;"><span style="font-size: inherit; color: inherit; line-height: inherit; margin: 0px; padding: 0px;">Thread基礎(chǔ)回顧</span></h3></div>

什么是Thread?

Thread顧名思義，是線程暮芭。你應(yīng)該知道鹿驼，一個(gè)java程序在操作系統(tǒng)上運(yùn)行，會(huì)啟動(dòng)一個(gè)JVM進(jìn)程谴麦，具有一個(gè)進(jìn)程ID蠢沿，這個(gè)進(jìn)程可以創(chuàng)建很多個(gè)線程。操作系統(tǒng)匾效、程序、進(jìn)程恤磷、線程關(guān)系如下圖所示：

file

運(yùn)行一個(gè)線程其實(shí)就是啟動(dòng)一個(gè)執(zhí)行分支面哼，執(zhí)行不同的事情，執(zhí)行分支時(shí)可以是阻塞的也可以是異步的扫步。舉一個(gè)例子魔策，假如你需要燒開水，還想玩手機(jī)河胎。異步就是你燒開水的時(shí)候闯袒，可以玩手機(jī)，阻塞就是你就一直等著水燒開了游岳，再開始玩手機(jī)政敢。

創(chuàng)建線程Thread

創(chuàng)建線程的方式一般是2種。一種是繼承Thread重寫run方法胚迫，一種是實(shí)現(xiàn)Runnable或Callable接口之后,創(chuàng)建Thread喷户。

當(dāng)然通過線程池也能說算是一種方式，但是底層還是上面的兩種方式之一访锻，沒什么區(qū)別褪尝。

這里帶你回顧下，代碼如下：

代碼清單: LinkedListDemo創(chuàng)建LinkedList

public static void main(String[] args) {
       //創(chuàng)建線程1
      new Thread(()-> System.out.println(Thread.currentThread().getName()),"demo1").start();
       //創(chuàng)建線程2
      new Thread(new MyThread(),"demo2").start();
       //創(chuàng)建線程3
       ThreadFactory namedThreadFactory = new ThreadFactoryBuilder()
.setNameFormat("demo-pool-%d")
.build();
       ExecutorService singleThreadPool = new ThreadPoolExecutor(1, 1,0L, TimeUnit.MILLISECONDS,
new LinkedBlockingQueue<Runnable>(1024),
namedThreadFactory,
new ThreadPoolExecutor.AbortPolicy());
       singleThreadPool.execute(()-> System.out.println(Thread.currentThread().getName()));
       singleThreadPool.shutdown();   
   }

   static class MyThread extends Thread{
       @Override
       public void run() {
          System.out.println(Thread.currentThread().getName());
       }
}

線程Thread的常用方法

相信這些方法你一定很熟悉了,這里就不過多贅述了期犬。我想讓你掌握的重點(diǎn)是剖析線程如何在開源項(xiàng)目中的使用河哑，從而更好的理解原理，更好的運(yùn)用線程龟虎，這個(gè)在成長(zhǎng)記后面會(huì)給大家講解的璃谨。

• start() 啟動(dòng)一個(gè)線程

• join() 加入一個(gè)線程

• sleep() 線程休眠一陣子

• isAlive() 線程是否存活

• interupted() 標(biāo)記線程為中斷

• sinterupted() 線程是否中斷

另外還有以下這些方法不經(jīng)常用，也不建議使用

destroy() 遣总、stop()睬罗、 suspend()轨功、 resume()、 yeild()

在開源項(xiàng)目和實(shí)際業(yè)務(wù)系統(tǒng)或者基礎(chǔ)架構(gòu)系統(tǒng)也是很少使用到的容达。

線程的狀態(tài)

線程中其實(shí)最重要的就是它的狀態(tài)流轉(zhuǎn)古涧。這里直接給大家看一個(gè)圖，這個(gè)圖非常重要花盐，對(duì)分析后面的源碼有很大幫助羡滑。大家一定要牢記于心，線程狀態(tài)圖如下所示：

file

線程應(yīng)用場(chǎng)景舉例

<div class="output_wrapper" id="output_wrapper_id" style="width:fit-content;font-size: 16px; color: rgb(62, 62, 62); line-height: 1.6; word-spacing: 0px; letter-spacing: 0px; font-family: 'Helvetica Neue', Helvetica, 'Hiragino Sans GB', 'Microsoft YaHei', Arial, sans-serif;"><h3 id="hdddd" style="width:fit-content;line-height: inherit; margin: 1.5em 0px; font-weight: bold; font-size: 1.3em; margin-bottom: 2em; margin-right: 5px; padding: 8px 15px; letter-spacing: 2px; background-image: linear-gradient(to right bottom, rgb(43,48,70), rgb(43,48,70)); background-color: rgb(63, 81, 181); color: rgb(255, 255, 255); border-left: 10px solid rgb(255,204,0); border-radius: 5px; text-shadow: rgb(102, 102, 102) 1px 1px 1px; box-shadow: rgb(102, 102, 102) 1px 1px 2px;"><span style="font-size: inherit; color: inherit; line-height: inherit; margin: 0px; padding: 0px;">線程應(yīng)用場(chǎng)景舉例</span></h3></div>

當(dāng)你回顧了線程的基本知識(shí)算芯，這來舉幾個(gè)例子柒昏。

在各個(gè)開源框架中，線程的應(yīng)用場(chǎng)景非常廣泛熙揍，這里給大家舉幾個(gè)例子职祷，主要是為了，讓你明白下熟練掌握線程的重要性届囚。之后的相關(guān)的成長(zhǎng)記你會(huì)學(xué)到具體是怎么使用線程的細(xì)節(jié)的有梆。

線程應(yīng)用舉例1 心跳和監(jiān)控時(shí)使用線程

在微服務(wù)系統(tǒng)中，經(jīng)常使用到的一個(gè)服務(wù)就是注冊(cè)中心意系。注冊(cè)中心簡(jiǎn)單的講就是讓一個(gè)服務(wù)訪問另一個(gè)服務(wù)的時(shí)候泥耀，可以知道對(duì)方所有實(shí)例的地址，可以用來在調(diào)用的時(shí)候選擇蛔添。這就需要每個(gè)服務(wù)的實(shí)例要注冊(cè)自己的信息到一個(gè)公共的地方痰催，這個(gè)地方就是注冊(cè)中心。

每個(gè)實(shí)例有一個(gè)客戶端用來和服務(wù)端通信迎瞧，在Spring Cloud實(shí)現(xiàn)的微服務(wù)技術(shù)棧中夸溶，Eureka這個(gè)組件就充當(dāng)了注冊(cè)中心的作用。它的服務(wù)端Eureka-Server大量使用了一些Thread夹攒。這里我舉兩個(gè)場(chǎng)景蜘醋，讓大家感受下Thread的應(yīng)用。

一個(gè)是場(chǎng)景咏尝，每個(gè)服務(wù)的實(shí)例需要發(fā)送心跳压语，告訴注冊(cè)中心自己還在線，服務(wù)還存活著编检。服務(wù)端通過一個(gè)線程來判斷胎食，某個(gè)服務(wù)如果在一定時(shí)間內(nèi)不發(fā)送心跳了，就認(rèn)為它故障了允懂，就會(huì)把它注冊(cè)中心剔除掉厕怜。如圖中藍(lán)色部分的圓圈所示。

file

另一個(gè)是場(chǎng)景，Eureka server將每個(gè)服務(wù)實(shí)例注冊(cè)的信息放到了一個(gè)內(nèi)存map中粥航，為了提高速度和并發(fā)能力琅捏，它設(shè)置了多個(gè)緩存，有寫緩存和讀緩存递雀。Eureka client客戶端讀取的是讀緩存柄延。什么時(shí)候?qū)懢彺鏀?shù)據(jù)刷入到讀緩存?就是通過一個(gè)后臺(tái)線程，每隔30秒從寫緩存刷新到讀緩存中缀程。

客戶端也有一個(gè)后臺(tái)線程搜吧，每隔30秒會(huì)發(fā)起http請(qǐng)求，從服務(wù)端讀取注冊(cè)中心的數(shù)據(jù)杨凑。

file

總之滤奈，在這個(gè)場(chǎng)景中，線程用于了心跳和監(jiān)控撩满，是非常常見的場(chǎng)景蜒程。因?yàn)樵诤芏嚅_源項(xiàng)目中都是這樣做的，比如hdfs伺帘，zookeeper等等搞糕。

線程應(yīng)用舉例2 定時(shí)更新、保存曼追、刪除數(shù)據(jù)

在MySQL、Redis汉规、ES礼殊、HDFS、Zookeeper等等的開源項(xiàng)目中针史，都會(huì)有線程的概念晶伦，來定時(shí)保存數(shù)據(jù)，或者刷新磁盤啄枕，清理磁盤等等操作婚陪。

它們一般其實(shí)都很類似，都是保存到磁盤的一個(gè)就是操作日志频祝，一個(gè)就是快照數(shù)據(jù)泌参。

比如hdfs中的checkpoint線程，用來自動(dòng)合并edit_log為fsImage常空、自動(dòng)清除edit_log線程沽一、比如mysql定時(shí)刷入bufferPool的數(shù)據(jù)到磁盤中的線程。比如Zookeeper保存WAL日志漓糙、或者mysql定時(shí)保存dump文件铣缠，redis的快照等等。

線程應(yīng)用舉例3 多線程提高處理速度和性能

比較典型的就是Storm、Flink蝗蛙、Spark分布式計(jì)算就是使用多線程計(jì)算提高性能蝇庭，當(dāng)然還有MQ的多線程消費(fèi)，也是典型的多線程提高了處理性能捡硅。

這里不就不一一舉例了哮内。有興趣的同學(xué)可以在評(píng)論區(qū)里寫下自己知道的開源項(xiàng)目中如何使用線程。

Thread源碼剖析

<div class="output_wrapper" id="output_wrapper_id" style="width:fit-content;font-size: 16px; color: rgb(62, 62, 62); line-height: 1.6; word-spacing: 0px; letter-spacing: 0px; font-family: 'Helvetica Neue', Helvetica, 'Hiragino Sans GB', 'Microsoft YaHei', Arial, sans-serif;"><h3 id="hdddd" style="width:fit-content;line-height: inherit; margin: 1.5em 0px; font-weight: bold; font-size: 1.3em; margin-bottom: 2em; margin-right: 5px; padding: 8px 15px; letter-spacing: 2px; background-image: linear-gradient(to right bottom, rgb(43,48,70), rgb(43,48,70)); background-color: rgb(63, 81, 181); color: rgb(255, 255, 255); border-left: 10px solid rgb(255,204,0); border-radius: 5px; text-shadow: rgb(102, 102, 102) 1px 1px 1px; box-shadow: rgb(102, 102, 102) 1px 1px 2px;"><span style="font-size: inherit; color: inherit; line-height: inherit; margin: 0px; padding: 0px;">Thread源碼剖析</span></h3></div>

回顧了線程的基本知識(shí)使用場(chǎng)景病曾，接下來你需要了解下Thread的源碼牍蜂，才能更好的理解它，使用它泰涂。

下面主要通過創(chuàng)建線程鲫竞，啟動(dòng)線程，線程狀態(tài)變化操作這幾個(gè)場(chǎng)景簡(jiǎn)單摸一下Thread的源碼逼蒙。

第一個(gè)場(chǎng)景：創(chuàng)建線程

newThread(

   ()-> System.out.println(Thread.currentThread().getName()),"demo1"

).start();

讓我們分析一下這行代碼,首先是new Thread从绘，會(huì)進(jìn)入構(gòu)造函數(shù)。

public Thread(Runnabletarget) {
 
   init(null, target,"Thread-"+ nextThreadNum(), 0);
 
}

調(diào)用了init方法前是牢，調(diào)用了nextThreadNum方法僵井，生成了一個(gè)自增id，和Thread-+num 作為線程名字驳棱。

/* For autonumbering anonymous threads. */

private static intthreadInitNumber;

private static synchronized int nextThreadNum() {

  return threadInitNumber++;

}

上面源碼總結(jié)為下圖：

file

默認(rèn)生成線程名字之后批什，調(diào)用4個(gè)參數(shù)的init方法，接著又繼續(xù)調(diào)用了6個(gè)參數(shù)的init方法社搅。

private void init(ThreadGroupg, Runnable target,String name,
 
         long stackSize) {
 
   init(g, target, name, stackSize,null, true);
 
 }

這個(gè)init是創(chuàng)建線程核心的步驟我們來看下它的脈絡(luò)驻债。

private void init(ThreadGroupg, Runnable target,String name,
 
         long stackSize, AccessControlContextacc,
 
         booleaninheritThreadLocals) {
 
   if(name ==null) {
 
     throw newNullPointerException("name cannot be null");
 
   }
 
 
 
   this.name = name;
 
 
 
   Thread parent= currentThread();
 
   SecurityManager security= System.getSecurityManager();
 
   if(g ==null) {
 
     if(security !=null) {
 
       g = security.getThreadGroup();
 
     }
 
     if(g ==null) {
 
       g = parent.getThreadGroup();
 
     }
 
   }
 
   g.checkAccess();
 
   if(security !=null) {
 
     if(isCCLOverridden(getClass())) {
 
       security.checkPermission(SUBCLASS_IMPLEMENTATION_PERMISSION);
 
     }
 
   }
 
 
 
   g.addUnstarted();
 
 
 
   this.group = g;
 
   this.daemon =parent.isDaemon();
 
   this.priority =parent.getPriority();
 
   if(security ==null || isCCLOverridden(parent.getClass()))
 
     this.contextClassLoader= parent.getContextClassLoader();
 
   else
 
     this.contextClassLoader=parent.contextClassLoader;
 
  this.inheritedAccessControlContext=
 
       acc !=null ? acc : AccessController.getContext();
 
   this.target = target;
 
   setPriority(priority);
 
   if(inheritThreadLocals && parent.inheritableThreadLocals!= null)
 
     this.inheritableThreadLocals=
 
       ThreadLocal.createInheritedMap(parent.inheritableThreadLocals);
 
   /* Stash the specified stack size in case the VM cares */
 
   this.stackSize = stackSize;
 
 
 
   /* Set thread ID */
 
   tid= nextThreadID();
 
 }

上面的代碼從脈絡(luò)可以分為4點(diǎn)：

1. 設(shè)置線程名稱，默認(rèn)是Thread+全局自增id
2. 設(shè)置線程組 父線程默認(rèn)是當(dāng)前線程形葬，默認(rèn)線程所屬組為父線程組
3. 優(yōu)先級(jí)和是否是后臺(tái)線程 默認(rèn)和父線程相同
4. 保存?zhèn)魅氲腞unnable或Callable的run方法

如下圖所示：

file

這個(gè)線程創(chuàng)建的過程合呐，你需要記住的核心點(diǎn)就是以下幾點(diǎn)：

創(chuàng)建你的線程，就是你的父線程

如果你沒有指定ThreadGroup笙以，你的ThreadGroup就是父線程的ThreadGroup

你的daemon狀態(tài)默認(rèn)是父線程的daemon狀態(tài)

你的優(yōu)先級(jí)默認(rèn)是父線程的優(yōu)先級(jí)

如果你沒有指定線程的名稱淌实，那么默認(rèn)就是Thread-0格式的名稱

你的線程id是全局遞增的，從1開始

第二個(gè)場(chǎng)景：?jiǎn)?dòng)線程

當(dāng)創(chuàng)建了線程后猖腕，接著就是啟動(dòng)線程了拆祈。你一定知道，thread啟動(dòng)一個(gè)線程使用通過start方法谈息。它的底層邏輯很簡(jiǎn)單缘屹，代碼如下：

public synchronized void start() {
  if(threadStatus !=0)
    throw newIllegalThreadStateException();

  group.add(this);

  boolean started =false;

  try{
    start0();
    started =true;
  } finally{
    try{
      if(!started) {
        group.threadStartFailed(this);
      }
    } catch(Throwable ignore) {


    }
  }
}

還是來看下核心脈絡(luò)：

1、判斷線程狀態(tài)侠仇，不能重復(fù)啟動(dòng)

2轻姿、放入線程組

3犁珠、調(diào)用一個(gè)native方法啟動(dòng)線程，如果失敗從線程組中移除互亮。

這個(gè)navive方法是C++實(shí)現(xiàn)的犁享，具體我們不去研究了，你只要知道本質(zhì)是將線程交給CPU線程執(zhí)行調(diào)度器執(zhí)行豹休，之后CPU會(huì)通過時(shí)間片的算法來執(zhí)行各個(gè)線程炊昆，就可以了。如下圖所示：

file

啟動(dòng)完成后威根，肯定會(huì)調(diào)用run方法凤巨，這里的run方法就是之前構(gòu)造函數(shù)保存的Runnable動(dòng)的run方法。如果是繼承Thread方式創(chuàng)建的線程洛搀，這個(gè)run方法被重寫了敢茁，所以下面這段邏輯只是適用于Runnalbe或Callable方式創(chuàng)建的Thread。

@Override
 public void run() {
   if(target !=null) {
     target.run();
   }
 }

第三個(gè)場(chǎng)景：線程狀態(tài)變化操作

了解了創(chuàng)建線程和不知道你還記得之前的線程狀態(tài)圖么留美？怎么進(jìn)入到其他狀態(tài)呢彰檬？讓我們一起來看看狀態(tài)變化的一些線程操作。

一個(gè)線程創(chuàng)建時(shí)候是NEW啟動(dòng)后變?yōu)镽unnable谎砾。之后怎么變?yōu)閃AITING呢逢倍？其實(shí)有很多種方法，我們這里講一個(gè)常用的方法join()景图。當(dāng)然調(diào)用Obejct.wait()或LockSupport.part()操作也會(huì)實(shí)現(xiàn)同樣的效果较雕，這個(gè)我們的成長(zhǎng)記后面會(huì)講到，大家不要著急挚币。

顧名思義郎笆，join表示加入的意思。意思就是另一線程加入到執(zhí)行過程中忘晤，當(dāng)前線程需要等待加入的線程執(zhí)行完成才能繼續(xù)執(zhí)行。如下圖所示:

file

接著我們看下如何進(jìn)入TimeWaiting狀態(tài)呢激捏？其實(shí)也很簡(jiǎn)單设塔。你可以通過使用sleep方法來進(jìn)入這個(gè)狀態(tài)。sleep方法支持傳入等待時(shí)間远舅。一般有兩種方式一個(gè)是直接傳入毫秒值比如 60 * 1000表示60秒闰蛔，一個(gè)是可以通過TimeUnit這個(gè)工具傳遞時(shí)間。但是大多數(shù)開源項(xiàng)目為了靈活图柏，使用的都是第一種方式序六，因?yàn)榈诙N方式限制了單位，如果需要修改的話蚤吹，使用起來就不太靈活了例诀。使用sleep的流程如下：

file

如果你看sleep的源碼随抠，發(fā)現(xiàn)就是一個(gè)native方法，底層肯定是通過C++代碼繁涂，通知CPU線程休眠一陣子拱她。無論在Java線程模型還是CPU的線程模型，其實(shí)線程狀態(tài)的變化都是一樣的扔罪，其實(shí)線程的狀態(tài)的模型是一個(gè)抽象概念秉沼。

最后線程如何進(jìn)入Block狀態(tài)？其實(shí)是通過syncronized加鎖后矿酵，被阻塞的線程就會(huì)進(jìn)入block狀態(tài)唬复。后面講到syncronized的時(shí)候詳細(xì)分析。這里就不過多說明了全肮。

好了到這里敞咧，我們通過線程的核心的三個(gè)場(chǎng)景分析了thread的源碼原理。相信你對(duì)thread有了進(jìn)一步的認(rèn)識(shí)了倔矾，但是更重要的是妄均，你要不斷的積累使用thread的場(chǎng)景，在合適的使用thread的方法哪自。理解線程的狀態(tài)變化就顯得更為重要丰包。

本文由博客一文多發(fā)平臺(tái) OpenWrite 發(fā)布！