Java怎么讓多線程按順序執行

本文小編為大家詳細介紹“Java怎么讓多線程按順序執行”，內容詳細，步驟清晰，細節處理妥當，希望這篇“Java怎么讓多線程按順序執行”文章能幫助大家解決疑惑，下面跟著小編的思路慢慢深入，一起來學習新知識吧。

在子線程中通過join()方法指定順序

通過join()方法使當前線程“阻塞”，等待指定線程執行完畢后繼續執行。舉例：在線程thread2中，加上一句thread1.join()，其意義在于，當前線程2運行到此行代碼時會進入阻塞狀態，直到線程thread1執行完畢后，線程thread2才會繼續運行，這就保證了線程thread1與線程thread2的運行順序。

public class ThreadJoinDemo {
    public static void main(String[] args) throws InterruptedException {
        final Thread thread1 = new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println("打開冰箱！");
            }
        });
 
        final Thread thread2 = new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    thread1.join();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("拿出一瓶牛奶！");
            }
        });
 
        final Thread thread3 = new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    thread2.join();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("關上冰箱！");
            }
        });
 
        //下面三行代碼順序可隨意調整，程序運行結果不受影響，因為我們在子線程中通過“join()方法”已經指定了運行順序。
        thread3.start();
        thread2.start();
        thread1.start();
 
    }
}

運行結果：

打開冰箱！
拿出一瓶牛奶！
關上冰箱！

在主線程中通過join()方法指定順序

簡單說一下子線程與主線程的區別，子線程指的是發生在Thread內部的代碼，主線程指的是發生在main函數中的代碼，我們可以在main函數中通過join()方法讓主線程阻塞等待以達到指定順序執行的目的。

public class ThreadMainJoinDemo {
    public static void main(String[] args) throws InterruptedException {
        final Thread thread1 = new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println("打開冰箱！");
            }
        });
 
        final Thread thread2 = new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println("拿出一瓶牛奶！");
            }
        });
 
        final Thread thread3 = new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println("關上冰箱！");
            }
        });
 
        thread1.start();
        thread1.join();
        thread2.start();
        thread2.join();
        thread3.start();
    }
}

輸出結果：

打開冰箱！
拿出一瓶牛奶！
關上冰箱！

通過倒數計時器CountDownLatch實現

CountDownLatch通過計數器提供了更靈活的控制，只要檢測到計數器為0當前線程就可以往下執行而不用管相應的thread是否執行完畢。

public class ThreadCountDownLatchDemo {
 
    private static CountDownLatch countDownLatch2 = new CountDownLatch(1);
 
    private static CountDownLatch countDownLatch3 = new CountDownLatch(1);
 
    public static void main(String[] args) {
        final Thread thread1 = new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println("打開冰箱！");
                countDownLatch2.countDown();
            }
        });
 
        final Thread thread2 = new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    countDownLatch2.await();
                    System.out.println("拿出一瓶牛奶！");
                    countDownLatch3.countDown();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        });
 
        final Thread thread3 = new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    countDownLatch3.await();
                    System.out.println("關上冰箱！");
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        });
 
        //下面三行代碼順序可隨意調整，程序運行結果不受影響
        thread3.start();
        thread1.start();
        thread2.start();
    }
}

輸出結果：

打開冰箱！
拿出一瓶牛奶！
關上冰箱！

通過創建單一化線程池newSingleThreadExecutor()實現

單線程化線程池(newSingleThreadExecutor)的優點，串行執行所有任務。

public class ThreadPoolDemo {
 
   static ExecutorService executorService = Executors.newSingleThreadExecutor();
 
    public static void main(String[] args) {
        final Thread thread1 = new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println("打開冰箱！");
            }
        });
 
        final Thread thread2 =new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println("拿出一瓶牛奶！");
            }
        });
 
        final Thread thread3 = new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println("關上冰箱！");
            }
        });
        executorService.submit(thread1);
        executorService.submit(thread2);
        executorService.submit(thread3);
        executorService.shutdown();        //使用完畢記得關閉線程池
    }
 
}

輸出結果：

打開冰箱！
拿出一瓶牛奶！
關上冰箱！

讀到這里，這篇“Java怎么讓多線程按順序執行”文章已經介紹完畢，想要掌握這篇文章的知識點還需要大家自己動手實踐使用過才能領會，如果想了解更多相關內容的文章，歡迎關注億速云行業資訊頻道。