知识大全 java多线程notify和wait

Posted 知

篇首语：丈夫欲遂平生志，一载寒窗一举汤。本文由小常识网(cha138.com)小编为大家整理，主要介绍了知识大全 java多线程notify和wait相关的知识，希望对你有一定的参考价值。

java多线程之 wait（） notify（） notifyAll（）　　　　wait（） notify（） notifyAll（）不属于Thread类 而是属于Object基础类 也就是说每个对像都有 wait（） notify（） notifyAll（）的功能 因为都个对像都有锁 锁是每个对像的基础 当然操作锁的方法也是最基础了 　　　　先看java doc怎么说 　　　　wait导致当前的线程等待 使当前线程进入阻塞状态（对象等待队列） 直到其他线程调用此对象的 notify（） 方法或 notifyAll（） 方法 当前的线程必须拥有此对象锁 该线程发布对此对象锁的所有权并等待 直到其他线程通过调用 notify 方法 或 notifyAll 方法通知在此对象的锁上等待的线程醒来 然后该线程将等到重新获得对对象锁的所有权后才能在wait阻塞处开始继续执行 　　　　例子如下　　　　import java util ArrayList;　　　　import java util List;　　　　class Consume implements Runnable 　　　　private List container = null;　　　　private int count;　　　　public Consume（List lst） 　　　　ntainer = lst;　　　　　　　　public void run（） 　　　　while（true）　　　　synchronized （container） 　　　　if （container size（）== ） 　　　　try 　　　　System out println（ ++++++++++++++wait之前 ） 　　　　container wait（） // 放弃锁　　　　System out println（ ++++++++++++++wait之后 ） 　　　　 catch （InterruptedException e） 　　　　e printStackTrace（） 　　　　　　　　　　　　try 　　　　Thread sleep（ ） 　　　　 catch （InterruptedException e） 　　　　// TODO Auto generated catch block　　　　e printStackTrace（） 　　　　　　　　container remove（ ） 　　　　container notify（） 　　　　System out println（ 我吃了 + container size（）  + 个 ） 　　　　　　　　　　　　　　　　　　　　class Product implements Runnable 　　　　private List container = null;　　　　private int count;　　　　public Product（List lst） 　　　　ntainer = lst;　　　　　　　　public void run（） 　　　　while（true） 　　　　synchronized （container） 　　　　if （container size（）>= MultiThread MAX） 　　　　try 　　　　container wait（） 　　　　 catch （InterruptedException e） 　　　　e printStackTrace（） 　　　　　　　　　　　　try 　　　　Thread sleep（ ） 　　　　 catch （InterruptedException e） 　　　　e printStackTrace（） 　　　　　　　　container add（new Object（）） 　　　　container notify（） 　　　　System out println（ 我生产了 +container size（） + 个 ） 　　　　　　　　　　　　　　　　　　　　public class MultiThread 　　　　private List container = new ArrayList（） 　　　　public final static int MAX = ;　　　　public static void main（String args[]） 　　　　MultiThread m = new MultiThread（） 　　　　new Thread（new Consume（m getContainer（））） start（） 　　　　new Thread（new Product（m getContainer（））） start（） 　　　　// new Thread（new Consume（m getContainer（））） start（） 　　　　// new Thread（new Product（m getContainer（））） start（） 　　　　　　　　public List getContainer（） 　　　　return container;　　　　　　　　public void setContainer（List container） 　　　　ntainer = container;　　　　　　　　　　　　++++++++++++++wait之前  //进入消费者线程 同时wait 当前线程为阻塞状态　　　　我生产了 个                 //进入生产者线程 同时notify 告知消费者 退出阻塞状态　　　　//退出同步块之后 生产者和消费者竞争处理器　　　　我生产了 个                 // 生产者再次获得处理器 同时notify 此时已经没有线程//在contain上等待 则notify不起作用 　　　　++++++++++++++wait之后  // 再次竞争 消费者获得处理器 从wait阻塞的地方开始继续//执行　　　　我吃了 个　　　　我吃了 个　　　　++++++++++++++wait之前　　　　我生产了 个　　　　++++++++++++++wait之后　　　　我吃了 个　　　　++++++++++++++wait之前　　　　我生产了 个　　　　我生产了 个　　　　我生产了 个　　　　++++++++++++++wait之后　　　　我吃了 个　　　　我吃了 个　　　　我生产了 个　　　　我生产了 个　　　　我吃了 个　　　　我吃了 个　　　　我吃了 个　　　　我生产了 个　　　　我吃了 个　　　　我生产了 个　　　　我生产了 个　　　　我吃了 个　　　　我吃了 个　　　　++++++++++++++wait之前　　　　我生产了 个　　　　我生产了 个　　　　++++++++++++++wait之后　　　　我吃了 个　　　　我生产了 个　　　　我生产了 个　　　　我吃了 个　　　　我生产了 个　　　　我生产了 个　　　　我吃了 个　　　　我吃了 个　　　　我生产了 个　　　　我生产了 个　　　　我吃了 个　　　　我生产了 个　　　　我生产了 个　　　　我吃了 个　　　　我吃了 个　　　　我生产了 个　　　　我生产了 个　　　　我吃了 个　　　　我吃了 个　　　　我吃了 个　　　　我生产了 个　　　　我吃了 个　　　　我吃了 个　　　　我生产了 个　　　　我吃了 个　　　　我吃了 个　　　　我生产了 个　　　　我吃了 个　　　　++++++++++++++wait之前　　　　我生产了 个　　　　我生产了 个　　　　++++++++++++++wait之后　　　　我吃了 个　　　　我吃了 个　　　　我生产了 个　　　　我吃了 个　　　　++++++++++++++wait之前　　　　我生产了 个　　　　……　　　　可能的一种输出结果如上所示 　　　　++++++++++++++wait之前　　　　我生产了 个　　　　我生产了 个　　　　++++++++++++++wait之后　　　　我吃了 个　　　　我吃了 个　　　　++++++++++++++wait之前　　　　我生产了 个　　　　++++++++++++++wait之后　　　　notify唤醒在此对象等待队列上等待的单个线程 使线程进入锁标记等待队列 此时锁标记等待队列重新进行锁的竞争 获得锁的线程运行同步块 如果所有线程都在此对象上等待 则会选择唤醒其中一个线程 直到当前的线程放弃此对象上的锁定 才能继续执行被唤醒的线程 此方法只应由作为此对象锁的所有者的线程来调用 　　　　 当前的线程必须拥有此对象锁 与 此方法只应由作为此对象锁的所有者的线程来调用 说明wait方法与notify方法必须在同步块内 执行 即synchronized（obj之内） 　　　　调用对像wait方法后 当前线程释放对像锁 进入对象等待队列 直到其他线程（也只能是其他线程）通过notify 方法 或 notifyAll 该线程重新进入锁标记等待队列 接下来进行锁的竞争 若获得锁的所有权 则继续执行 　　　　记得线程必须重新获得对像锁才能继续执行 因为synchronized代码块内没有锁是寸步不能走的 看一个很经典的例子 　　　　Code　　　　package ProductAndConsume;　　　　import java util List;　　　　public class Consume implements Runnable　　　　private List container = null;　　　　private int count;　　　　public Consume（List lst）　　　　ntainer = lst;　　　　　　　　public void run（） 　　　　while（true）　　　　synchronized （container） 　　　　if（container size（）== ）　　　　try 　　　　container wait（） //放弃锁　　　　 catch （InterruptedException e） 　　　　e printStackTrace（） 　　　　　　　　　　　　try 　　　　Thread sleep（ ） 　　　　 catch （InterruptedException e） 　　　　// TODO Auto generated catch block　　　　e printStackTrace（） 　　　　　　　　container remove（ ） 　　　　container notify（） 　　　　System out println（ 我吃了 +（++count）+ 个 ） 　　　　　　　　　　　　　　　　　　　　package ProductAndConsume;　　　　import java util List;　　　　public class Product implements Runnable 　　　　private List container = null;　　　　private int count;　　　　public Product（List lst） 　　　　ntainer = lst;　　　　　　　　public void run（） 　　　　while （true） 　　　　synchronized （container） 　　　　if （container size（） > MultiThread MAX） 　　　　try 　　　　container wait（） 　　　　 catch （InterruptedException e） 　　　　e printStackTrace（） 　　　　　　　　　　　　try 　　　　Thread sleep（ ） 　　　　 catch （InterruptedException e） 　　　　e printStackTrace（） 　　　　　　　　container add（new Object（）） 　　　　container notify（） 　　　　System out println（ 我生产了 +（++count）+ 个 ） 　　　　　　　　　　　　　　　　　　　　package ProductAndConsume;　　　　import java util ArrayList;　　　　import java util List;　　　　public class MultiThread 　　　　private List container = new ArrayList（） 　　　　public final static int MAX = ;　　　　public static void main（String args[]）　　　　MultiThread m = new MultiThread（） 　　　　new Thread（new Consume（m getContainer（））） start（） 　　　　new Thread（new Product（m getContainer（））） start（） 　　　　new Thread（new Consume（m getContainer（））） start（） 　　　　new Thread（new Product（m getContainer（））） start（） 　　　　　　　　public List getContainer（） 　　　　return container;　　　　　　　　public void setContainer（List container） 　　　　ntainer = container;　　　　　　　　 run（）和start（）　　　　这两个方法应该都比较熟悉 把需要并行处理的代码放在run（）方法中 start（）方法启动线程将自动调用 run（）方法 这是由Java的内存机制规定的 并且run（）方法必须是public访问权限 返回值类型为void 　　　　二 关键字Synchronized　　　　这个关键字用于保护共享数据 当然前提是要分清哪些数据是共享数据 每个对象都有一个锁标志 当一个线程访问该对象时 被 Synchronized 修饰的数据将被 上锁 阻止其他线程访问 当前线程访问完这部分数据后释放锁标志 其他线程就可以访问了 　　　　以下是引用片段 　　　　public ThreadTest implements Runnable　　　　　　　　public synchronized void run（）　　　　for（int i= ;i< ;i++）　　　　　　　　System out println（ + i） 　　　　　　　　　　　　public static void main（String[] args）　　　　　　　　Runnable r = new ThreadTest（） 　　　　Runnable r = new ThreadTest（） 　　　　Thread t = new Thread（r ） 　　　　Thread t = new Thread（r ） 　　　　t start（） 　　　　t start（） 　　　　　　　　　　　　以上这段程序中的 i 变量并不是共享数据 也就是这里的Synchronized关键字并未起作用 因为t t 两个线程是两个对象（r r ）的线程 不同的对象其数据 是不同的 所以r 和r 两个对象的i变量是并不是共享数据 　　　　当把代码改成如下 Synchronized关键字才会起作用　　　　以下是引用片段 　　　　Runnable r = new ThreadTest（） 　　　　Thread t = new Thread（r） 　　　　Thread t = new Thread（r） 　　　　t start（） 　　　　t start（） 　　　　三 sleep（）　　　　使当前线程（即调用该方法的线程）暂停执行一段时间 让其他线程有机会继续执行 但它并不释放对象锁 也就是如果有Synchronized同步 块 其他线程仍然不同访问共享数据 注意该方法要捕获异常　　　　比如有两个线程同时执行（没有Synchronized） 一个线程优先级为MAX_PRIORITY 另一个为MIN_PRIORITY 如果 没有Sleep（）方法 只有高优先级的线程执行完成后 低优先级的线程才能执行 但当高优先级的线程sleep（ ）后 低优先级就有机会执行 了 　　　　总之 sleep（）可以使低优先级的线程得到执行的机会 当然也可以让同优先级 高优先级的线程有执行的机会 　　　　四 join（）　　　　join（）方法使调用该方法的线程在此之前执行完毕 也就是等待调用该方法的线程执行完毕后再往下继续执行 注意该方法也要捕获异常 　　　　五 yield（）　　　　它与sleep（）类似 只是不能由用户指定暂停多长时间 并且yield（）方法只能让同优先级的线程有执行的机会 　　　　六 wait（）和notify（） notifyAll（）　　　　这三个方法用于协调多个线程对共享数据的存取 所以必须在Synchronized语句块内使用这三个方法 前面说过Synchronized 这个关键字用于保护共享数据 阻止其他线程对共享数据的存取 但是这样程序的流程就很不灵活了 如何才能在当前线程还没退出Synchronized数据 块时让其他线程也有机会访问共享数据呢？此时就用这三个方法来灵活控制 　　　　wait（）方法使当前线程暂停执行并释放对象锁标志 让其他线程可以进入 Synchronized数据块 当前线程被放入对象等待池中 当调用 notify（）方法后 将从对象的等待池中移走一个任意的线程并放到锁标志等待池中 只有　　　　锁标志等待池中的线程能够获取锁标志 如果锁标志等待池中没有线程 则notify（）不起作用 　　　　notifyAll（）则从对象等待池中移走所有等待那个对象的线程并放到锁标志等待池中 cha138/Article/program/Java/gj/201311/27303

相关参考

知识大全 线程等待和释放的小麻烦(wait/notify)

　　对于初学者来说下面这个例子是一个非常常见的错误　　/**　　* 线程A循环次后等待并放弃锁让线程B执行　　*/　　classThreadAextendsThread　　//线程同步的公共

知识大全 Java编程语言中notify和wait的具体应用

Java编程语言中notify和wait的具体应用  以下文字资料是由(全榜网网www.cha138.com)小编为大家搜集整理后发布的内容，让我们赶快一起来看一下吧！J

知识大全 Java多线程notify¬ifyall的区别

Java多线程notify¬ifyall的区别  以下文字资料是由(全榜网网www.cha138.com)小编为大家搜集整理后发布的内容，让我们赶快一起来看一下吧！

知识大全 Java多线程中wait语句的具体使用方法

Java多线程中wait语句的具体使用方法  以下文字资料是由(全榜网网www.cha138.com)小编为大家搜集整理后发布的内容，让我们赶快一起来看一下吧！　　Jav

知识大全 Java多线程编程基础之线程和多线程

Java多线程编程基础之线程和多线程  以下文字资料是由(全榜网网www.cha138.com)小编为大家搜集整理后发布的内容，让我们赶快一起来看一下吧！　　随着计算机技

知识大全 高级应用 java多线程设计模式详解之一

　　线程的创建和启动　　　　java语言已经内置了多线程支持所有实现Runnable接口的类都可被启动一个新线程新线程会执行该实例的run()方法当run()方法执行完毕后线程就结束了一旦一个线程执行

知识大全 Java多线程中run和start的区别

Java多线程中run和start的区别  以下文字资料是由(全榜网网www.cha138.com)小编为大家搜集整理后发布的内容，让我们赶快一起来看一下吧！　　区别调用

知识大全 Java的多线程-实现多线程及线程的同步

Java的多线程-实现多线程及线程的同步  以下文字资料是由(全榜网网www.cha138.com)小编为大家搜集整理后发布的内容，让我们赶快一起来看一下吧！　　一．实现

知识大全 Java多线程如何创建多个线程

Java多线程如何创建多个线程  以下文字资料是由(全榜网网www.cha138.com)小编为大家搜集整理后发布的内容，让我们赶快一起来看一下吧！　　Java多线程的同

知识大全 超线程多核心下Java多线程编程分析

超线程多核心下Java多线程编程分析  以下文字资料是由(全榜网网www.cha138.com)小编为大家搜集整理后发布的内容，让我们赶快一起来看一下吧！　　一Java环