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

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

Java多種方式實(shí)現(xiàn)生產(chǎn)者消費(fèi)者模式

瀏覽:22日期:2022-08-29 10:42:17

實(shí)現(xiàn)需求:兩個(gè)線程交替打印1,0,打印10輪

java多線程口訣:

高內(nèi)聚,低耦合 線程操作資源類 判斷干活通知 防止虛假喚醒

方式一:使用synchronized和Object的wait和notifyAll方法

wait:使當(dāng)前線程阻塞

notify,notifyAll喚醒當(dāng)前線程

/** * 兩個(gè)線程交替打印1,0 打印10輪 * * @author Administrator * @version 1.0 2020年7月12日 * @see ProdConsumerDemo1 * @since 1.0 * */class ShareData1 { public int number = 0; public synchronized void increment() throws Exception { while (number != 0) { this.wait(); } number++; System.out.println(Thread.currentThread().getName() + ' ' + number); this.notifyAll(); } public synchronized void decrement() throws InterruptedException { while (number != 1) { this.wait(); } number--; System.out.println(Thread.currentThread().getName() + ' ' + number); this.notifyAll(); }} public class ProdConsumerDemo1 { public static void main(String[] args) { ShareData1 shareData = new ShareData1(); new Thread(() -> { for (int i = 0; i < 10; i++) {try { shareData.increment();} catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace();} } }, 'A').start(); new Thread(() -> { for (int i = 0; i < 10; i++) {try { shareData.decrement();} catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace();} } }, 'B').start(); }}

輸出結(jié)果

A 1B 0A 1B 0A 1B 0A 1B 0A 1B 0A 1B 0A 1B 0A 1B 0A 1B 0A 1B 0

方式二:使用jdk1.8的Lock和Condition

class ShareData2 { private int number = 0; private Lock lock = new ReentrantLock(); private Condition condition = lock.newCondition(); public void increment() throws Exception { lock.lock(); try { while (number != 0) {condition.await(); } number++; System.out.println(Thread.currentThread().getName() + ' ' + number); condition.signalAll(); } finally { lock.unlock(); } } public void decrement() throws InterruptedException { lock.lock(); try { while (number != 1) {condition.await(); } number--; System.out.println(Thread.currentThread().getName() + ' ' + number); condition.signalAll(); } finally { // TODO: handle finally clause lock.unlock(); } }} public class ProdConsumerDemo2 { public static void main(String[] args) { ShareData2 shareData = new ShareData2(); new Thread(() -> { for (int i = 0; i < 10; i++) {try { shareData.increment();} catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace();} } }, 'A').start(); new Thread(() -> { for (int i = 0; i < 10; i++) {try { shareData.decrement();} catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace();} } }, 'B').start(); }}

輸出結(jié)果

A 1B 0A 1B 0A 1B 0A 1B 0A 1B 0A 1B 0A 1B 0A 1B 0A 1B 0A 1B 0

主要是熟悉Lock和Condition的使用

Lock和Condition相比于synchronized,能夠精確喚醒

需求:三個(gè)線程A,B,C順序打印,A打印5次,B打印10次,C打印15次,10輪

class ShareData3 { private int number = 1; private Lock lock = new ReentrantLock(); private Condition c1 = lock.newCondition(); private Condition c2 = lock.newCondition(); private Condition c3 = lock.newCondition(); public void print5() throws Exception { lock.lock(); try { while (number != 1) {c1.await(); } number = 2; for (int i = 0; i < 5; i++) {System.out.println(Thread.currentThread().getName() + ' ' + i); } c2.signalAll(); } finally { // TODO: handle finally clause lock.unlock(); } } public void print10() throws InterruptedException { lock.lock(); try { while (number != 2) {c2.await(); } number=3; for (int i = 0; i < 10; i++) {System.out.println(Thread.currentThread().getName() + ' ' + i); } c3.signalAll(); } finally { // TODO: handle finally clause lock.unlock(); } } public void print15() throws InterruptedException { lock.lock(); try { while (number != 3) {c3.await(); } number = 1; for (int i = 0; i < 15; i++) {System.out.println(Thread.currentThread().getName() + ' ' + i); } c1.signalAll(); } finally { // TODO: handle finally clause lock.unlock(); } }} public class ProdConsumerDemo3 { public static void main(String[] args) { ShareData3 shareData3 = new ShareData3(); new Thread(() -> { try {for (int i = 0; i < 10; i++) { shareData3.print5();} } catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace(); } }, 'A').start(); new Thread(() -> { try {for (int i = 0; i < 10; i++) { shareData3.print10();} } catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace(); } }, 'B').start(); new Thread(() -> { try {for (int i = 0; i < 10; i++) { shareData3.print15();} } catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace(); } }, 'C').start(); }}

以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持好吧啦網(wǎng)。

標(biāo)簽: Java
相關(guān)文章:
主站蜘蛛池模板: 91久操视频 | 久久久久国产精品免费免费搜索 | 精品国产乱码久久久久久影片 | 国产精品1区 | 久久久蜜桃一区二区人 | 一区二区三区视频 | 97在线观视频免费观看 | 午夜视频一区二区三区 | av手机在线看 | 日日噜噜噜夜夜爽爽狠狠视频, | 黄色一级免费 | 97超级碰碰 | 毛片入口 | 综合二区 | 欧美久久久久 | 超碰免费在线 | 国产一区二区三区久久久久久久久 | h小视频| www.亚洲精品 | 九九热这里 | 久久精品国产久精国产 | 国产精品久久久久久久久久99 | 亚洲成人福利 | 99久久精品国产一区二区三区 | 视频一区在线观看 | cao在线 | 成人免费在线视频 | 日本不卡免费新一二三区 | 伊人久久在线 | 欧美不卡一区二区 | 麻豆av一区二区三区久久 | 午夜在线视频一区二区三区 | 久久精品亚洲国产奇米99 | 欧美一级二级三级视频 | 欧美日韩国产高清视频 | 国产剧情一区 | 欧州一区二区三区 | 一区二区三区在线 | 久久久久久久一区 | 神马久久av | 欧美一区二区在线免费观看 |