1.一生產(chǎn)與一消費(fèi)：操作值
public class P {
private String lock;
public P(String lock){
super();
this.lock = lock;
}
public void setValue(){
try {
synchronized (lock){
if(!ValueObject.value.equals("")){
lock.wait();
}
String value = System.currentTimeMillis() + "_" +
System.nanoTime();
System.out.println("set的值是" + value);
ValueObject.value = value;
lock.notify();
}
} catch (InterruptedException e) {
e.printStackTrace();
}
}
class C {
private String lock;
public C(String lock) {
super();
this.lock = lock;
}
public void getValue() {
try {
synchronized (lock) {
if (ValueObject.value.equals("")) {
lock.wait();
}
System.out.println("get的值是" + ValueObject.value);
ValueObject.value = "";
lock.notify();
}
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
class ThreadP extends Thread {
private P p;
public ThreadP(P p){
super();
this.p = p;
}
@Override
public void run(){
while (true){
p.setValue();
}
}
}
class ThreadC extends Thread {
private C c;
public ThreadC(C c){
super();
this.c = c;
}
@Override
public void run(){
while (true){
c.setValue();
}
}
}
}
public class Run{
public static void main(String[] args){
String lock = new String("");
P p = new P(lock);
C c = new C(lock);
ThreadP pThread = new ThreadP(p);
ThreadC cThread = new ThreadC(r);
pThread.start();
cThread.start();
}
}
上述代碼是一生產(chǎn)一消費(fèi)進(jìn)行數(shù)據(jù)的交互在控制臺中打印的日志get和set是交替運(yùn)行的扼劈。
但是如果是多生產(chǎn)者和多消費(fèi)者宛徊，那在運(yùn)行中就極有可能出現(xiàn)假死狀態(tài)（即所有線程均處于WAITING狀態(tài)）
2.多生產(chǎn)與多消費(fèi)：操作值－假死
假死的現(xiàn)象其實(shí)就是線程進(jìn)入WAITING狀態(tài)壕翩，則程序就不再執(zhí)行任何業(yè)務(wù)功能了泛豪，整個項(xiàng)目呈停止?fàn)顟B(tài)蚜迅。這在使用生產(chǎn)者與消費(fèi)者模式時經(jīng)常遇到敢艰。
public class P｛
private String lock诬乞；
public P（String lock）｛
super（）；
this.lock ＝ lock钠导；
｝
public void setValue（）｛
synchronized （lock）｛
while（震嫉！ValueObject.Value.equals（""））｛
System.out.println（“生產(chǎn)者”＋
Thread.currentThread（）.getName()+"WAITING了"）；
lock.wait();
｝
System.out.println("生產(chǎn)者"＋
Thread.currentThread().getName()+"RUNNABLE了")牡属；
String value ＝
System.currentTimeMillis()+"_"+System.nanoTime();
ValueObject.value=value;
lock.notify();
｝
｝
｝
public class C｛
private String lock票堵；
public C（String lock）｛
super（）；
this.lock ＝ lock逮栅；
｝
public void setValue（）｛
synchronized （lock）｛
while（ValueObject.Value.equals（""））｛
System.out.println（“消費(fèi)者”＋
Thread.currentThread（）.getName()+"WAITING了"）悴势；
lock.wait();
｝
System.out.println("消費(fèi)者"＋
Thread.currentThread().getName()+"RUNNABLE了");
ValueObject.value="";
lock.notify();
｝
｝
｝
class ThreadP extends Thread {
private P p;
public ThreadP(P p){
super();
this.p = p;
}
@Override
public void run(){
while (true){
p.setValue();
}
}
}
class ThreadC extends Thread {
private C c;
public ThreadC(C c){
super();
this.c = c;
}
@Override
public void run(){
while (true){
c.setValue();
}
}
}
}
public class Run{
public static void main（String［］ args）｛
String lock = new String("")；
P p = new P(lock);
C r = new C(lock);
ThreadP[] pThread = new ThreadP[2];
ThreadC[] rThread = new ThreadC[2];
for(int i=0;i<2;i++){
pThread[i] = new ThreadP(p);
pThread[i].setName("生產(chǎn)者"＋（i＋1）)措伐；
rThread[i] = new ThreadC(r);
rThread[i].setName("消費(fèi)者" ＋ (i+1));
pThread[i].start();
rThread[i].start();
}
Thread.sleep(5000);
Thread[] threadArray = new
Thread[Thread.currentThread().getThreadGroup().activeCount()];
Thread.currentThread().getThreadGroup()
.enumerate(threadArray);
for(int i = 0;i<threadArray.length;i++){
System.out.println(ThreadArray[i].getName()+" "+threadArray[i].getState());
}
｝
}
在代碼中確實(shí)已經(jīng)通過wait／notify進(jìn)行通信了特纤，但不保證notify喚醒的是異類，也許是同類侥加，比如“生產(chǎn)者”喚醒“生產(chǎn)者”或“消費(fèi)者”喚醒“消費(fèi)者”這樣的情況叫潦。如果按這樣的情況運(yùn)行的比率積少成多，就會導(dǎo)致所有的線程都不能繼續(xù)運(yùn)行下去，大家都在等待矗蕊，都呈WAITING狀態(tài)短蜕，程序最后也就呈假死狀態(tài)。
如何解決喚醒同類的問題傻咖？
將notify（）改成notifyAll（）朋魔，也就是不光喚醒同類，將異類也一同喚醒就解決了卿操。
