第1章:并发编程线程基础

wait()

如果调用wait()方法的线程没有实现获取该对象的监视器锁,则调用wait()方法时线程会抛出IllegalMonitorStateException异常。

一个线程获取一个共享变量的监视器锁的方法

  • 执行synchronized同步代码块时,使用该共享变量作为参数:
    1. synchronized(共享变量) {
    2. //do something
    3. }
  • 调用该共享变量的方法,并且该方法使用了synchronized修饰:
    1. synchronized void add(int a, int b) {
    2. //do something
    3. }

注意:一个线程可以挂起状态变成运行状态(也就是被唤醒),即使该线程没有被其他线程调用notify()、notifyAll()方法进行通知,或者被中断,或者等待超时,这就是所谓的虚假唤醒

虚假唤醒在实践中很少发生,但要防患于未然,如下:

  1. synchronized(obj) {
  2. while(条件不满足) {
  3. obj.wait();
  4. }
  5. }

notify()和notifyAll()

notify()会唤醒被阻塞到该共享变量上的一个线程,notifyAll()会唤醒所有在该共享变量上由于调用wait系列方法而被挂起的线程。

join()

  1. ...
  2. public static void main(String[] args){
  3. ...
  4. thread1.join();
  5. thread2.join();
  6. System.out.println("all child thread over!");
  7. }

主线程首先会在调用thread1.join()后被阻塞,等待thread1执行完毕后,thread2开始阻塞,以此类推,最终会等所有子线程都结束后main函数才会返回。

sleep()

sleep()会使线程暂时让出指定时间的执行权,也就是在这期间不参与CPU的调度,但不会释放锁。

yield()

线程调用yield()方法时,实际上是暗示线程调度器当前线程请求让出自己的CPU使用(告诉线程调度器可以进行下一轮的线程调度),但线程调度器可以无条件忽略这个暗示。

线程中断

void interrupt()

设置线程的中断标志为true并立即返回,但线程实际上并没有被中断而会继续向下执行;如果线程因为调用了wait系列函数、join方法或者sleep方法而被阻塞挂起,其他线程调用该线程的interrupt()方法会使该线程抛出InterruptedException异常而返回。

boolean isInterrupted()

检测当前线程是否被中断,是则返回true,否则返回false。

boolean interrupted()

检测当前线程是否被中断,返回值同上,但如果发现当前线程被中断,会清除中断标志;该方法是static方法,内部是获取当前调用线程的中断标志而不是调用interrupted()方法的实例对象的中断标志。

示例

  1. public static void main(String[] args){
  2. Thread threadOne = new Thread(new Runnable(){
  3. @Override
  4. public void run() {
  5. for(;;) {
  6. }
  7. }
  8. });
  9. //启动线程
  10. threadOne.start();
  11. //设置中断标志
  12. threadOne.interrupt();
  13. //获取中断标志
  14. System.out.println("isInterrupted:" + threadOne.isInterrupted() );
  15. //获取中断标志并重置
  16. System.out.println("isInterrupted:" + threadOne.interrupted() );
  17. //获取中断标志并重置
  18. System.out.println("isInterrupted:" + Thread.interrupted() );
  19. //获取中断标志
  20. System.out.println("isInterrupted:" + threadOne.isInterrupted() );
  21. try{
  22. threadOne.join();
  23. }catch(InterruptedException e) {
  24. System.out.println("interrupted!!!");
  25. }
  26. System.out.println("main thread is over");
  27. }

输出为

  1. isInterrupted:true
  2. isInterrupted:false
  3. isInterrupted:false
  4. isInterrupted:true

解析 threadOne.interrupted()一句,由于interrupted()为static方法,相当于执行Thread.interrupted()。

守护进程与用户进程

当最后一个用户进程结束时,JVM会正常退出,而不管当前是否有守护进程。

示例

  1. public static void main(String[] args){
  2. Thread t = new Thread(new Runnable(){
  3. @Override
  4. public void run() {
  5. for(;;) {}
  6. }
  7. });
  8. // t.setDaemon(true);
  9. t.start();
  10. System.out.println("main is over");
  11. }

运行后发现虽然输出了”main is over”,但ide运行状态红框仍亮着,说明JVM进程未结束,如图:

image01

打开注释后程序则快速退出。

更多

相关笔记:《Java并发编程之美》阅读笔记