北京住房和城乡建设部官方网站,湛江制作网站企业,wordpress国内工作室主题,百度中心wait是指在一个已经进入了同步锁的线程内#xff0c;让自己暂时让出同步锁#xff0c;以便其他正在等待此锁的线程可以得到同步锁并运行#xff0c;只有其他线程调用了notify方法(notify并不释放锁#xff0c;只是告诉调用过wait方法的线程可以去参与获得锁的竞争了#x…wait是指在一个已经进入了同步锁的线程内让自己暂时让出同步锁以便其他正在等待此锁的线程可以得到同步锁并运行只有其他线程调用了notify方法(notify并不释放锁只是告诉调用过wait方法的线程可以去参与获得锁的竞争了但不是马上得到锁因为锁还在别人手里别人还没释放)调用wait方法的一个或多个线程就会解除wait状态重新参与竞争对象锁程序如果可以再次得到锁就可以继续向下运行。1)wait()、notify()和notifyAll()方法是本地方法并且为final方法无法被重写。2)当前线程必须拥有此对象的monitor(即锁)才能调用某个对象的wait()方法能让当前线程阻塞(这种阻塞是通过提前释放synchronized锁重新去请求锁导致的阻塞这种请求必须有其他线程通过notify()或者notifyAll()唤醒重新竞争获得锁)3)调用某个对象的notify()方法能够唤醒一个正在等待这个对象的monitor的线程如果有多个线程都在等待这个对象的monitor则只能唤醒其中一个线程(notify()或者notifyAll()方法并不是真正释放锁必须等到synchronized方法或者语法块执行完才真正释放锁)4)调用notifyAll()方法能够唤醒所有正在等待这个对象的monitor的线程唤醒的线程获得锁的概率是随机的取决于cpu调度例子1(错误使用导致线程阻塞)三个线程线程3先拥有sum对象的锁然后通过sum.notify()方法通知等待sum锁的线程去获得锁但是这个时候线程1,2并没有处于wait()导致的阻塞状态而是在synchronized方法块处阻塞了所以这次notify()根本没有通知到线程1,2。然后线程3正常结束释放掉sum锁这个时候线程1就立刻获得了sum对象的锁(通过synchronized获得)然后调用sum.wait()方法释放掉sum的锁线程2随后获得了sum对象的线程锁(通过synchronized获得)这个时候线程1,2都处于阻塞状态但是悲催的是这之后再也没有线程主动调用sum.notify()或者notifyAll()方法显示唤醒这两个线程所以程序阻塞public class CyclicBarrierTest {public static void main(String[] args) throws Exception {final Sum sumnew Sum();new Thread(new Runnable() {Overridepublic void run() {try {synchronized (sum) {System.out.println(thread3 get lock);sum.sum();sum.notifyAll(); //此时唤醒没有作用没有线程等待Thread.sleep(2000);System.out.println(thread3 really release lock);}} catch (Exception e) {e.printStackTrace();}}}).start();new Thread(new Runnable() {Overridepublic void run() {try {synchronized (sum) {System.out.println(thread1 get lock);sum.wait();//主动释放掉sum对象锁System.out.println(sum.total);System.out.println(thread1 release lock);}} catch (Exception e) {e.printStackTrace();}}}).start();new Thread(new Runnable() {Overridepublic void run() {try {synchronized (sum) {System.out.println(thread2 get lock);sum.wait(); //释放sum的对象锁等待其他对象唤醒(其他对象释放sum锁)System.out.println(sum.total);System.out.println(thread2 release lock);}} catch (Exception e) {e.printStackTrace();}}}).start();}}class Sum{public Integer total0;public void sum() throws Exception{total100;Thread.sleep(5000);}}thread3 get lockthread3 really release lockthread2 get lockthread1 get lock//程序后面一直阻塞例子2还是上面程序顺序不同把线程3放到最下面。最后线程1,2都因为没有再次获得线程导致线程阻塞运行过程线程1先运行获得sum对象锁(通过synchronized)但是随后执行了sum.wait()方法主动释放掉了sum对象锁然后线程2获得了sum对象锁(通过synchronized),也通过sum.wait()失去sum的对象锁最后线程3获得了sum对象锁(通过synchronized)主动通过sum.notify()通知了线程1或者2假设是1线程1重新通过notify()/notifyAll()的方式获得了锁然后执行完毕随后线程释放锁然后这个时候线程2成功获得锁执行完毕。public class CyclicBarrierTest {public static void main(String[] args) throws Exception {final Sum sumnew Sum();new Thread(new Runnable() {Overridepublic void run() {try {synchronized (sum) {System.out.println(thread1 get lock);sum.wait();//主动释放sum对象锁等待唤醒System.out.println(sum.total);System.out.println(thread1 release lock);}} catch (Exception e) {e.printStackTrace();}}}).start();new Thread(new Runnable() {Overridepublic void run() {try {synchronized (sum) {System.out.println(thread2 get lock);sum.wait(); //主动释放sum对象锁等待唤醒System.out.println(sum.total);System.out.println(thread2 release lock);}} catch (Exception e) {e.printStackTrace();}}}).start();new Thread(new Runnable() {Overridepublic void run() {try {synchronized (sum) {System.out.println(thread3 get lock);sum.sum();sum.notifyAll();//唤醒其他等待线程(线程1,2)Thread.sleep(2000);System.out.println(thread3 really release lock);}} catch (Exception e) {e.printStackTrace();}}}).start();}}class Sum{public Integer total0;public void sum() throws Exception{total100;Thread.sleep(5000);}}thread1 get lockthread2 get lockthread3 get lockthread3 really release lock100thread2 release lock100thread1 release lock
