上一篇[Java多線程之并發(fā)協(xié)作生產(chǎn)者消費(fèi)者設(shè)計(jì)模式]已經(jīng)講述了在Java的多線程中翁逞，如何處理并發(fā)安全的生產(chǎn)者消費(fèi)者設(shè)計(jì)模式埂材，不了解的可以先看看上一篇的內(nèi)容
上一篇中的效率和優(yōu)化問(wèn)題
- 在上一篇中生產(chǎn)者消費(fèi)者設(shè)計(jì)模式中最后為了不產(chǎn)生類(lèi)似于“死鎖”老客，就是多線程全部wait()導(dǎo)致程序無(wú)法向下繼續(xù)運(yùn)行的情況咧党，我們采用了notifyAll()這個(gè)方法炊豪，那么有什么問(wèn)題呢在跳？
- 效率問(wèn)題，notifyAll()方法是將在執(zhí)行了wait()方法后的所有等待線程都喚醒了伶选，那么也就是說(shuō)史飞，即喚醒了生產(chǎn)者線程也喚醒了消費(fèi)者線程
- 優(yōu)化方案：我們沒(méi)有必要把大家都喚醒，只需要讓生產(chǎn)者線程喚醒消費(fèi)者線程仰税，消費(fèi)者線程喚醒生產(chǎn)者線程即可构资。
jdk1.5的對(duì)多線程并發(fā)安全的新解決方案
- jdk1.5以后將同步和鎖封裝成了對(duì)象。并將操作鎖的隱式方式定義到了該對(duì)象中陨簇，將隱式動(dòng)作變成了顯示動(dòng)作。
- Lock接口： 出現(xiàn)替代了同步代碼塊或者同步函數(shù)。將同步的隱式鎖操作變成現(xiàn)實(shí)鎖操作唉窃。同時(shí)更為靈活纹份÷В可以一個(gè)鎖上加上多組監(jiān)視器。
- lock():獲取鎖鳞陨。
- unlock():釋放鎖厦滤，通常需要定義finally代碼塊中掏导。
- Condition接口：出現(xiàn)替代了Object中的wait notify notifyAll方法趟咆。將這些監(jiān)視器方法單獨(dú)進(jìn)行了封裝梅屉，變成Condition監(jiān)視器對(duì)象坯汤《枘簦可以任意鎖進(jìn)行組合搓幌。
- await();線程等待—>等同于wait();【監(jiān)視器的方法】
- signal();喚醒線程——>等同于notify();【監(jiān)視器的方法】
- signalAll();喚醒全部等待中的線程——>等同于notifyAll();【監(jiān)視器的方法】
最終經(jīng)過(guò)優(yōu)化的代碼
- Resource.java
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
/**
* Created by yuandl on 2016-10-12.
* 要生產(chǎn)的資源
*/
public class Resource {
private int number = 0;//資源編號(hào)
private boolean flag = false;//資源標(biāo)記 時(shí)候有資源
/* 創(chuàng)建一個(gè)鎖對(duì)象反番。*/
private Lock lock = new ReentrantLock();//鎖
/*通過(guò)已有的鎖獲取該鎖上的監(jiān)視器對(duì)象罢缸。通過(guò)已有的鎖獲取兩組監(jiān)視器枫疆，一組監(jiān)視生產(chǎn)者息楔，一組監(jiān)視消費(fèi)者值依。*/
private Condition condition_consumer = lock.newCondition();//消費(fèi)者對(duì)鎖的監(jiān)視器
private Condition condition_producer = lock.newCondition();//生產(chǎn)者對(duì)鎖的監(jiān)視器
public void create() {
lock.lock();
try {
while (flag) {
condition_producer.await();
}
number++;
System.out.println("生產(chǎn)者--------------" + number);
flag = true;
condition_consumer.signalAll();
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
lock.unlock();
}
}
public void destroy() {
lock.lock();
try {
while (!flag) {
condition_consumer.await();
}
System.out.println("消費(fèi)者***" + number);
flag = false;
condition_producer.signalAll();
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
lock.unlock();
}
}
}
- Producer.java
/**
* Created by yuandl on 2016-10-12.
* 生產(chǎn)者
*/
public class Producer implements Runnable {
private Resource resource;
public Producer(Resource resource) {
this.resource = resource;
}
@Override
public void run() {
while (true) {
try {
Thread.sleep(10);
} catch (InterruptedException e) {
e.printStackTrace();
}
resource.create();
}
}
}
- Consumer.java
/**
* Created by yuandl on 2016-10-12.
* 消費(fèi)者
*/
public class Consumer implements Runnable {
private Resource resource;
public Consumer(Resource resource) {
this.resource = resource;
}
@Override
public void run() {
while (true) {
try {
Thread.sleep(10);
} catch (InterruptedException e) {
e.printStackTrace();
}
resource.destroy();
}
}
}
- MainTest.java
package thread.produceconsumer2;
/**
* Created by yuandl on 2016-10-12.
*/
public class MainTest {
public static void main(String args[]) {
Resource resource = new Resource();
new Thread(new Producer(resource)).start();
new Thread(new Producer(resource)).start();
new Thread(new Consumer(resource)).start();
new Thread(new Consumer(resource)).start();
}
}
- 打印結(jié)果
生產(chǎn)者--------------381
消費(fèi)者***381
生產(chǎn)者--------------382
消費(fèi)者***382
生產(chǎn)者--------------383
消費(fèi)者***383
生產(chǎn)者--------------384
消費(fèi)者***384
生產(chǎn)者--------------385
消費(fèi)者***385
生產(chǎn)者--------------386
消費(fèi)者***386
生產(chǎn)者--------------387
消費(fèi)者***387
生產(chǎn)者--------------388
消費(fèi)者***388
生產(chǎn)者--------------389
消費(fèi)者***389
生產(chǎn)者--------------390
消費(fèi)者***390
生產(chǎn)者--------------391
消費(fèi)者***391
