842      阿里云  技术社区[云栖]

线程同步2——同步通信wait和notify

一、线程如何停止
使用stop()不安全。它会解除由线程获取的所有锁定，而且如果对象处于一种不连贯状态，那么其他线程能在那种状态下检查和修改它们。结果很难检查出真正的问题所在。suspend()方法容易发生死锁。调用suspend()的时候，目标线程会停下来，但却仍然持有在这之前获得的锁定。此时其他任何线程都不能访问锁定的资源，除非被"挂起"的线程恢复运行。对任何线程来说，如果它们想恢复目标线程，同时又试图使用任何一个锁定的资源，就会造成死锁。所以不应该使用suspend()。正确的做法是而应在自己的Thread类中置入一个标志，指出线程应该活动还是挂起。若标志指出线程应该挂起，便用wait()命其进入等待状态。若标志指出线程应当恢复，则用一个notify()重新启动线程。

二、wait和notify实例
子线程循环10次，主线程循环100次。接着子线程循环10次，主线程循环100次。如此循环50次。摘自张孝祥老师线程视频源码。

public class TraditionalThreadCommunication
{

 public static void main(String[] args)
 {
  final Business business = new Business();
  new Thread(new Runnable()
  {
   public void run()
   {
    for (int i = 1; i <= 50; i++)
    {
     business.sub(i);
    }
   }
  }).start();

  for (int i = 1; i <= 50; i++)
  {
   business.main(i);
  }

 }

}

class Business
{
 private boolean bShouldSub = true;

 public synchronized void sub(int i)
 {
  while (!bShouldSub)
  {
   try
   {
    this.wait();
   }
   catch (InterruptedException e)
   {
    e.printStackTrace();
   }
  }
  for (int j = 1; j <= 10; j++)
  {
   System.out.println("sub thread sequence of " + j + ",loop of " + i);
  }
  bShouldSub = false;
  this.notify();
 }

 public synchronized void main(int i)
 {
  while (bShouldSub)
  {
   try
   {
    this.wait();
   }
   catch (InterruptedException e)
   {
    e.printStackTrace();
   }
  }
  for (int j = 1; j <= 100; j++)
  {
   System.out.println("main thread sequence of " + j + ",loop of " + i);
  }
  bShouldSub = true;
  this.notify();
 }
}

最后更新：2017-04-03 20:19:19

  上一篇： JSP过滤器Filter配置过滤类型汇总

  下一篇： linux查看文件夹大小、文件个数的方法