多线程之Java线程阻塞与唤醒

线程的阻塞和唤醒在多线程并发过程中是一个关键点,当线程数量达到很大的数量级时,并发可能带来很多隐蔽的问题。如何正确暂停一个线程,暂停后又如何在一个要求的时间点恢复,这些都需要仔细考虑的细节。在Java发展史上曾经使用suspend()、resume()方法对于线程进行阻塞唤醒,但随之出现很多问题,比较典型的还是死锁问题。如下代码,主要的逻辑代码是主线程启动线程mt一段时间后尝试使用suspend()让线程挂起,最后使用resume()恢复线程。但现实并不如愿,执行到suspend()时将一直卡住,你等不来“canyou get here?”的输出。

public class ThreadSuspend {

public static voidmain(String[] args) {

     Thread mt = newMyThread();

     mt.start();

     try {

          Thread.currentThread().sleep(100);

     } catch(InterruptedException e) {

          e.printStackTrace();

     }

     mt.suspend();

     System.out.println("canyou get here?");

     mt.resume();

}

 

static class MyThreadextends Thread {

     public void run() {

          while (true) {

              System.out.println("running....");

          }

     }

}

}

产生上面所述现象其实是由死锁导致,看起来一点问题都没有,线程的任务仅仅只是简单地打印字符串,问题的根源隐藏得较深,主线程启动了线程mt后,线程mt开始执行execute()方法,不断打印字符串,问题正是出现在System.out.println,由于println被声明为一个同步方法,执行时将对System类的out(PrintStream类的一个实例)单例属性加同步锁,而suspend()方法挂起线程但并不释放锁,在线程mt被挂起后主线程调用System.out.println同样需要获取System类out对象的同步锁才能打印“can you get here?”,主线程一直在等待同步锁而mt线程不释放锁,这就导致了死锁的产生。

可见suspend和resume有死锁倾向,一不小心将导致很多问题,甚至导致整个系统崩溃。也许,解决方案可以使用以对象为目标的阻塞,即利用Object类的wait()和notify()方法实现线程阻塞。针对对象的阻塞编程思维需要稍微转化下,它与面向线程阻塞思维有较大差异,如前面的suspend与resume只需在线程内直接调用就能完成挂起恢复操作,这个很好理解,而如果改用wait、notify形式则通过一个object作为信号,可以看成是一堵门,object的wait()方法是锁门的动作,notify()是开门的动作,某一线程一旦关上门后其他线程都将阻塞,直到别的线程打开门。如图2-5-8-4,一个对象object调用wait()方法则像是堵了一扇门,线程一、线程二都将阻塞,线程三调用object的notify()方法打开门(准确说是调用了notifyAll()方法,notify()仅仅能让线程一或线程二其中一条线程通过),线程一、线程二得以通过。

图2-5-8-4

使用wait和notify能规避死锁问题,但并不能完全避免,必须在编程过程中避免死锁。在使用过程中需要注意的几点是:首先,wait、notify方法是针对对象的,调用任意对象的wait()方法都将导致线程阻塞,阻塞的同时也将释放该对象的锁,相应地,调用任意对象的notify()方法则将随机解除该对象阻塞的线程,但它需要重新获取改对象的锁,直到获取成功才能往下执行;其次,wait、notify方法必须在synchronized块或方法中被调用,并且要保证同步块或方法的锁对象与调用wait、notify方法的对象是同一个,如此一来在调用wait之前当前线程就已经成功获取某对象的锁,执行wait阻塞后当前线程就将之前获取的对象锁释放。当然假如你不按照上面规定约束编写,程序一样能通过编译,但运行时将抛出IllegalMonitorStateException异常,必须在编写时保证用法正确;最后,notify是随机唤醒一条阻塞中的线程并让之获取对象锁,进而往下执行,而notifyAll则是唤醒阻塞中的所有线程,让他们去竞争该对象锁,获取到锁的那条线程才能往下执行。

通过wait、notify改造上面的例子,代码如下,改造的思想就是在MyThread中添加一个标识变量,一旦变量改变就相应地调用wait和notify阻塞唤醒线程,由于在执行wait后将释放synchronized (this)锁住的对象锁,此时System.out.println("running....");早已执行完毕,System类out对象不存在死锁问题。

publicclass ThreadWait {

     public static void main(String[] args) {

         MyThread mt = new MyThread();

         mt.start();

         try {

              Thread.currentThread().sleep(10);

         } catch (InterruptedException e) {

              e.printStackTrace();

         }

         mt.suspendThread();

         System.out.println("can you gethere?");

         try {

              Thread.currentThread().sleep(3000);

         } catch (InterruptedException e) {

              e.printStackTrace();

         }

         mt.resumeThread();

     }

}

 

classMyThread extends Thread {

     public boolean stop = false;

     public void run() {

         while (true) {

              synchronized (this) {

                   System.out.println("running....");

                   if (stop)

                       try {

                            wait();

                       } catch(InterruptedException e) {

                            e.printStackTrace();

                       }

              }

         }

     }

 

     public void suspendThread() {

         this.stop = true;

     }

 

     public void resumeThread() {

         synchronized (this) {

              this.stop = false;

              notify();

          }

     }

}

wait与notify组合的方式看起来是个不错的解决方式,但其面向的主体是对象object,阻塞的是当前线程,而唤醒的是随机的某个线程或所有线程,偏重于线程之间的通信交互。假如换个角度,面向的主体是线程的话,我就能轻而易举地对指定的线程进行阻塞唤醒,这个时候就需要LockSupport,它提供的park和unpark方法分别用于阻塞和唤醒,而且它提供避免死锁和竞态条件,很好地代替suspend和resume组合。用park和unpark改造上述例子,代码如下:

public class ThreadPark {

public static voidmain(String[] args) {

           MyThreadmt = new MyThread();

           mt.start();

           try {

                    Thread.currentThread().sleep(10);

           } catch(InterruptedException e) {

                    e.printStackTrace();

           }

           mt.park();

           System.out.println("canyou get here?");

           try {

                    Thread.currentThread().sleep(3000);

           } catch(InterruptedException e) {

                    e.printStackTrace();

           }

           mt.unPark();

}

 

static classMyThread extends Thread {

           privateboolean isPark=false;

           publicvoid run() {

                    while(true) {

                             if(isPark)

                                       LockSupport.park();

                             System.out.println("running....");

                    }

           }

    public void park(){

    isPark=true;

    }

    public void unPark(){

    isPark=false;

     LockSupport.unpark(this);

    }

}

}

把主体换成线程进行的阻塞看起来貌似比较顺眼,而且由于park与unpark方法控制的颗粒度更加细小,能准确决定线程在某个点停止,进而避免死锁的产生,例如此例中在执行System.out.println前线程就被阻塞了,于是不存在因竞争System类out对象而产生死锁,即便在执行System.out.println后线程才阻塞也不存在死锁问题,因为锁已释放。

LockSupport类为线程阻塞唤醒提供了基础,同时,在竞争条件问题上,它具有wait和notify无可比拟的优势。使用wait和notify组合时,某一线程在被另一线程notify之前必须要保证此线程已经执行到wait等待点,错过notify则可能永远都在等待,另外notify也不能保证唤醒指定的某线程。反观LockSupport,由于park与unpark引入了许可机制,许可逻辑为:①park将许可在等于0的时候阻塞,等于1的时候返回并将许可减为0;②unpark尝试唤醒线程,许可加1。根据这两个逻辑,对于同一条线程,park与unpark先后操作的顺序似乎并不影响程序正确地执行,假如先执行unpark操作,许可则为1,之后再执行park操作,此时因为许可等于1直接返回往下执行,并不执行阻塞操作。

最后,LockSupport的park与unpark组合真正解耦了线程之间的同步,不再需要另外的对象变量存储状态,并且也不需要考虑同步锁,wait与notify要保证必须有锁才能执行,而且执行notify操作释放锁后还要将当前线程扔进该对象锁的等待队列,LockSupport则完全不用考虑对象、锁、等待队列等问题。

点击订购作者书籍《Tomcat内核设计剖析》

时间: 2025-01-20 17:20:25

多线程之Java线程阻塞与唤醒的相关文章

多线程暂停和唤醒-java线程暂停和唤醒问题

问题描述 java线程暂停和唤醒问题 java线程如何暂停,暂停的时间未知.之后又可以在程序中唤醒呢? 解决方案 在数据不可用的时候,当前线程里wait:在数据可用的时候,当前线程notify 举个例子,如果一个自定义队列,有生产者线程和消费者线程: 那么,如果消费者发现队列里拿不到数据了,队列空了,那么就wait: 生产者一直在生产,如果生产了一条数据,插入队列以后,马上notifyAll,自然就把消费者唤醒了. 请举一反三. 解决方案二: java线程的暂停与唤醒测试java 线程阻塞的问题

java基本教程之java线程等待与java唤醒线程 java多线程教程_java

本章,会对线程等待/唤醒方法进行介绍.涉及到的内容包括:1. wait(), notify(), notifyAll()等方法介绍2. wait()和notify()3. wait(long timeout)和notify()4. wait() 和 notifyAll()5. 为什么notify(), wait()等函数定义在Object中,而不是Thread中 wait(), notify(), notifyAll()等方法介绍在Object.java中,定义了wait(), notify()

java多线程编程之java线程简介_java

一.线程概述 线程是程序运行的基本执行单元.当操作系统(不包括单线程的操作系统,如微软早期的DOS)在执行一个程序时,会在系统中建立一个进程,而在这个进程中,必须至少建立一个线程(这个线程被称为主线程)来作为这个程序运行的入口点.因此,在操作系统中运行的任何程序都至少有一个主线程.进程和线程是现代操作系统中两个必不可少的运行模型.在操作系统中可以有多个进程,这些进程包括系统进程(由操作系统内部建立的进程)和用户进程(由用户程序建立的进程):一个进程中可以有一个或多个线程.进程和进程之间不共享内存

java多线程之:线程对象一些api

一:wait()方法,wait(long timeout)--->锁对象调用wait()方法,让当前线程小a进入等待状态,阻塞住,并让出当先线程拥有的锁.--->直到其他线程用锁对象调用notifyAll(),notify()将小a从wait虚拟队列中将阻塞的线程唤醒.重新争锁.--->当别的线程对当前线程小a的对象调用interrupt()方法,则阻塞在wait虚拟队列的线程抛出InterruptedException异常,打算阻塞.--->wait(longtimeout)进入

java线程阻塞中断和LockSupport的常见问题

上周五和周末,工作忙里偷闲,在看java cocurrent中也顺便再温故了一下Thread.interrupt和java 5之后的LockSupport的实现.   在介绍之前,先抛几个问题.   Thread.interrupt()方法和InterruptedException异常的关系?是由interrupt触发产生了InterruptedException异常? Thread.interrupt()会中断线程什么状态的工作? RUNNING or BLOCKING? 一般Thread编程

java线程阻塞中断与LockSupport使用介绍_java

上周五和周末,工作忙里偷闲,在看java cocurrent中也顺便再温故了一下Thread.interrupt和java 5之后的LockSupport的实现. 在介绍之前,先抛几个问题. Thread.interrupt()方法和InterruptedException异常的关系?是由interrupt触发产生了InterruptedException异常? Thread.interrupt()会中断线程什么状态的工作? RUNNING or BLOCKING? 一般Thread编程需要关注

java多线程之:创建开启一个线程的开销

---->关于时间,创建线程使用是直接向系统申请资源的,这里调用系统函数进行分配资源的话耗时不好说.---->关于资源,Java线程的线程栈所占用的内存是在Java堆外的,所以是不受java程序控制的,只受系统资源限制,默认一个线程的线程栈大小是1M(当让这个可以通过设置-Xss属性设置,但是要注意栈溢出问题),但是,如果每个用户请求都新建线程的话,1024个用户光线程就占用了1个G的内存,如果系统比较大的话,一下子系统资源就不够用了,最后程序就崩溃了.--->对操作系统来说,创建一个线

java多线程之:深入JVM锁机制2-Lock (转载)

前文(深入JVM锁机制-synchronized)分析了JVM中的synchronized实现,本文继续分析JVM中的另一种锁Lock的实现.与synchronized不同的是,Lock完全用Java写成,在java这个层面是无关JVM实现的. 在 java.util.concurrent.locks包中有很多Lock的实现类,常用的有ReentrantLock. ReadWriteLock(实现类ReentrantReadWriteLock),其实现都依赖 java.util.concurre

Java多线程:“基础篇”05之线程等待与唤醒

wait(), notify(), notifyAll()等方法介绍 在Object.java中,定义了wait(), notify()和notifyAll()等接口.wait()的作用是让当前线程进入 等待状态,同时,wait()也会让当前线程释放它所持有的锁.而notify()和notifyAll()的作用,则是唤 醒当前对象上的等待线程:notify()是唤醒单个线程,而notifyAll()是唤醒所有的线程. Object类中关于等待/唤醒的API详细信息如下: notify()