av一区二区在线观看_亚洲男人的天堂网站_日韩亚洲视频_在线成人免费_欧美日韩精品免费观看视频_久草视

您的位置:首頁技術(shù)文章
文章詳情頁

java如何實(shí)現(xiàn)多線程的順序執(zhí)行

瀏覽:6日期:2022-08-12 15:25:29
場景

編寫一個程序,啟動三個線程,三個線程的name分別是A,B,C;,每個線程將自己的ID值在屏幕上打印5遍,打印順序是ABCABC...

使用 synchronized 實(shí)現(xiàn)

public class MyService{ private int flag = 1;public synchronized void printA(){while (flag != 1){ try {this.wait(); } catch (InterruptedException e) {e.printStackTrace(); }}System.out.print(Thread.currentThread().getName());flag = 2;this.notifyAll(); } public synchronized void printB(){while (flag != 2){ try {this.wait(); } catch (InterruptedException e) {e.printStackTrace(); }}System.out.print(Thread.currentThread().getName());flag = 3;this.notifyAll(); } public synchronized void printC(){while (flag != 3){ try {this.wait(); } catch (InterruptedException e) {e.printStackTrace(); }}System.out.print(Thread.currentThread().getName());flag = 1;this.notifyAll(); }}

這里的判斷條件中用的是 while 而不是 if , 這兩者之間有什么區(qū)別呢? 線程從 wait 狀態(tài)被喚醒,并且獲得鎖以后會繼續(xù)往下執(zhí)行,比如 A 調(diào)用nofityAll() 喚醒 B,C,這時 B與C誰會先獲得鎖是不確定的。如果是C先獲得了鎖,那么C就繼續(xù)往下執(zhí)行打印,這與我們的期望的不符。所以這里我們使用了一個 while,當(dāng)C獲得鎖以后再去判斷一下flag,如果這時還不是它執(zhí)行的時候,它就再次進(jìn)入wait狀態(tài)。此時A與C都是wait狀態(tài),獲得鎖的一定是B,從而實(shí)現(xiàn)我們期望的順序打印。

測試類

package testABC;public class TestMain{ public static void main(String[] args) {//編寫一個程序,啟動三個線程,三個線程的ID分別是A,B,C;,每個線程將自己的ID值在屏幕上打印5遍,打印順序是ABCABC...//MyService service = new MyService();MyService2 service = new MyService2();Thread A = new Thread(new Runnable(){ @Override public void run() {for (int i = 0; i < 5; i++){ service.printA();} }});A.setName('A');Thread B = new Thread(new Runnable(){ @Override public void run() {for (int i = 0; i < 5; i++){ service.printB();} }});B.setName('B');Thread C = new Thread(new Runnable(){ @Override public void run() {for (int i = 0; i < 5; i++){ service.printC();} }});C.setName('C');A.start();B.start();C.start(); }}使用 Lock 實(shí)現(xiàn)

import java.util.concurrent.locks.Condition;import java.util.concurrent.locks.Lock;import java.util.concurrent.locks.ReentrantLock;public class MyService2{ private int flag = 1; private Lock lock = new ReentrantLock(); private Condition conditionA = lock.newCondition(); private Condition conditionB = lock.newCondition(); private Condition conditionC = lock.newCondition(); public void printA() {try{ lock.lock(); if (flag != 1) {try{ conditionA.await();}catch (InterruptedException e){ e.printStackTrace();} } System.out.print(Thread.currentThread().getName()); flag = 2; conditionB.signal();}finally{ lock.unlock();} } public void printB() {try{ lock.lock(); if (flag != 2) {try{ conditionB.await();}catch (InterruptedException e){ e.printStackTrace();} } System.out.print(Thread.currentThread().getName()); flag = 3; conditionC.signal();}finally{ lock.unlock();} } public void printC() {try{ lock.lock(); if (flag != 3) {try{ conditionC.await();}catch (InterruptedException e){ e.printStackTrace();} } System.out.print(Thread.currentThread().getName()); flag = 1; conditionA.signal();}finally{ lock.unlock();} }}

當(dāng)使用LOCK時可以不使用while因?yàn)閏ondition可以喚醒指定的線程。同時注意必須先調(diào)用 conditionA.signal(); 再調(diào)用 lock.unlock(); ,否則會拋 java.lang.IllegalMonitorStateException 異常。因?yàn)樵谡{(diào)用unlock之后,當(dāng)前線程已不是此監(jiān)視器對象condition的持有者。也就是說要在此線程持有鎖定對象時,才能使用此鎖定對象。

關(guān)于此異常的博文:關(guān)于java.lang.IllegalMonitorStateException

api中的解釋

public class IllegalMonitorStateExceptionextends RuntimeException

拋出的異常表明某一線程已經(jīng)試圖等待對象的監(jiān)視器,或者試圖通知其他正在等待對象的監(jiān)視器而本身沒有指定監(jiān)視器的線程。

從以下版本開始:

JDK1.0

另請參見: Object.notify(), Object.notifyAll(), Object.wait(), Object.wait(long), Object.wait(long, int), 序列化表格

也就是當(dāng)前的線程不是此對象監(jiān)視器的所有者。也就是要在當(dāng)前線程鎖定對象,才能用鎖定的對象此行這些方法,需要用到synchronized ,鎖定什么對象就用什么對象來執(zhí)行

notify(), notifyAll(),wait(), wait(long), wait(long, int)操作,否則就會報IllegalMonitorStateException異常。

例如 :

exapmle 1,鎖定方法所屬的實(shí)例對象:

public synchronized void method(){ //然后就可以調(diào)用:this.notify()... //或者直接調(diào)用notify()...}

exapmle 2,鎖定方法所屬的實(shí)例的Class:

public Class Test{ public static synchronized void method(){ //然后調(diào)用:Test.class.notify()... }}

exapmle 3,鎖定其他對象:

public Class Test{public Object lock = new Object(); public static void method(){ synchronized (lock) { //需要調(diào)用 lock.notify(); } }}

到此這篇關(guān)于java如何實(shí)現(xiàn)多線程的順序執(zhí)行的文章就介紹到這了,更多相關(guān)java 多線程順序執(zhí)行內(nèi)容請搜索好吧啦網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持好吧啦網(wǎng)!

標(biāo)簽: Java
相關(guān)文章:
主站蜘蛛池模板: yiren22 亚洲综合 | 亚洲国产成人久久综合一区,久久久国产99 | 91精品国产综合久久久动漫日韩 | 中文字幕亚洲精品 | 亚州精品天堂中文字幕 | 精品国产欧美日韩不卡在线观看 | 国产精品久久国产精品 | 日韩欧美二区 | 日韩精品中文字幕在线 | 91高清视频| 亚洲成人久久久 | 午夜在线影院 | 日韩综合在线播放 | 91在线色视频 | 剑来高清在线观看 | 精品乱码一区二区三四区 | 国产伦一区二区三区四区 | 日韩一级免费大片 | 日韩精品在线一区 | 黄色片av | 久久er精品 | 日韩国产高清在线观看 | 国产精品视频一二三区 | 国产一区二区在线播放 | 国产一区二区 | www.99热这里只有精品 | 欧美极品在线视频 | 亚洲欧美日韩国产综合 | 久久久久精 | 久久久精品在线 | 免费成年网站 | 国产成人精品免费视频大全最热 | 亚洲欧洲日本国产 | 特黄特色大片免费视频观看 | 成人婷婷 | 中文字幕在线三区 | 欧美一级视频免费看 | 在线欧美亚洲 | 天天草天天爱 | 欧美高清视频一区 | 国产一区二区在线免费观看 |