JAVA线程间协作:wait.notify.notifyAll

    JAVA的进程同步是通过synchronized()来实现的,需要说明的是,JAVA的synchronized()方法类似于操作系统概念中的互斥内存块,在JAVA中的Object类型中,都是带有一个内存锁的,在有线程获取该内存锁后,其它线程无法访问该内存,从而实现JAVA中简单的同步、互斥操作。明白这个原理,就能理解为什么synchronized(this)与synchronized(static XXX)的区别了,synchronized就是针对内存区块申请内存锁,this关键字代表类的一个对象,所以其内存锁是针对相同对象的互斥操作,而static成员属于类专有,其内存空间为该类所有成员共有,这就导致synchronized()对static成员加锁,相当于对类加锁,也就是在该类的所有成员间实现互斥,在同一时间只有一个线程可访问该类的实例。如果只是简单的想要实现在JAVA中的线程互斥,明白这些基本就已经够了。但是如果需要在线程间进行协作通信,就需要借助Object对象的wait,notify和notifyAll方法了。
    在Java中,可以通过配合调用Object对象的wait方法和notify方法或notifyAll方法来实现线程间的协作通信。在线程中调用wait方法,将阻塞等待其他线程的通知(其他线程调用notify方法或notifyAll方法),在线程中调用notify方法或notifyAll方法,将通知其他线程从wait方法处返回。 

    Object.wait()与Object.notify()必须要与同步块或同步方法(synchronized块或者synchronized方法)一起使用,也就是wait与notify是针对已经获取了Object锁进行操作,从语法角度来说就是Object.wait(),Object.notify必须在同步块或同步方法内。从功能上来说wait就是说线程在获取对象锁后,主动释放对象锁,同时本线程休眠。直到有其它线程调用对象的notify()唤醒该线程,才能继续获取对象锁,并继续执行。相应的notify()就是对对象锁的唤醒操作。但有一点需要注意的是notify()调用后,并不是马上就释放对象锁的,而是在相应的同步块或同步方法中执行结束,自动释放锁后,JVM会在wait()对象锁的线程中随机选取一线程,赋予其对象锁,唤醒线程,继续执行。这样就提供了在线程间同步、唤醒的操作。Thread.sleep()与Object.wait()二者都可以暂停当前线程,释放CPU控制权,主要的区别在于Object.wait()在释放CPU同时,释放了对象锁的控制。

    wait方法

    调用线程的sleep,yield方法时,线程并不会让出对象锁,wait却不同。

    wait函数必须在同步代码块中调用(也就是当前线程必须持有对象的锁),他的功能是这样的:

        我累了,休息一会儿,对象的锁你们拿去用吧,CPU也给你们。

    调用了wait函数的线程会一直等待,直到有其他线程调用了同一个对象的notify或者notifyAll方法才能被唤醒,需要注意的是:被唤醒并不代表立即获得对象的锁。也就是说,一个线程调用了对象的wait方法后,他需要等待两件事情的发生:

    1. 有其他线程调用同一个对象的notify或者notifyAll方法(调用notify/notifyAll方法之前)

    2. 被唤醒之后重新获得对象的锁(调用notify/notifyAll方法之后)才能继续往下执行后续动作。

    如果一个线程调用了某个对象的wait方法,但是后续并没有其他线程调用该对象的notify或者notifyAll方法,则该线程将会永远等下去…

    notify和notifyAll方法

    notify/notifyAll方法也必须在同步代码块中调用(也就是调用线程必须持有对象的锁),他们的功能是这样的:

        女士们,先生们请注意,锁的对象我即将用完,请大家醒醒,准备一下,马上你们就能使用锁了。

    不同的是,notify方法只会唤醒一个正在等待的线程(至于唤醒谁,不确定!),而notifyAll方法会唤醒所有正在等待的线程。还有一点需要特别强调:调用notify和notifyAll方法后,当前线程并不会立即放弃锁的持有权,而必须要等待当前同步代码块执行完才会让出锁。

    如果一个对象之前没有调用wait方法,那么调用notify方法是没有任何影响的。

    下面来看一个例子:

package com.cooperation;

import java.util.concurrent.TimeUnit;

public class Test
{
    public static Object object = new Object();

    static class Thread1 implements Runnable
    {
        @Override
        public void run()
        {
            synchronized(object)
            {
                System.out.println(Thread.currentThread().getName()+" is running.");
                try
                {
                    object.wait();
                }
                catch (InterruptedException e)
                {
                    e.printStackTrace();
                }
                System.out.println(Thread.currentThread().getName()+" get the lock.");
            }
        }
    }

    static class Thread2 implements Runnable
    {
        @Override
        public void run()
        {
            synchronized(object)
            {
                System.out.println(Thread.currentThread().getName()+" is running.");
                object.notify();
                System.out.println(Thread.currentThread().getName()+" invoke notify()");
                System.out.println(Thread.currentThread().getName()+" release the lock.");
            }
        }
    }

    public static void main(String[] args) throws InterruptedException
    {
        Thread thread1 = new Thread(new Thread1());
        Thread thread2 = new Thread(new Thread2());
        thread1.start();
        TimeUnit.SECONDS.sleep(1);
        thread2.start();
    }
}

    运行结果(运行多次,结果相同):

Thread-0 is running.
Thread-1 is running.
Thread-1 invoke notify()
Thread-1 release the lock.
Thread-0 get the lock.

   可以看到当Thread-0调用了wait方法后就释放了object锁,Thread-1获取锁之后调用notify的释放锁,但是这个时候Thread没有立刻获取object锁,而是等到了Thread-1的同步块退出之后才获取了object的锁。

    如果将class Thread2中的 System.out.println(Thread.currentThread().getName()+" release the lock.");这句放在synchronized(object)的外面,有可能出现如下的运行结果:

Thread-0 is running.
Thread-1 is running.
Thread-1 invoke notify()
Thread-0 get the lock.
Thread-1 release the lock.

    这是因为,当Thread-1释放了object锁并且退出了同步块之后Thread-0立刻获取了锁,而这时候两个线程的打印语句的顺序就随机了。

    在JDK1.4之后出现了一个Condition类,这个类也能够实现相同的功能,并且一般建议使用Condition替代wait,notify,notifyAll家族,实现更安全的线程间协作通信功能,比如ArrayBlockingQueue就是使用Condition实现阻塞队列的。这个我在以后的博客中会涉及到。
    如果有什么意见或者建议请在下方留言。

时间: 2024-10-27 15:48:40

JAVA线程间协作:wait.notify.notifyAll的相关文章

JAVA线程间协作:Condition

    内置条件队列存在一些缺陷.每个内置锁都只能有一个相关联的条件队列,因而在像BounderBuffer这种类中,多个线程可能在同一个条件队列上等待不同的条件谓词,并且在最常见的加锁模式下公开条件队列对象.这些因素都使得无法满足在使用notifyAll时所有等待线程为统一类型的需求.如果想编写一个带有多个条件谓词的并发对象,或者想获得除了条件队列可见性之外的更多控制权,就可以使用显示的Lock和Condition而不是内置锁和条件队列,这是一种更灵活的选择.     一个Condition和

线程间协作的两种方式:wait、notify、notifyAll和Condition

在前面我们将了很多关于同步的问题,然而在现实中,需要线程之间的协作.比如说最经典的生产者-消费者模型:当队列满时,生产者需要等待队列有空间才能继续往里面放入商品,而在等待的期间内,生产者必须释放对临界资源(即队列)的占用权.因为生产者如果不释放对临界资源的占用权,那么消费者就无法消费队列中的商品,就不会让队列有空间,那么生产者就会一直无限等待下去.因此,一般情况下,当队列满时,会让生产者交出对临界资源的占用权,并进入挂起状态.然后等待消费者消费了商品,然后消费者通知生产者队列有空间了.同样地,当

java-并发-线程间协作的两种方式:wait、notify、notifyAll和Condition

线程之间的协作.比如说最经典的生产者-消费者模型:当队列满时,生产者需要等待队列有空间才能继续往里面放入商品,而在等待的期间内,生产者必须释放对临界资源(即队列)的占用权.因为生产者如果不释放对临界资源的占用权,那么消费者就无法消费队列中的商品,就不会让队列有空间,那么生产者就会一直无限等待下去.因此,一般情况下,当队列满时,会让生产者交出对临界资源的占用权,并进入挂起状态.然后等待消费者消费了商品,然后消费者通知生产者队列有空间了.同样地,当队列空时,消费者也必须等待,等待生产者通知它队列中有

java线程间通信

线程通信的目标是使线程间能够互相发送信号.另一方面,线程通信使线程能够等待其他线程的信号. 例如,线程B可以等待线程A的一个信号,这个信号会通知线程B数据已经准备好了.本文将讲解以下几个JAVA线程间通信的主题: 1.通过共享对象通信 2.忙等待 3.wait(),notify()和notifyAll() 4.丢失的信号 5.假唤醒 6.多线程等待相同信号 7.不要对常量字符串或全局对象调用wait() 1.通过共享对象通信 线程间发送信号的一个简单方式是在共享对象的变量里设置信号值.线程A在一

Java线程间的通信方式详解_java

本总结我对于JAVA多线程中线程之间的通信方式的理解,主要以代码结合文字的方式来讨论线程间的通信,故摘抄了书中的一些示例代码,具体内容如下 ①同步 这里讲的同步是指多个线程通过synchronized关键字这种方式来实现线程间的通信. 参考示例: public class MyObject { synchronized public void methodA() { //do something.... } synchronized public void methodB() { //do so

Java线程间通讯概述

这个故事源自一个很简单的想法:创建一个对开发人员友好的.简单轻量的线程间通讯框架,完全不 用锁.同步器.信号量.等待和通知,在Java里开发一个轻量.无锁的线程内通讯框架:并且也没有队列 .消息.事件或任何其他并发专用的术语或工具. 只用普通的老式Java接口实现POJO的通讯. 它可能跟Akka的类型化actor类似,但作为一个必须超级轻量,并且要针对单台多核计算机进行优化的 新框架,那个可能有点过了. 当actor跨越不同JVM实例(在同一台机器上,或分布在网络上的不同机器上)的进程边界时,

Java中使用wait()与notify()实现线程间协作

使用wait()与notify()/notifyAll()可以使得多个任务之间彼 此协作. 1. wait()与notify()/notifyAll() 调用sleep()和yield()的时候锁并没有被释放,而调用wait() 将释放锁.这样另一个任务(线程)可以获得当前对象的锁,从而 进入它的synchronized方法中.可以通过notify()/notifyAll(), 或者时间到期,从wait()中恢复执行. 只能在同步控制方法或同步块中调用wait().notify()和 notif

Java多线程之线程间协作 notify与wait的使用

(转载请注明出处:http://blog.csdn.net/buptgshengod) 1.背景        Java多线程操作运用很广,特别是在android程序方面.线程异步协作是多线程操作的难点也是关键,也是找工作面试经常考到的地方.下面分享一下我的使用心得. 介绍几个关键字: synchronized:线程锁,使得系统只执行当前线程. notifyAll():唤醒其它被锁住的线程 wait():挂起线程 ExecutorService exec=Executors.newCachedT

Java并发——线程间协作(wait、notify、sleep、yield、join)

1 线程的状态 Java中线程中状态可分为五种:New(新建状态),Runnable(就绪状态),Running(运行状态),Blocked(阻塞状态),Dead(死亡状态). New:新建状态,当线程创建完成时为新建状态,即new Thread(...),还没有调用start方法时,线程处于新建状态 Runnable:就绪状态,当调用线程的的start方法后,线程进入就绪状态,等待CPU资源.处于就绪状态的线程由Java运行时系统的线程调度程序(*thread scheduler*)来调度 R