您好,登錄后才能下訂單哦!
這篇文章給大家介紹怎么在Java中利用Lock實現(xiàn)一個生產(chǎn)者消費者模型,內(nèi)容非常詳細,感興趣的小伙伴們可以參考借鑒,希望對大家能有所幫助。
具體如下:
package com.expgiga.JUC; import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; /** * 生產(chǎn)者消費者案例 */ public class TestProductorAndConsumerForLock { public static void main(String[] args) { Clerk clerk = new Clerk(); Productor productor = new Productor(clerk); Consumer consumer = new Consumer(clerk); new Thread(productor, "生產(chǎn)者A").start(); new Thread(consumer, "消費者B").start(); new Thread(productor, "生產(chǎn)者C").start(); new Thread(consumer, "消費者D").start(); } } //店員 class Clerk { private int product = 0; private Lock lock = new ReentrantLock(); private Condition condition = lock.newCondition(); //進貨方法 public void get() { lock.lock(); try { while (product >= 1) { //為了避免虛假喚醒,應(yīng)該總是使用在循環(huán)中 System.out.println("產(chǎn)品已滿!"); try { condition.await(); } catch (InterruptedException e) { e.printStackTrace(); } } System.out.println(Thread.currentThread().getName() + " : " + ++product); condition.signalAll(); } finally { lock.unlock(); } } //賣貨方法 public void sale() { lock.lock(); try { while (product <= 0) { System.out.println("產(chǎn)品缺貨!"); try { condition.await(); } catch (InterruptedException e) { e.printStackTrace(); } } System.out.println(Thread.currentThread().getName() + " : " + --product); condition.signalAll(); } finally { lock.unlock(); } } } //生產(chǎn)者 class Productor implements Runnable { private Clerk clerk; public Productor(Clerk clerk) { this.clerk = clerk; } @Override public void run() { for (int i = 0; i < 20; i++) { try { Thread.sleep(200); } catch (InterruptedException e) { e.printStackTrace(); } clerk.get(); } } } //消費者 class Consumer implements Runnable { private Clerk clerk; public Consumer(Clerk clerk) { this.clerk = clerk; } @Override public void run() { for (int i = 0; i < 20; i++) { clerk.sale(); } } }
運行結(jié)果:
產(chǎn)品缺貨!
產(chǎn)品缺貨!
生產(chǎn)者A : 1
消費者B : 0
產(chǎn)品缺貨!
產(chǎn)品缺貨!
生產(chǎn)者C : 1
消費者B : 0
產(chǎn)品缺貨!
產(chǎn)品缺貨!
生產(chǎn)者A : 1
消費者B : 0
產(chǎn)品缺貨!
產(chǎn)品缺貨!
生產(chǎn)者C : 1
消費者B : 0
產(chǎn)品缺貨!
產(chǎn)品缺貨!
生產(chǎn)者A : 1
消費者B : 0
產(chǎn)品缺貨!
產(chǎn)品缺貨!
生產(chǎn)者C : 1
消費者B : 0
產(chǎn)品缺貨!
產(chǎn)品缺貨!
生產(chǎn)者A : 1
消費者B : 0
產(chǎn)品缺貨!
產(chǎn)品缺貨!
生產(chǎn)者C : 1
消費者B : 0
產(chǎn)品缺貨!
產(chǎn)品缺貨!
生產(chǎn)者A : 1
消費者B : 0
產(chǎn)品缺貨!
產(chǎn)品缺貨!
生產(chǎn)者C : 1
消費者B : 0
產(chǎn)品缺貨!
產(chǎn)品缺貨!
生產(chǎn)者A : 1
消費者B : 0
產(chǎn)品缺貨!
產(chǎn)品缺貨!
生產(chǎn)者C : 1
消費者B : 0
產(chǎn)品缺貨!
產(chǎn)品缺貨!
生產(chǎn)者A : 1
消費者B : 0
產(chǎn)品缺貨!
產(chǎn)品缺貨!
生產(chǎn)者C : 1
消費者B : 0
產(chǎn)品缺貨!
產(chǎn)品缺貨!
生產(chǎn)者A : 1
產(chǎn)品已滿!
消費者B : 0
產(chǎn)品缺貨!
產(chǎn)品缺貨!
生產(chǎn)者C : 1
消費者B : 0
產(chǎn)品缺貨!
產(chǎn)品缺貨!
生產(chǎn)者C : 1
產(chǎn)品已滿!
消費者B : 0
產(chǎn)品缺貨!
產(chǎn)品缺貨!
生產(chǎn)者A : 1
消費者B : 0
產(chǎn)品缺貨!
產(chǎn)品缺貨!
生產(chǎn)者C : 1
消費者B : 0
產(chǎn)品缺貨!
產(chǎn)品缺貨!
生產(chǎn)者A : 1
消費者B : 0
產(chǎn)品缺貨!
生產(chǎn)者C : 1
消費者D : 0
產(chǎn)品缺貨!
生產(chǎn)者A : 1
消費者D : 0
產(chǎn)品缺貨!
生產(chǎn)者C : 1
消費者D : 0
產(chǎn)品缺貨!
生產(chǎn)者A : 1
消費者D : 0
產(chǎn)品缺貨!
生產(chǎn)者C : 1
消費者D : 0
產(chǎn)品缺貨!
生產(chǎn)者A : 1
消費者D : 0
產(chǎn)品缺貨!
生產(chǎn)者C : 1
消費者D : 0
產(chǎn)品缺貨!
生產(chǎn)者A : 1
消費者D : 0
產(chǎn)品缺貨!
生產(chǎn)者C : 1
消費者D : 0
產(chǎn)品缺貨!
生產(chǎn)者A : 1
消費者D : 0
產(chǎn)品缺貨!
生產(chǎn)者C : 1
消費者D : 0
產(chǎn)品缺貨!
生產(chǎn)者A : 1
消費者D : 0
產(chǎn)品缺貨!
生產(chǎn)者C : 1
消費者D : 0
產(chǎn)品缺貨!
生產(chǎn)者A : 1
消費者D : 0
產(chǎn)品缺貨!
生產(chǎn)者C : 1
消費者D : 0
產(chǎn)品缺貨!
生產(chǎn)者A : 1
消費者D : 0
產(chǎn)品缺貨!
生產(chǎn)者C : 1
消費者D : 0
產(chǎn)品缺貨!
生產(chǎn)者A : 1
消費者D : 0
產(chǎn)品缺貨!
生產(chǎn)者C : 1
消費者D : 0
產(chǎn)品缺貨!
生產(chǎn)者A : 1
消費者D : 0
關(guān)于怎么在Java中利用Lock實現(xiàn)一個生產(chǎn)者消費者模型就分享到這里了,希望以上內(nèi)容可以對大家有一定的幫助,可以學(xué)到更多知識。如果覺得文章不錯,可以把它分享出去讓更多的人看到。
免責聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進行舉報,并提供相關(guān)證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權(quán)內(nèi)容。