使用wait及notify方法实现线程之间的互通信

下面的代码，如果没有t3和t4这两个进程，程序输出的结果是 0 1 0 1 0 1 0 1 0 1 0 1 0 1 ……
加上t3和t4这两个进程之后，输出结果就乱了，没有任何规律。这是为什么？应该怎么改才能使输出结果变成 0 1 0 1 0 1 0 1 0 1 0 1 0 1 ……

看代码吧：

public class MainTest
{
public static void main(String[] args)
{
Sample sample = new Sample();
Thread t1 = new IncreaseThread(sample);
Thread t2 = new DecreaseThread(sample);
Thread t3 = new IncreaseThread(sample);
Thread t4 = new DecreaseThread(sample);
t1.start();
t2.start();
t3.start();
t4.start();
}
}

复制代码

public class IncreaseThread extends Thread
{
private Sample sample;
public IncreaseThread(Sample sample)
{
this.sample = sample;
}
public void run()
{
for(int i=0 ; i<20 ; i++)
{
try
{
Thread.sleep((long)(Math.random()*1000));
} catch (InterruptedException e)
{
e.printStackTrace();
}
sample.increase();
}
}
}

复制代码

public class DecreaseThread extends Thread
{
private Sample sample;
public DecreaseThread(Sample sample)
{
this.sample = sample;
}
public void run()
{
for(int i=0 ; i<20 ; i++)
{
try
{
Thread.sleep((long)(Math.random()*1000));
} catch (InterruptedException e)
{
e.printStackTrace();
}
sample.decrease();
}
}
}

复制代码

public class Sample
{
private int number;
public synchronized void increase()
{
if(0 != number)
{
try
{
wait();
} catch (InterruptedException e)
{
e.printStackTrace();
}
}
number++;
System.out.println(number);
notify();
}
public synchronized void decrease()
{
if(0 == number)
{
try
{
wait();
} catch (InterruptedException e)
{
e.printStackTrace();
}
}
number--;
System.out.println(number);
notify();
}
}

复制代码

刘源 · 刘源

public class Sample
{
private int number;
public synchronized void increase()
{
  if(0 != number)
  {
try
{
wait();
} catch (InterruptedException e)
{
e.printStackTrace();
}
  }

  number++;

  System.out.println(number);

notify();
}
public synchronized void decrease()
{
if(0 == number)
  {
try
{
wait();
} catch (InterruptedException e)
{
e.printStackTrace();
}
  }

  number--;

  System.out.println(number);

  notify();
}
}

Thread t1 = new IncreaseThread(sample);
Thread t2 = new DecreaseThread(sample)
Thread t3 = new IncreaseThread(sample);
Thread t4 = new DecreaseThread(sample);
先说说怎么改：你只需要把if,改为while.notify改为notifyAll。就行了。
再说说你的为什么会乱：假如这种情况，当开始0 == number时，执行 if(0 == number)的时候，你的t2，t4个线程执行number--时，你会发现他们都在if中wait()了。然后 t1 线程执行 if(0 ！= number)时，t1就把t2的唤醒,然后t1也wait()，现在还能有执行权的是t2和t3。然后t3执行，因为现在number=1。所以t3，也wait()。现在就剩t2了。
注意：由于t2执行时，就会把t4唤醒，由于是if条件语句，t4就不会去判断if(0 == number)。所有t4就会继续执行下去。所以执行了2次number--。所以你的程序就乱了。
最后说说为什么这么改：由上面分析，你应该知道，t4唤醒时，还要去判断下，所以if就改为while。但用while是，会出现死锁。所以就把notify，改为notifyAll。因为每个线程唤醒时，都会去判断条件，所有之后就不会乱了。

黑马_许芸 · 黑马_许芸

刘源发表于 2012-8-23 10:04
public class Sample
{
private int number;

你真厉害。我看懂了。只是不太明白notify和notifyAll的区别是什么？为什么你说使用notifyAll就不会出现死锁？

刘源 · 刘源

notify:一次只能唤醒一个，就是把最先wait(),的那个线程唤醒。
notifyAll:而它就是把所有wait()的线程全部唤醒。你想啊，每次他都把你4个线程都唤醒了，肯定不会出现4个线程都wait()的情况啊

黑马_许芸 · 黑马_许芸

刘源发表于 2012-8-23 10:18
notify:一次只能唤醒一个，就是把最先wait(),的那个线程唤醒。
notifyAll:而它就是把所有wait()的线程全部 ...

明白了。谢谢。问题已解决。

帐号		自动登录	找回密码
密码			加入黑马

使用wait及notify方法实现线程之间的互通信

4 个回复