今天就跟大家聊聊有關(guān)Java多線程怎么實(shí)現(xiàn)按指定順序同步執(zhí)行，可能很多人都不太了解，為了讓大家更加了解，小編給大家總結(jié)了以下內(nèi)容，希望大家根據(jù)這篇文章可以有所收獲。

成都創(chuàng)新互聯(lián)是一家集網(wǎng)站建設(shè),富順企業(yè)網(wǎng)站建設(shè),富順品牌網(wǎng)站建設(shè),網(wǎng)站定制,富順網(wǎng)站建設(shè)報(bào)價(jià),網(wǎng)絡(luò)營(yíng)銷,網(wǎng)絡(luò)優(yōu)化,富順網(wǎng)站推廣為一體的創(chuàng)新建站企業(yè)，幫助傳統(tǒng)企業(yè)提升企業(yè)形象加強(qiáng)企業(yè)競(jìng)爭(zhēng)力?？沙浞譂M足這一群體相比中小企業(yè)更為豐富、高端、多元的互聯(lián)網(wǎng)需求。同時(shí)我們時(shí)刻保持專業(yè)、時(shí)尚、前沿，時(shí)刻以成就客戶成長(zhǎng)自我，堅(jiān)持不斷學(xué)習(xí)、思考、沉淀、凈化自己，讓我們?yōu)楦嗟钠髽I(yè)打造出實(shí)用型網(wǎng)站。

方法1 使用newSingleThreadExecutor

newSingleThreadExecutor返回僅僅包含一個(gè)線程的線程池,將多個(gè)任務(wù)交給此Executor時(shí)，這個(gè)線程池處理完一個(gè)任務(wù)后接著處理下一個(gè)任務(wù)，這樣就保證了執(zhí)行順序，先提交先執(zhí)行。如果當(dāng)前線程意外終止，會(huì)創(chuàng)建一個(gè)新線程繼續(xù)執(zhí)行任務(wù)。

示例代碼如下：

ExecutorService pool = Executors.newSingleThreadExecutor();
    for(int i=0;i<1000;++i) {
      final int number = i;
      pool.execute(()-> {
        System.out.println("I am " + number);
      } );
    }
pool.shutdown();

方法2 使用join方法

When we call this method using a thread object, it suspends the execution of the calling thread until the object called finishes its execution.

英語(yǔ)原版其實(shí)很拗口，不好理解。簡(jiǎn)單點(diǎn)說(shuō)，就是某個(gè)線程A調(diào)用join，其他線程就要乖乖等A執(zhí)行完畢才能執(zhí)行。

示例代碼如下：

public class Worker implements Runnable {

  private int number;
  public Worker(int i) {
    number = i;
  }
  
  @Override
  public synchronized void run() {
    System.out.println("I am " + number);
  }
}

public class TestWorker {

  public static void main(String[] args) {
    
    for(int j=0;j<1000;++j) {
      Thread thread = new Thread(new Worker(j));
      thread.start();
      try {
        thread.join();
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
    }
  }
}

方法3 使用ThreadPoolExecutor，設(shè)置它的核心線程數(shù)為1

我們先分析一下ThreadPoolExecutor,其構(gòu)造函數(shù)如下

public ThreadPoolExecutor(int corePoolSize,
               int maximumPoolSize,
               long keepAliveTime,
               TimeUnit unit,
               BlockingQueue<Runnable> workQueue,
               ThreadFactory threadFactory,               
               RejectedExecutionHandler handler)

各個(gè)參數(shù)含義如下：

1、corePoolSize, 核心線程數(shù)，建議和cpu的核心數(shù)一樣，當(dāng)有任務(wù)提交，檢測(cè)當(dāng)前線程池內(nèi)的線程數(shù)小于corePoolSize的話，新建線程執(zhí)行任務(wù)，直到達(dá)到corePoolSize。線程池內(nèi)的線程數(shù)大于等于corePoolSize時(shí)，將任務(wù)放入workQueue等待。

2、maximumPoolSize，允許線程池內(nèi)最大線程數(shù)，當(dāng)隊(duì)列滿了之后，如果線程池內(nèi)的線程數(shù)小于maximumPoolSize新建線程，如果大于等于執(zhí)行拒絕策略。

3、keepAliveTime，線程最大空閑時(shí)間，如果設(shè)置60s，那么線程空閑60s后自動(dòng)結(jié)束。

unit，時(shí)間單位分鐘，秒等等。

4、workQueue，線程數(shù)超過(guò)corePoolSize存放任務(wù)的地方。

5、threadFactory，線程工廠，默認(rèn)的即可。

6、handler，拒絕策略，分4種，AbortPolicy直接拋出異常、DiscardPolicy悄悄拋棄不執(zhí)行、CallerRunsPolicy（調(diào)用者運(yùn)行）：該策略既不會(huì)拋棄任務(wù)也不會(huì)拋出異常，而是將這個(gè)任務(wù)退回給調(diào)用者，從而降低新任務(wù)的流量；、DiscardOldestPolicy（拋棄最舊的）

示例代碼如下：

ExecutorService pool = new ThreadPoolExecutor(1, 1000, 300, TimeUnit.SECONDS, 
        new LinkedBlockingQueue<Runnable>(1000),Executors.defaultThreadFactory(), 
        new ThreadPoolExecutor.AbortPolicy());
    for(int i=0;i<1000;++i) {
      final int number = i;
      pool.execute(()-> {
        System.out.println("I am " + number);
      } );
    }
pool.shutdown();

4. 執(zhí)行結(jié)果

I am 0
I am 1
I am 2
I am 3
I am 4
I am 5
I am 6
I am 7
I am 8
I am 9
I am 10

。。。

I am 990
I am 991
I am 992
I am 993
I am 994
I am 995
I am 996
I am 997
I am 998
I am 999

看完上述內(nèi)容，你們對(duì)Java多線程怎么實(shí)現(xiàn)按指定順序同步執(zhí)行有進(jìn)一步的了解嗎？如果還想了解更多知識(shí)或者相關(guān)內(nèi)容，請(qǐng)關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，感謝大家的支持。

網(wǎng)頁(yè)標(biāo)題：Java多線程怎么實(shí)現(xiàn)按指定順序同步執(zhí)行
網(wǎng)頁(yè)URL：http://chinadenli.net/article14/gicege.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供全網(wǎng)營(yíng)銷推廣、品牌網(wǎng)站設(shè)計(jì)、網(wǎng)站設(shè)計(jì)公司、品牌網(wǎng)站制作、網(wǎng)站收錄、面包屑導(dǎo)航

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)