今天就跟大家聊聊有關(guān)Java多線程怎么實現(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è)報價,網(wǎng)絡(luò)營銷,網(wǎng)絡(luò)優(yōu)化,富順網(wǎng)站推廣為一體的創(chuàng)新建站企業(yè)，幫助傳統(tǒng)企業(yè)提升企業(yè)形象加強企業(yè)競爭力。可充分滿足這一群體相比中小企業(yè)更為豐富、高端、多元的互聯(lián)網(wǎng)需求。同時我們時刻保持專業(yè)、時尚、前沿，時刻以成就客戶成長自我，堅持不斷學(xué)習(xí)、思考、沉淀、凈化自己，讓我們?yōu)楦嗟钠髽I(yè)打造出實用型網(wǎng)站。

方法1 使用newSingleThreadExecutor

newSingleThreadExecutor返回僅僅包含一個線程的線程池,將多個任務(wù)交給此Executor時，這個線程池處理完一個任務(wù)后接著處理下一個任務(wù)，這樣就保證了執(zhí)行順序，先提交先執(zhí)行。如果當前線程意外終止，會創(chuàng)建一個新線程繼續(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.

英語原版其實很拗口，不好理解。簡單點說，就是某個線程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)

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

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

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

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

unit，時間單位分鐘，秒等等。

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

5、threadFactory，線程工廠，默認的即可。

6、handler，拒絕策略，分4種，AbortPolicy直接拋出異常、DiscardPolicy悄悄拋棄不執(zhí)行、CallerRunsPolicy（調(diào)用者運行）：該策略既不會拋棄任務(wù)也不會拋出異常，而是將這個任務(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)容，你們對Java多線程怎么實現(xiàn)按指定順序同步執(zhí)行有進一步的了解嗎？如果還想了解更多知識或者相關(guān)內(nèi)容，請關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，感謝大家的支持。

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

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

廣告

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