溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
這篇文章將為大家詳細講解有關在Java中使用 synchronized如何實現運行線程交替，文章內容質量較高，因此小編分享給大家做個參考，希望大家閱讀完這篇文章后對相關知識有一定的了解。
背景
用兩個線程交替輸出A-Z和1-26，即一個線程輸出A-Z，另一個線程輸出1-26
而且是交替形式
以此類推
分析
主要考察線程之間的通信，思路就是創建兩個線程
在一個線程輸出一個內容之后，自己進入阻塞，去喚醒另一個線程
另一個線程同樣，輸出一個內容之后，自己進入阻塞，去喚醒另一個線程
代碼實現（一）
public class AlternateCover {
public static void main(String[] args) {
final char[] arrLetter = "ABCDEFGHIJKLMNOPQRSTUVWXYZ".toCharArray();
final String[] arrNumber = {"1","2","3","4","5","6","7","8","9","10","11","12","13","14","15","16","17","18","19","20","21","22","23","24","25","26"};
threadRun(arrLetter, arrNumber);
}
private static void threadRun(char[] arrLetter,String[] arrNumber){
final Object lock = new Object();// 設置一個鎖對象
// print arrNumber
new Thread(() -> {
synchronized (lock) {
for (String a : arrNumber) {
System.out.print( a);
try {
lock.notify();// 喚醒其他等待的線程 此處喚醒 arrLetter
lock.wait();// arrNumber自己進入等待 讓出CPU資源和鎖資源
} catch (InterruptedException e) {
e.printStackTrace();
}
}
lock.notify();
}
}, "arrNumber ").start();
// print arrLetter
new Thread(() -> {
synchronized (lock) {// 獲取對象鎖
for (char a : arrLetter) {
System.out.print(a);
try {
lock.notify();// 喚醒其他等待的線程 此處喚醒 arrNumber
lock.wait();// arrLetter自己進入等待 讓出CPU資源和鎖資源
} catch (InterruptedException e) {
e.printStackTrace();
}
}
lock.notify();// 最后那個等待的線程需要被喚醒，否則程序無法結束
}
}, "arrLetter ").start();
}
}運行一下，確實實現了交替輸出，但是多運行幾次，就會發現問題
有時候是數字先輸出，有時候是字母先輸出
即兩個線程誰先啟動的順序是不固定的
倘若試題中再加一句，必須要字母先輸出，怎么辦？
代碼實現（二）
/**
* 交替掩護 必須保證大寫字母先輸出
*/
public class AlternateCover {
public static volatile Boolean flg = false;// 誰先開始的標志 volatile修飾目的是讓該值修改對所有線程可見，且防止指令重排序
public static void main(String[] args) {
final char[] arrLetter = "ABCDEFGHIJKLMNOPQRSTUVWXYZ".toCharArray();
final String[] arrNumber = {"1","2","3","4","5","6","7","8","9","10","11","12","13","14","15","16","17","18","19","20","21","22","23","24","25","26"};
threadRun(arrLetter, arrNumber);
}
private static void threadRun(char[] arrLetter,String[] arrNumber){
final Object lock = new Object();// 鎖對象
// print arrLetter
new Thread(() -> {
synchronized (lock) {
if (!flg){ // 如果flg是false 就將值設為true
flg = true;
}
for (char a : arrLetter) {
System.out.print(a);// 輸出內容
try {
lock.notify();// 喚醒在等待的其他線程中的一個（此處也只有另一個）
lock.wait();// 自己進入等待 讓出CPU資源和鎖資源
} catch (InterruptedException e) {
e.printStackTrace();
}
}
lock.notify();// 最后那個等待的線程需要被喚醒，否則程序無法結束
}
}, "arrLetter").start();
// print arrNumber
new Thread(() -> {
synchronized (lock) {
if (!flg){// 倘若是該線程先執行，那么flg次數還是false 就先等著
try {
lock.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
for (String a : arrNumber) {
System.out.print( a);
try {
lock.notify();
lock.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
lock.notify();
}
}, "arrNumber").start();
}
}如此問題可以得到解決，但有更優(裝)雅（B）的解決辦法
CountDownLatch實現
/**
* 交替掩護 必須保證大寫字母先輸出
*/
public class AlternateCover {
private static CountDownLatch count = new CountDownLatch(1);// 計數器容量為1
public static void main(String[] args) {
final char[] arrLetter = "ABCDEFGHIJKLMNOPQRSTUVWXYZ".toCharArray();
final String[] arrNumber = {"1","2","3","4","5","6","7","8","9","10","11","12","13","14","15","16","17","18","19","20","21","22","23","24","25","26"};
threadRun(arrLetter, arrNumber);
}
private static void threadRun(char[] arrLetter,String[] arrNumber){
final Object lock = new Object();
// print arrLetter
new Thread(() -> {
synchronized (lock) {// 獲取對象鎖
count.countDown();// 對計數器進行遞減1操作，當計數器遞減至0時，當前線程會去喚醒阻塞隊列里的所有線程（只針對count）
for (char a : arrLetter) {
System.out.print(a);
try {
lock.notify();// 喚醒其他等待的線程 此處喚醒 arrNumber
lock.wait();// arrLetter自己進入等待 讓出CPU資源和鎖資源
} catch (InterruptedException e) {
e.printStackTrace();
}
}
lock.notify();// 最后那個等待的線程需要被喚醒，否則程序無法結束
}
}, "arrLetter ").start();
// print arrNumber
new Thread(() -> {
synchronized (lock) {
try {
count.await();// 如果該線程先執行 阻塞當前線程，將當前線程加入阻塞隊列
} catch (InterruptedException e) {
e.printStackTrace();
}
for (String a : arrNumber) {
System.out.print( a);
try {
lock.notify();// 喚醒其他等待的線程 此處喚醒 arrLetter
lock.wait();// arrNumber自己進入等待 讓出CPU資源和鎖資源
} catch (InterruptedException e) {
e.printStackTrace();
}
}
lock.notify();
}
}, "arrNumber ").start();
}
}關于在Java中使用 synchronized如何實現運行線程交替就分享到這里了，希望以上內容可以對大家有一定的幫助，可以學到更多知識。如果覺得文章不錯，可以把它分享出去讓更多的人看到。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
