关于线程调度，高手请进！__public_synchronized_notifyAll_A.t_class_

当前位置: 技术问答>java相关

关于线程调度，高手请进！

来源: 互联网发布时间：2015-04-15

本文导语: 关于wait() wait()只能在一个被同步的方法内被调用，并释放某个对象锁；注意：它不能在一个被同步的块内被调用，所以它所释放的对象是拥有这个被同步（synchronized)的方法的类的一个对象--即当前对象，我在这一点...

关于wait()
wait()只能在一个被同步的方法内被调用，并释放某个对象锁；
注意：它不能在一个被同步的块内被调用，所以它所释放的对象是拥有这个被同步（synchronized)的方法的类的一个对象--即当前对象，我在这一点上的理解应
该没有错误吧？
与wait()配套的是notify()或是notifyAll()，他门两个也只能在被同步的方法或
块被调用，我想用下面的形式实现线程调度，不知为什么会错：

public class Main
{ public static void main(String[] args)
  { new A(); }
}

public class A
{
   public A()
   {
      t=new B();
      t.start();

      new C().start();
   }

   public static Thread t;
   public static Queue queue=new Queue();  //这是个自己实现的队列，在此充当消息队列
}

class B extends Thread
{
  public synchronized void run()
  {
    while(true)
    {
     if(A.queue.isEmpty())
        wait();
     else { do something... }
    }
  }
}

class C extends Thread
{
  public void run()
  {
   while(true)
   {
    //这里有相关代码等待套接子输入流的信息
    A.queue.EnQueue(Message);
    synchronized(A.t)
    {  notifyAll();  }
  }
}

我想实现的功能是启动两个线程，一个从消息队列取出消息，如果消息队列为空，则等待。
第二个是在等待套接子输入流的信息（注意：等待套接子的输入流信息不阻塞其他线程），如有消
息到来则让消息进入队列，同时唤醒第一个线程，好取出消息并做响应处理；
编译通过，但执行时抛出如下异常：java.lang.IllegalMonitorStateException
根据文档的说明，证明 synchronized(A.t)
                     {  notifyAll();  }语句没有锁住A.t，
这是为什么？希望大家讨论，也希望大家能提出解决这个问题的其他方案来。

另附：其实在这里如果用suspend(),和resume()很容易解决问题，但我想用wait()应该能解决吧？

很荣幸成为你口中的“高手”。
这个问题出在notifyAll()的调用上面！
下面是在JDK文档中对Object.notifyAll()方法的描述：
Wakes up a single thread that is waiting on this object's monitor。
注意那个“this”。
也就是说：你的notifyAll()的调用是在C类的this上调用的，所以它
首先必须获得C类this的锁！
既然问题找到了，那么就很容易得出两种改法：
1、C类中的synchronized(A.t)改成：synchronized(this)
当然，我想这不是你要的，因为虽然这样不出错，但是B和C没有在同一个
对象上面同步。
2、C类中的notifyAll();改成：A.t.notifyAll();
我想这才是你真正想要的吧。

快试试吧，会有惊喜的。

下面是我的实验程序，你可以参考（别忘了给我加分呀～～～）：



import java.util.*;



public class Main{

	public static void main(String[] args) { 

		new A().go();

	} 

} 



class A{ 

	public static Thread t = new B(); 

	public static Queue queue = new Queue();

	public void go() { 

		t.start(); 

		new C().start(); 

	} 

} 



class B extends Thread { 

	public synchronized void run(){ 

		while(true){ 

			if(A.queue.isEmpty())

				try{

					sleep(1000);

					wait();

				}catch(InterruptedException e){}

			else

				System.out.println(A.queue.getValues());

		} 

	} 

} 



class C extends Thread {

	public void run() {

		int i = 1;

		while(true) {

			try{

				sleep(2000);

			}catch(InterruptedException e){}

			A.queue.insert(""+i);

			synchronized(A.t){A.t.notifyAll();}

			i++;

		}

	}

}



class Queue{

	Vector vector = new Vector();

	public void insert(String str){

		vector.addElement(str);

	}

	public boolean isEmpty(){

		return vector.isEmpty();

	}

	public String getValues(){

		StringBuffer strbuf = new StringBuffer();

		for(int i=0; i