java wait()和notify()
(2012-07-28 10:16:02)
最近在学习同步的时候用到了这两个方法,开始在学习线程的时候没有注意到wait()和notify方法。原因是这两个方法不属于Thread类,它们是在lang包下面的Object类,是最底层的基础类。因此每个类的对象都可以操作这两个方法。而这两个方法的用途就是操作锁,所以它们只能在synchronized方法或者synchronized块中使用。说道wait()方法,就不得不提到Thread类中的一个静态的方法sleep(),两者间最大的区别在于:sleep()方法在睡眠的时候也一直拿着锁不放开,因此其他的线程也得不到这把锁。而wait()方法在睡眠的时候会放开锁,给其他的线程使用。wait()有两种方式获得锁:1.wait(long
timeout),通过设定时间来获得锁,值得注意的是,timeout这个时间到了以后,它不会立即醒来,而是要看那个正在使用这把锁的线程是否结束。2.通过notify()的方法,通知需要这把锁的wait(),使之唤醒,而notifyAll()是通知所有的线程。
下面用一个实例说明:
public class Demo
{
public static void main(String[] args)
{
ThreadDemo b=new
ThreadDemo();
b.start();
System.out.println("b is
start....");
synchronized(b)
{
try
{
System.out.println("Waiting
for b to complete...");
// b.wait(3000);
b.wait();
System.out.println("Completed.Now
back to main thread");
}catch
(InterruptedException e){}
}
System.out.println("Total
is :"+b.total);
}
}
class ThreadDemo extends Thread
{
int total;
public void run()
{
try {
Thread.sleep(2000);
synchronized(this)
{
System.out.println("ThreadB
is running..");
for
(int i=0;i<100;i++ )
{
total
+=i;
//
if(i==30){Thread.sleep(3000);} //当 i=30的时候,让当前线程睡眠3秒
System.out.println("total
is "+total);
}
this.notify();
}
} catch (InterruptedException
e1) {
e1.printStackTrace();
}
}
}
分析:ThreadDemo类继承Thread,在run()方法里使用了synchronized块给ThreadDemo对象上锁,并在synchronized块中调用notify()方法,在主函数里也使用了synchronized块给ThreadDemo对象上锁,并使用wait()方法。注意这里上锁都是ThreadDemo对象。
程序运行:运行main方法时产生一个主线程,通过ThreadDemo对象启动其线程,在运行到run()方法的时候产生一个子线程,这时候就有两个线程,为了更好的看到效果,在run()方法里用Thread.sleep(2000);让当前线程睡眠2秒,这时还没有给ThreadDe对象上锁。而主线程接着往下面执行,进入到同步块,直到b.wait();的时候,这时主线程进入睡眠,同时释放了锁(ThreadDe对象)。因此两秒钟以后,子线程就可以获得锁,继续执行,执行到this.notify()时,就会通知主线程中的wait(),让主线程继续执行。
使用b.wait(3000);同样为了效果,在ThreadDemo类中的run()方法的循环语句中加入if(i==30){Thread.sleep(4000);}
。执行程序的时候你会发现,不管是否过了3秒钟,只要子线程已经执行到同步块的时候,主线程必须等,直到子线程执行结束,释放了锁,才能继续执行。
喜欢
0
赠金笔
加载中,请稍候......