java多线程核心技术梳理(附源码)

java多线程核心技术梳理(附源码)

标签： java

---

[TOC]

---

本文对多线程基础知识进行梳理，主要包括多线程的基本使用，对象及变量的并发访问，线程间通讯，lock的使用，定时器，单例模式，以及线程状态与线程组。

写在前面

花了一周时间阅读《java多线程编程核心技术》(高洪岩 著)，本文算是此书的整理概括，书中几乎全部示例，我都亲手敲了一遍，并上传到了个人github上，有兴趣的朋友能够到个人github下载。源码采用maven构建，多线程这部分源码位于java-multithread模块中。

• 仓库地址：java-learning
• git clone： git@github.com:brianway/java-learning.git

java多线程

基础知识

• 建立线程的两种方式：1.继承Thread类，2.实现Runnable接口。具体二者的联系能够参阅我以前的博文《java基础巩固笔记(5)-多线程之传统多线程》
• 一些基本API：isAlive(),sleep(),getId(),yield()等。
  • isAlive()测试线程是否处于活动状态
  • sleep()让“正在执行的线程”休眠
  • getId()取得线程惟一标识
  • yield()放弃当前的CPU资源
• 弃用的API:stop(),suspend(),resume()等，已经弃用了，由于可能产生数据不一样步等问题。
• 中止线程的几种方式：
  • 使用退出标识，使线程正常退出，即run方法完成。
  • 使用interrupt方法中断线程
• 线程的优先级:继承性，规则性，随机性
  • 线程的优先级具备继承性. 如,线程A启动线程B，则B和A优先级同样
  • 线程的优先级具备规则性. CPU尽可能倾向于把资源优先级高的线程
  • 线程的优先级具备随机性. 优先级不等同于执行顺序，两者关系不肯定
• java中的两种线程：用户线程和守护(Daemon)线程。
  • 守护线程：进程中不存在非守护线程时，守护线程自动销毁。典型例子如：垃圾回收线程。

比较和辨析

• 某个线程与当前线程：当前线程则是指正在运行的那个线程，可由currentThread()方法返回值肯定。例如，直接在main方法里调用run方法，和调用线程的start方法，打印出的当前线程结果是不一样的。
• interrupted()和isInterrupted()
  • interrupted()是类的静态方法，测试当前线程是否已是中断状态，执行后具备将状态标志清除为false的功能。
  • isInterrupted()是类的实例方法，测试Thread对象是否已是中断状态，但不清楚状态标志。
• sleep()和wait()区别：
  • sleep()是Thread类的static(静态)的方法；wait()方法是Object类里的方法
  • sleep()睡眠时，保持对象锁，仍然占有该锁；wait()睡眠时，释放对象锁
  • 在sleep()休眠时间期满后，该线程不必定会当即执行，这是由于其它线程可能正在运行并且没有被调度为放弃执行，除非此线程具备更高的优先级；wait()使用notify或者notifyAlll或者指定睡眠时间来唤醒当前等待池中的线程
  • wait()必须放在synchronized block中，不然会在runtime时扔出java.lang.IllegalMonitorStateException异常

方法	是否释放锁	备注
wait	是	wait和notify/notifyAll是成对出现的, 必须在synchronize块中被调用
sleep	否	可以使低优先级的线程得到执行机会
yield	否	yield方法使当前线程让出CPU占有权, 但让出的时间是不可设定的

对象及变量的并发访问

• synchronized关键字
  • 调用用关键字synchronized声明的方法是排队运行的。但假如线程A持有某对象的锁，那线程B异步调用非synchronized类型的方法不受限制。
  • synchronized锁重入:一个线程获得对象锁后，再次请求此对象锁时是能够获得该对象的锁的。同时，子类可经过“可重入锁”调用父类的同步方法。
  • 同步不具备继承性。
  • synchronized使用的“对象监视器”是一个，即必须是同一个对象
• synchronized同步方法和synchronized同步代码块。
  • 对其余synchronized同步方法或代码块调用呈阻塞状态。
  • 同一时间只有一个线程可执行synchronized方法/代码块中的代码
• synchronized(非this对象x)，将x对象做为“对象监视器”
  • 当多个线程同时执行synchronized(x){}同步代码块时呈同步效果
  • 当其余线程执行x对象中synchronizd同步方法时呈同步效果
  • 当其余线程执行x对象方法里的synchronized(this)代码块时呈同步效果
• 静态同步synchronized方法与synchronized(class)代码块：对当前对应的class类进行持锁。

线程的私有堆栈图

• volatile关键字：主要做用是使变量在多个线程间可见。加volatile关键字可强制性从公共堆栈进行取值,而不是从线程私有数据栈中取得变量的值
  • 在方法中while循环中设置状态位(不加volatile关键字)，在外面把状态位置位并不可行，循环不会中止，好比JVM在-server模式。
  • 缘由：是私有堆栈中的值和公共堆栈中的值不一样步
  • volatile增长了实例变量在多个线程间的可见性，但不支持原子性
• 原子类:一个原子类型就是一个原子操做可用的类型，可在没有锁的状况下作到线程安全。但原子类也不是彻底安全，虽然原子操做是安全的，可方法间的调用却不是原子的，须要用同步。

读取公共内存图

辨析和零散补充

• synchronized静态方法与非静态方法：synchronized关键字加static静态方法上是给Class类上锁，能够对类的全部实例对象起做用；synchronized关键字加到非static静态方法上是给对象上锁，对该对象起做用。这两个锁不是同一个锁。
• synchronized和volatile比较
  • 1)关键字volatile是线程同步的轻量级实现，性能比synchronized好，且volatile只能修饰变量，synchronized可修饰方法和代码块。
  • 2)多线程访问volatile不会发生阻塞，synchronized会出现阻塞
  • 3)volatile能保证数据可见性，不保证原子性;synchronized能够保证原子性，也能够间接保证可见性，由于synchronized会将私有内存和公共内存中的数据作同步。
  • 4)volatile解决的是变量在多个线程间的可见性，synchronized解决的是多个线程访问资源的同步性。
• String常量池特性，故大多数状况下，synchronized代码块都不适用String做为锁对象。
• 多线程死锁。使用JDK自带工具，jps命令+jstack命令监测是否有死锁。
• 内置类与静态内置类。
• 锁对象的的改变。
• 一个线程出现异常时，其所持有的锁会自动释放。

变量在内存中的工做过程图

线程间通讯

• 等待/通知机制：wait()和notify()/notifyAll()。wait使线程中止运行，notify使中止的线程继续运行。
  • wait()：将当前执行代码的线程进行等待，置入"预执行队列"。
    • 在调用wait()以前，线程必须得到该对象的对象级别锁；
    • 执行wait()方法后，当前线程当即释放锁；
    • 从wait()返回前，线程与其余线程竞争从新得到锁
    • 当线程呈wait()状态时，调用线程的interrup()方法会出现InterrupedException异常
    • wait(long)是等待某一时间内是否有线程对锁进行唤醒，超时则自动唤醒。
  • notify()：通知可能等待该对象的对象锁的其余线程。随机挑选一个呈wait状态的线程，使它等待获取该对象的对象锁。
    • 在调用notify()以前，线程必须得到该对象的对象级别锁；
    • 执行完notify()方法后，不会立刻释放锁，要直到退出synchronized代码块，当前线程才会释放锁。
    • notify()一次只随机通知一个线程进行唤醒
  • notifyAll()和notify()差很少，只不过是使全部正在等待队中等待同一共享资源的“所有”线程从等待状态退出，进入可运行状态。
• 每一个锁对象有两个队列：就绪队列和阻塞队列。
  • 就绪队列：存储将要得到锁的线程
  • 阻塞队列：存储被阻塞的的线程
• 生产者/消费者模式
  • “假死”：线程进入WAITING等待状态，呈假死状态的进程中全部线程都呈WAITING状态。
    • 假死的主要缘由：有可能连续唤醒同类。notify唤醒的不必定是异类，也许是同类，如“生产者”唤醒“生产者”。
    • 解决假死：将notify()改成notifyAll()
  • wait条件改变，可能出现异常，须要将if改为while
• 经过管道进行线程间通讯：一个线程发送数据到输出管道，另外一个线程从输入管道读数据。
  • 字节流：PipedInputStream和PipedOutputStream
  • 字符流：PipedReader和PipedWriter
• join()：等待线程对象销毁，具备使线程排队运行的做用。
  • join()与interrupt()方法彼此遇到会出现异常。
  • join(long)可设定等待的时间
• join与synchronized的区别：join在内部使用wait()方法进行等待;synchronized使用的是“对象监视器”原理做为同步
• join(long)与sleep(long)的区别：join(long)内部使用wait(long)实现，因此join(long)具备释放锁的特色;Thread.sleep(long)不释放锁。
• ThreadLocal类：每一个线程绑定本身的值
  • 覆写该类的initialValue()方法可使变量初始化，从而解决get()返回null的问题
  • InheritableThreadLocal类可在子线程中取得父线程继承下来的值。

Lock的使用

• ReentrantLock类：实现线程之间的同步互斥，比synchronized更灵活
  • lock()，调用了的线程就持有了“对象监视器”，效果和synchronized同样
• 使用Condition实现等待/通知：比wait()和notify()/notyfyAll()更灵活，好比可实现多路通知。
  • 调用condition.await()前须先调用lock.lock()得到同步监视器

Object与Condition方法对比

Object	Condition
wait()	await()
wait(long timeout)	await(long time,TimeUnit unit)
notify()	signal()
notifyAll()	signalAll()

一些API

方法	说明
int getHoldCount()	查询当前线程保持此锁定的个数，即调用lock()方法的次数
int getQueueLength()	返回正在等待获取此锁定的线程估计数
int getWaitQueueLength(Condition condition)	返回等待与此锁定相关的给定条件Conditon的线程估计数
boolean hasQueueThread(Thread thread)	查询指定的线程是否正在等待获取此锁定
boolean hasQueueThreads()	查询是否有线程正在等待获取此锁定
boolean hasWaiters(Condition)	查询是否有线程正在等待与此锁定有关的condition条件
boolean isFair()	判断是否是公平锁
boolean isHeldByCurrentThread()	查询当前线程是否保持此锁定
boolean isLocked()	查询此锁定是否由任意线程保持
void lockInterruptibly()	若是当前线程未被中断，则获取锁定，若是已经被中断则出现异常
boolean tryLock()	仅在调用时锁定未被另外一个线程保持的状况下，才获取该锁定
boolean tryLock(long timeout,TimeUnit unit)	若是锁定在给定等待时间内没有被另外一个线程保持，且当前线程未被中断，则获取该锁定

• 公平锁与非公平锁
  • 公平锁表示线程获取锁的顺序是按照加锁的顺序来分配的，即FIFO先进先出。
  • 非公平锁是一种获取锁的抢占机制，随机得到锁。
• ReentrantReadWriteLock类
  • 读读共享
  • 写写互斥
  • 读写互斥
  • 写读互斥

定时器

经常使用API

方法	说明
schedule(TimerTask task, Date time)	在指定的日期执行某一次任务
scheduleAtFixedRate(TimerTask task, Date firstTime, long period)	在指定的日期以后按指定的间隔周期，无限循环的执行某一任务
schedule(TimerTask task, long delay)	以执行此方法的当前时间为基准时间，在此时间基础上延迟指定的毫秒数后执行一次TimerTask任务
schedule(TimerTask task, long delay, long period)	以执行此方法的当前时间为基准时间，在此时间基础上延迟指定的毫秒数，再以某一间隔时间无限次数地执行某一TimerTask任务

• schedule和scheduleAtFixedRate的区别:schedule不具备追赶执行性;scheduleAtFixedRate具备追赶执行性

单例模式与多线程

• 当即加载/“饿汉模式”：调用方法前，实例已经被建立了。经过静态属性new实例化实现的
• 延迟加载/“懒汉模式”：调用get()方法时实例才被建立。最多见的实现办法是在get()方法中进行new实例化
  • 缺点：多线程环境中，会出问题
  • 解决方法
    • 声明synchronized关键字，但运行效率很是低下
    • 同步代码块，效率也低
    • 针对某些重要代码(实例化语句)单独同步，效率提高，但会出问题
    • 使用DCL双检查锁
    • 使用enum枚举数据类型实现单例模式

拾遗补增

方法与状态关系示意图

• 线程的状态：Thread.State枚举类,参阅官网APIEnum Thread.State
• 线程组：线程组中能够有线程对象，也能够有线程组，组中还能够有线程。可批量管理线程或线程组对象。
• SimpleDateFormat非线程安全，解决办法有：
  • 建立多个SimpleDateFormat类的实例
  • 使用ThreadLocal类
• 线程组出现异常的处理
  • setUncaughtExceptionHandler()给指定线程对线设置异常处理器
  • setDefaultUncaughtExceptionHandler()对全部线程对象设置异常处理器

相关资料

• 浅谈Java中的锁
• java synchronized关键字的用法
• Java Thread(线程)案例详解sleep和wait的区别

---

做者@brianway更多文章：我的网站 | CSDN | oschina