Java中多個(gè)線程交替循環(huán)執(zhí)行的實(shí)現(xiàn)
有些時(shí)候面試官經(jīng)常會(huì)問，兩個(gè)線程怎么交替執(zhí)行呀，如果是三個(gè)線程，又怎么交替執(zhí)行呀，這種問題一般人還真不一定能回答上來。多線程這塊如果理解的不好，學(xué)起來是很吃力的，更別說面試了。下面我們就來剖析一下怎么實(shí)現(xiàn)多個(gè)線程順序輸出。
兩個(gè)線程循環(huán)交替打印
//首先我們來看一種比較簡單的方式
public class ThreadCq {
public static void main(String[] args) {
Stack<Integer> stack = new Stack<>();
for(int i=1;i<100;i++) {
stack.add(i);
}
Draw draw = new Draw(stack);
new Thread(draw).start();
new Thread(draw).start();
}
}
class Draw implements Runnable{
private Stack<Integer> stack;
public Draw(Stack<Integer> stack) {
this.stack = stack;
}
@Override
public void run() {
while(!stack.isEmpty()) {
synchronized (this) {
notify();
System.out.println(Thread.currentThread().getName()+"---"+stack.pop());
try {
wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
}這種方式是用Condition對(duì)象來完成的：
public class ThreadCq3 {
//聲明一個(gè)鎖
static ReentrantLock lock = new ReentrantLock();
public static void main(String[] args) {
//創(chuàng)建兩個(gè)Condition對(duì)象
Condition c1 = lock.newCondition();
Condition c2 = lock.newCondition();
Stack<Integer> stack = new Stack<>();
for (int i = 0; i <= 100; i++) {
stack.add(i);
}
new Thread(() -> {
try {
Thread.sleep(500);
} catch (InterruptedException e1) {
e1.printStackTrace();
}
while (true) {
lock.lock();
// 打印偶數(shù)
try {
if (stack.peek() % 2 != 0) {
c1.await();
}
System.out.println(Thread.currentThread().getName() + "-----" + stack.pop());
c2.signal();
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
lock.unlock();
}
}
}).start();
new Thread(() -> {
while (true) {
try {
Thread.sleep(500);
} catch (InterruptedException e1) {
e1.printStackTrace();
}
lock.lock();
try {
// 打印奇數(shù)
if (stack.peek() % 2 != 1) {
c2.await();
}
System.out.println(Thread.currentThread().getName() + "-----" + stack.pop());
c1.signal();
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
lock.unlock();
}
}
}).start();
}
}這種方式是通過Semaphore來實(shí)現(xiàn)的：
public class ThreadCq4 {
//利用信號(hào)量來限制
private static Semaphore s1 = new Semaphore(1);
private static Semaphore s2 = new Semaphore(1);
public static void main(String[] args) {
try {
//首先調(diào)用s2為 acquire狀態(tài)
s1.acquire();
// s2.acquire(); 調(diào)用s1或者s2先占有一個(gè)
} catch (InterruptedException e1) {
e1.printStackTrace();
}
new Thread(()->{
while(true) {
try {
s1.acquire();
} catch (InterruptedException e) {
e.printStackTrace();
}
try {
Thread.sleep(500);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("A");
s2.release();
}
}).start();
new Thread(()->{
while(true) {
try {
s2.acquire();
} catch (InterruptedException e) {
e.printStackTrace();
}
try {
Thread.sleep(500);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("B");
s1.release();
}
}).start();
}
}
上面就是三種比較常用的，最常用的要屬第一種和第二種。
三個(gè)線程交替打印輸出
上面我們看了兩個(gè)線程依次輸出的實(shí)例，這里我們來看看三個(gè)線程如何做呢。
public class LockCond {
private static int count = 0;
private static Lock lock = new ReentrantLock();
public static void main(String[] args) {
Condition c1 = lock.newCondition();
Condition c2 = lock.newCondition();
Condition c3 = lock.newCondition();
new Thread(()->{
while(true) {
lock.lock();
try {
while(count %3 != 0) {
//剛開始count為0 0%3=0 所以此線程執(zhí)行 執(zhí)行完之后 喚醒現(xiàn)成2，由于此時(shí)count已經(jīng)進(jìn)行了++，所有while成立，c1進(jìn)入等待狀態(tài)，其他兩個(gè)也一樣
c1.await();
}
System.out.println(Thread.currentThread().getName()+"========:A");
count++;
//喚醒線程2
c2.signal();
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
lock.unlock();
}
}
}) .start();
new Thread(()->{
while(true) {
lock.lock();
try {
while(count %3 != 1) {
c2.await();
}
System.out.println(Thread.currentThread().getName()+"========:B");
count++;
//喚醒線程3
c3.signal();
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
lock.unlock();
}
}
}) .start();
new Thread(()->{
while(true) {
lock.lock();
try {
while(count %3 != 2) {
c3.await();
}
System.out.println(Thread.currentThread().getName()+"========:C");
count++;
//喚醒線程1
c1.signal();
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
lock.unlock();
}
}
}) .start();
}
}三個(gè)線程的也可以寫三種，這里寫一種就行了，寫法和上面兩個(gè)線程的都一樣。大家可以自己試一下。
Condition介紹
我們?cè)跊]有學(xué)習(xí)Lock之前，使用的最多的同步方式應(yīng)該是synchronized關(guān)鍵字來實(shí)現(xiàn)同步方式了。配合Object的wait()、notify()系列方法可以實(shí)現(xiàn)等待/通知模式。Condition接口也提供了類似Object的監(jiān)視器方法，與Lock配合可以實(shí)現(xiàn)等待/通知模式，但是這兩者在使用方式以及功能特性上還是有差別的。Object和Condition接口的一些對(duì)比。摘自《Java并發(fā)編程的藝術(shù)》
Condition接口常用方法
condition可以通俗的理解為條件隊(duì)列。當(dāng)一個(gè)線程在調(diào)用了await方法以后，直到線程等待的某個(gè)條件為真的時(shí)候才會(huì)被喚醒。這種方式為線程提供了更加簡單的等待/通知模式。Condition必須要配合鎖一起使用，因?yàn)閷?duì)共享狀態(tài)變量的訪問發(fā)生在多線程環(huán)境下。一個(gè)Condition的實(shí)例必須與一個(gè)Lock綁定，因此Condition一般都是作為Lock的內(nèi)部實(shí)現(xiàn)。
await() ：造成當(dāng)前線程在接到信號(hào)或被中斷之前一直處于等待狀態(tài)。
await(long time, TimeUnit unit) ：造成當(dāng)前線程在接到信號(hào)、被中斷或到達(dá)指定等待時(shí)間之前一直處于等待狀態(tài)。
awaitNanos(long nanosTimeout) ：造成當(dāng)前線程在接到信號(hào)、被中斷或到達(dá)指定等待時(shí)間之前一直處于等待狀態(tài)。返回值表示剩余時(shí)間，如果在nanosTimesout之前喚醒，那么返回值 = nanosTimeout - 消耗時(shí)間，如果返回值 <= 0 ,則可以認(rèn)定它已經(jīng)超時(shí)了。
awaitUninterruptibly() ：造成當(dāng)前線程在接到信號(hào)之前一直處于等待狀態(tài)?！咀⒁猓涸摲椒▽?duì)中斷不敏感】。
awaitUntil(Date deadline) ：造成當(dāng)前線程在接到信號(hào)、被中斷或到達(dá)指定最后期限之前一直處于等待狀態(tài)。如果沒有到指定時(shí)間就被通知，則返回true，否則表示到了指定時(shí)間，返回返回false。
signal() ：喚醒一個(gè)等待線程。該線程從等待方法返回前必須獲得與Condition相關(guān)的鎖。
signal()All ：喚醒所有等待線程。能夠從等待方法返回的線程必須獲得與Condition相關(guān)的鎖。
Semaphore介紹
Semaphore 是 synchronized 的加強(qiáng)版，作用是控制線程的并發(fā)數(shù)量。就這一點(diǎn)而言，單純的synchronized 關(guān)鍵字是實(shí)現(xiàn)不了的。他可以保證某一個(gè)資源在一段區(qū)間內(nèi)有多少給線程可以去訪問。
從源碼我們可以看出來，它new了一個(gè)靜態(tài)內(nèi)部類，繼承Sync接口。他同時(shí)也提供了一些構(gòu)造方法
比如說通過這個(gè)構(gòu)造方法可以創(chuàng)建一個(gè)是否公平的Semaphore類。關(guān)于公平鎖和非公平鎖大家可以看我的另外一篇文章。
到此這篇關(guān)于Java中多個(gè)線程交替循環(huán)執(zhí)行的實(shí)現(xiàn)的文章就介紹到這了,更多相關(guān)Java線程交替循環(huán)執(zhí)行內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
Java命令行運(yùn)行錯(cuò)誤之找不到或無法加載主類問題的解決方法
這篇文章主要給大家介紹了關(guān)于Java命令行運(yùn)行錯(cuò)誤之找不到或無法加載主類問題的解決方法,文中通過實(shí)例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2022-01-01
淺談Java中浮點(diǎn)型數(shù)據(jù)保留兩位小數(shù)的四種方法
今天在進(jìn)行開發(fā)的過程中遇到了一個(gè)小問題，是關(guān)于如何將double類型的數(shù)據(jù)保留兩位小數(shù)。具有一定的參考價(jià)值，本文就詳細(xì)的介紹一下2021-09-09
Java集合定義與用法實(shí)例總結(jié)【Set、List與Map】
這篇文章主要介紹了Java集合定義與用法,結(jié)合實(shí)例形式總結(jié)分析了Java集合中Set、List和Map相關(guān)概念、功能、用法及操作注意事項(xiàng),需要的朋友可以參考下2018-08-08
這篇文章主要介紹了PC 端微信掃碼注冊(cè)和登錄實(shí)例的相關(guān)資料,需要的朋友可以參考下2016-09-09
springboot靜態(tài)資源(static)無法訪問問題404及解決過程
文章瀏覽閱讀7.8k次。本文介紹了SpringBoot項(xiàng)目中遇到的靜態(tài)資源無法訪問的問題及解決辦法。主要從攔截器配置、靜態(tài)資源映射配置和pom.xml文件配置三個(gè)方面進(jìn)行詳細(xì)說明。2026-05-05
這篇文章主要給大家介紹了關(guān)于Spring框架中@AliasFor注解詳細(xì)說明的相關(guān)資料,@AliasFor是Spring Framework中的一個(gè)注解,它用于指定注解屬性之間的別名關(guān)系,文中通過代碼介紹的非常詳細(xì),需要的朋友可以參考下2024-02-02
劍指Offer之Java算法習(xí)題精講數(shù)組查找與字符串交集
跟著思路走，之后從簡單題入手，反復(fù)去看，做過之后可能會(huì)忘記，之后再做一次，記不住就反復(fù)做，反復(fù)尋求思路和規(guī)律，慢慢積累就會(huì)發(fā)現(xiàn)質(zhì)的變化2022-03-03
java編程實(shí)現(xiàn)獲取服務(wù)器IP地址及MAC地址的方法
這篇文章主要介紹了java編程實(shí)現(xiàn)獲取機(jī)器IP地址及MAC地址的方法,實(shí)例分析了Java分別針對(duì)單網(wǎng)卡及多網(wǎng)卡的情況下獲取服務(wù)器IP地址與MAC地址的相關(guān)技巧,需要的朋友可以參考下2015-11-11
Java concurrency之AtomicReference原子類_動(dòng)力節(jié)點(diǎn)Java學(xué)院整理
AtomicReference是作用是對(duì)"對(duì)象"進(jìn)行原子操作。這篇文章主要介紹了Java concurrency之AtomicReference原子類,需要的朋友可以參考下2017-06-06
這篇文章詳細(xì)介紹了JAVA中的異常與錯(cuò)誤處理，有需要的朋友可以參考一下2013-09-09