auto commit

This commit is contained in:
CyC2018
2019-12-13 00:48:43 +08:00
parent 80d6d56074
commit dde20ddf94
4 changed files with 130 additions and 136 deletions

View File

@ -1,34 +1,34 @@
<!-- GFM-TOC --> <!-- GFM-TOC -->
* [线程状态转换](#一线程状态转换) * [使用线程](#使用线程)
* [新建New](#新建new)
* [可运行Runnable](#可运行runnable)
* [阻塞Blocked](#阻塞blocked)
* [无限期等待Waiting](#无限期等待waiting)
* [限期等待Timed Waiting](#限期等待timed-waiting)
* [死亡Terminated](#死亡terminated)
* [使用线程](#二使用线程)
* [实现 Runnable 接口](#实现-runnable-接口) * [实现 Runnable 接口](#实现-runnable-接口)
* [实现 Callable 接口](#实现-callable-接口) * [实现 Callable 接口](#实现-callable-接口)
* [继承 Thread ](#继承-thread-) * [继承 Thread ](#继承-thread-)
* [实现接口 VS 继承 Thread](#实现接口-vs-继承-thread) * [实现接口 VS 继承 Thread](#实现接口-vs-继承-thread)
* [基础线程机制](#基础线程机制) * [基础线程机制](#基础线程机制)
* [Executor](#executor) * [Executor](#executor)
* [Daemon](#daemon) * [Daemon](#daemon)
* [sleep()](#sleep) * [sleep()](#sleep)
* [yield()](#yield) * [yield()](#yield)
* [中断](#中断) * [中断](#中断)
* [InterruptedException](#interruptedexception) * [InterruptedException](#interruptedexception)
* [interrupted()](#interrupted) * [interrupted()](#interrupted)
* [Executor 的中断操作](#executor-的中断操作) * [Executor 的中断操作](#executor-的中断操作)
* [互斥同步](#互斥同步) * [互斥同步](#互斥同步)
* [synchronized](#synchronized) * [synchronized](#synchronized)
* [ReentrantLock](#reentrantlock) * [ReentrantLock](#reentrantlock)
* [比较](#比较) * [比较](#比较)
* [使用选择](#使用选择) * [使用选择](#使用选择)
* [线程之间的协作](#线程之间的协作) * [线程之间的协作](#线程之间的协作)
* [join()](#join) * [join()](#join)
* [wait() notify() notifyAll()](#wait-notify-notifyall) * [wait() notify() notifyAll()](#wait-notify-notifyall)
* [await() signal() signalAll()](#await-signal-signalall) * [await() signal() signalAll()](#await-signal-signalall)
* [线程状态](#六线程状态)
* [新建NEW](#新建new)
* [可运行RUNABLE](#可运行runable)
* [阻塞BLOCKED](#阻塞blocked)
* [无限期等待Waiting](#无限期等待waiting)
* [限期等待Timed Waiting](#限期等待timed-waiting)
* [死亡Terminated](#死亡terminated)
* [J.U.C - AQS](#七juc---aqs) * [J.U.C - AQS](#七juc---aqs)
* [CountDownLatch](#countdownlatch) * [CountDownLatch](#countdownlatch)
* [CyclicBarrier](#cyclicbarrier) * [CyclicBarrier](#cyclicbarrier)
@ -59,59 +59,8 @@
<!-- GFM-TOC --> <!-- GFM-TOC -->
# 线程状态转换
<div align="center"> <img src="https://cs-notes-1256109796.cos.ap-guangzhou.myqcloud.com/adfb427d-3b21-40d7-a142-757f4ed73079.png" width="600px"> </div><br> # 使用线程
## 新建New
创建后尚未启动
## 可运行Runnable
可能正在运行也可能正在等待 CPU 时间片
包含了操作系统线程状态中的 Running Ready
## 阻塞Blocked
等待获取一个排它锁如果其线程释放了锁就会结束此状态
## 无限期等待Waiting
等待其它线程显式地唤醒否则不会被分配 CPU 时间片
| 进入方法 | 退出方法 |
| --- | --- |
| 没有设置 Timeout 参数的 Object.wait() 方法 | Object.notify() / Object.notifyAll() |
| 没有设置 Timeout 参数的 Thread.join() 方法 | 被调用的线程执行完毕 |
| LockSupport.park() 方法 | LockSupport.unpark(Thread) |
## 限期等待Timed Waiting
无需等待其它线程显式地唤醒在一定时间之后会被系统自动唤醒
调用 Thread.sleep() 方法使线程进入限期等待状态时常常用使一个线程睡眠进行描述
调用 Object.wait() 方法使线程进入限期等待或者无限期等待时常常用挂起一个线程进行描述
睡眠和挂起是用来描述行为而阻塞和等待用来描述状态
阻塞和等待的区别在于阻塞是被动的它是在等待获取一个排它锁而等待是主动的通过调用 Thread.sleep() Object.wait() 等方法进入
| 进入方法 | 退出方法 |
| --- | --- |
| Thread.sleep() 方法 | 时间结束 |
| 设置了 Timeout 参数的 Object.wait() 方法 | 时间结束 / Object.notify() / Object.notifyAll() |
| 设置了 Timeout 参数的 Thread.join() 方法 | 时间结束 / 被调用的线程执行完毕 |
| LockSupport.parkNanos() 方法 | LockSupport.unpark(Thread) |
| LockSupport.parkUntil() 方法 | LockSupport.unpark(Thread) |
## 死亡Terminated
可以是线程结束任务之后自己结束或者产生了异常而结束
# 使用线程
有三种使用线程的方法 有三种使用线程的方法
@ -193,7 +142,7 @@ public static void main(String[] args) {
- Java 不支持多重继承因此继承了 Thread 类就无法继承其它类但是可以实现多个接口 - Java 不支持多重继承因此继承了 Thread 类就无法继承其它类但是可以实现多个接口
- 类可能只要求可执行就行继承整个 Thread 类开销过大 - 类可能只要求可执行就行继承整个 Thread 类开销过大
# 基础线程机制 # 基础线程机制
## Executor ## Executor
@ -258,7 +207,7 @@ public void run() {
} }
``` ```
# 中断 # 中断
一个线程执行完毕之后会自动结束如果在运行过程中发生异常也会提前结束 一个线程执行完毕之后会自动结束如果在运行过程中发生异常也会提前结束
@ -378,7 +327,7 @@ Future<?> future = executorService.submit(() -> {
future.cancel(true); future.cancel(true);
``` ```
# 互斥同步 # 互斥同步
Java 提供了两种锁机制来控制多个线程对共享资源的互斥访问第一个是 JVM 实现的 synchronized而另一个是 JDK 实现的 ReentrantLock Java 提供了两种锁机制来控制多个线程对共享资源的互斥访问第一个是 JVM 实现的 synchronized而另一个是 JDK 实现的 ReentrantLock
@ -566,7 +515,7 @@ synchronized 中的锁是非公平的ReentrantLock 默认情况下也是非
除非需要使用 ReentrantLock 的高级功能否则优先使用 synchronized这是因为 synchronized JVM 实现的一种锁机制JVM 原生地支持它 ReentrantLock 不是所有的 JDK 版本都支持并且使用 synchronized 不用担心没有释放锁而导致死锁问题因为 JVM 会确保锁的释放 除非需要使用 ReentrantLock 的高级功能否则优先使用 synchronized这是因为 synchronized JVM 实现的一种锁机制JVM 原生地支持它 ReentrantLock 不是所有的 JDK 版本都支持并且使用 synchronized 不用担心没有释放锁而导致死锁问题因为 JVM 会确保锁的释放
# 线程之间的协作 # 线程之间的协作
当多个线程可以一起工作去解决某个问题时如果某些部分必须在其它部分之前完成那么就需要对线程进行协调 当多个线程可以一起工作去解决某个问题时如果某些部分必须在其它部分之前完成那么就需要对线程进行协调
@ -726,6 +675,54 @@ before
after after
``` ```
# 线程状态
一个线程只能处于一种状态并且这里的线程状态特指 Java 虚拟机的线程状态不能反映线程在特定操作系统下的状态
## 新建NEW
创建后尚未启动
## 可运行RUNABLE
正在 Java 虚拟机中运行但是在操作系统层面它可能处于运行状态也可能等待资源调度例如处理器资源资源调度完成就进入运行状态所以该状态的可运行是指可以被运行具体有没有运行要看底层操作系统的资源调度
## 阻塞BLOCKED
请求获取 monitor lock 从而进入 synchronized 函数或者代码块但是其它线程已经占用了该 monitor lock所以出于阻塞状态要结束该状态进入从而 RUNABLE 需要其他线程释放 monitor lock
## 无限期等待Waiting
等待其它线程显式地唤醒
阻塞和等待的区别在于阻塞是被动的它是在等待获取 monitor lock而等待是主动的通过调用 Object.wait() 等方法进入
| 进入方法 | 退出方法 |
| --- | --- |
| 没有设置 Timeout 参数的 Object.wait() 方法 | Object.notify() / Object.notifyAll() |
| 没有设置 Timeout 参数的 Thread.join() 方法 | 被调用的线程执行完毕 |
| LockSupport.park() 方法 | LockSupport.unpark(Thread) |
## 限期等待Timed Waiting
无需等待其它线程显式地唤醒在一定时间之后会被系统自动唤醒
| 进入方法 | 退出方法 |
| --- | --- |
| Thread.sleep() 方法 | 时间结束 |
| 设置了 Timeout 参数的 Object.wait() 方法 | 时间结束 / Object.notify() / Object.notifyAll() |
| 设置了 Timeout 参数的 Thread.join() 方法 | 时间结束 / 被调用的线程执行完毕 |
| LockSupport.parkNanos() 方法 | LockSupport.unpark(Thread) |
| LockSupport.parkUntil() 方法 | LockSupport.unpark(Thread) |
调用 Thread.sleep() 方法使线程进入限期等待状态时常常用使一个线程睡眠进行描述调用 Object.wait() 方法使线程进入限期等待或者无限期等待时常常用挂起一个线程进行描述睡眠和挂起是用来描述行为而阻塞和等待用来描述状态
## 死亡Terminated
可以是线程结束任务之后自己结束或者产生了异常而结束
[Java SE 9 Enum Thread.State](https://docs.oracle.com/javase/9/docs/api/java/lang/Thread.State.html)
# J.U.C - AQS # J.U.C - AQS
java.util.concurrentJ.U.C大大提高了并发性能AQS 被认为是 J.U.C 的核心 java.util.concurrentJ.U.C大大提高了并发性能AQS 被认为是 J.U.C 的核心

View File

@ -1,34 +1,34 @@
<!-- GFM-TOC --> <!-- GFM-TOC -->
* [线程状态转换](#一线程状态转换) * [使用线程](#使用线程)
* [新建New](#新建new)
* [可运行Runnable](#可运行runnable)
* [阻塞Blocked](#阻塞blocked)
* [无限期等待Waiting](#无限期等待waiting)
* [限期等待Timed Waiting](#限期等待timed-waiting)
* [死亡Terminated](#死亡terminated)
* [使用线程](#二使用线程)
* [实现 Runnable 接口](#实现-runnable-接口) * [实现 Runnable 接口](#实现-runnable-接口)
* [实现 Callable 接口](#实现-callable-接口) * [实现 Callable 接口](#实现-callable-接口)
* [继承 Thread ](#继承-thread-) * [继承 Thread ](#继承-thread-)
* [实现接口 VS 继承 Thread](#实现接口-vs-继承-thread) * [实现接口 VS 继承 Thread](#实现接口-vs-继承-thread)
* [基础线程机制](#基础线程机制) * [基础线程机制](#基础线程机制)
* [Executor](#executor) * [Executor](#executor)
* [Daemon](#daemon) * [Daemon](#daemon)
* [sleep()](#sleep) * [sleep()](#sleep)
* [yield()](#yield) * [yield()](#yield)
* [中断](#中断) * [中断](#中断)
* [InterruptedException](#interruptedexception) * [InterruptedException](#interruptedexception)
* [interrupted()](#interrupted) * [interrupted()](#interrupted)
* [Executor 的中断操作](#executor-的中断操作) * [Executor 的中断操作](#executor-的中断操作)
* [互斥同步](#互斥同步) * [互斥同步](#互斥同步)
* [synchronized](#synchronized) * [synchronized](#synchronized)
* [ReentrantLock](#reentrantlock) * [ReentrantLock](#reentrantlock)
* [比较](#比较) * [比较](#比较)
* [使用选择](#使用选择) * [使用选择](#使用选择)
* [线程之间的协作](#线程之间的协作) * [线程之间的协作](#线程之间的协作)
* [join()](#join) * [join()](#join)
* [wait() notify() notifyAll()](#wait-notify-notifyall) * [wait() notify() notifyAll()](#wait-notify-notifyall)
* [await() signal() signalAll()](#await-signal-signalall) * [await() signal() signalAll()](#await-signal-signalall)
* [线程状态](#六线程状态)
* [新建NEW](#新建new)
* [可运行RUNABLE](#可运行runable)
* [阻塞BLOCKED](#阻塞blocked)
* [无限期等待Waiting](#无限期等待waiting)
* [限期等待Timed Waiting](#限期等待timed-waiting)
* [死亡Terminated](#死亡terminated)
* [J.U.C - AQS](#七juc---aqs) * [J.U.C - AQS](#七juc---aqs)
* [CountDownLatch](#countdownlatch) * [CountDownLatch](#countdownlatch)
* [CyclicBarrier](#cyclicbarrier) * [CyclicBarrier](#cyclicbarrier)
@ -59,59 +59,8 @@
<!-- GFM-TOC --> <!-- GFM-TOC -->
# 线程状态转换
<div align="center"> <img src="https://cs-notes-1256109796.cos.ap-guangzhou.myqcloud.com/adfb427d-3b21-40d7-a142-757f4ed73079.png" width="600px"> </div><br> # 使用线程
## 新建New
创建后尚未启动
## 可运行Runnable
可能正在运行也可能正在等待 CPU 时间片
包含了操作系统线程状态中的 Running Ready
## 阻塞Blocked
等待获取一个排它锁如果其线程释放了锁就会结束此状态
## 无限期等待Waiting
等待其它线程显式地唤醒否则不会被分配 CPU 时间片
| 进入方法 | 退出方法 |
| --- | --- |
| 没有设置 Timeout 参数的 Object.wait() 方法 | Object.notify() / Object.notifyAll() |
| 没有设置 Timeout 参数的 Thread.join() 方法 | 被调用的线程执行完毕 |
| LockSupport.park() 方法 | LockSupport.unpark(Thread) |
## 限期等待Timed Waiting
无需等待其它线程显式地唤醒在一定时间之后会被系统自动唤醒
调用 Thread.sleep() 方法使线程进入限期等待状态时常常用使一个线程睡眠进行描述
调用 Object.wait() 方法使线程进入限期等待或者无限期等待时常常用挂起一个线程进行描述
睡眠和挂起是用来描述行为而阻塞和等待用来描述状态
阻塞和等待的区别在于阻塞是被动的它是在等待获取一个排它锁而等待是主动的通过调用 Thread.sleep() Object.wait() 等方法进入
| 进入方法 | 退出方法 |
| --- | --- |
| Thread.sleep() 方法 | 时间结束 |
| 设置了 Timeout 参数的 Object.wait() 方法 | 时间结束 / Object.notify() / Object.notifyAll() |
| 设置了 Timeout 参数的 Thread.join() 方法 | 时间结束 / 被调用的线程执行完毕 |
| LockSupport.parkNanos() 方法 | LockSupport.unpark(Thread) |
| LockSupport.parkUntil() 方法 | LockSupport.unpark(Thread) |
## 死亡Terminated
可以是线程结束任务之后自己结束或者产生了异常而结束
# 使用线程
有三种使用线程的方法 有三种使用线程的方法
@ -193,7 +142,7 @@ public static void main(String[] args) {
- Java 不支持多重继承因此继承了 Thread 类就无法继承其它类但是可以实现多个接口 - Java 不支持多重继承因此继承了 Thread 类就无法继承其它类但是可以实现多个接口
- 类可能只要求可执行就行继承整个 Thread 类开销过大 - 类可能只要求可执行就行继承整个 Thread 类开销过大
# 基础线程机制 # 基础线程机制
## Executor ## Executor
@ -258,7 +207,7 @@ public void run() {
} }
``` ```
# 中断 # 中断
一个线程执行完毕之后会自动结束如果在运行过程中发生异常也会提前结束 一个线程执行完毕之后会自动结束如果在运行过程中发生异常也会提前结束
@ -378,7 +327,7 @@ Future<?> future = executorService.submit(() -> {
future.cancel(true); future.cancel(true);
``` ```
# 互斥同步 # 互斥同步
Java 提供了两种锁机制来控制多个线程对共享资源的互斥访问第一个是 JVM 实现的 synchronized而另一个是 JDK 实现的 ReentrantLock Java 提供了两种锁机制来控制多个线程对共享资源的互斥访问第一个是 JVM 实现的 synchronized而另一个是 JDK 实现的 ReentrantLock
@ -566,7 +515,7 @@ synchronized 中的锁是非公平的ReentrantLock 默认情况下也是非
除非需要使用 ReentrantLock 的高级功能否则优先使用 synchronized这是因为 synchronized JVM 实现的一种锁机制JVM 原生地支持它 ReentrantLock 不是所有的 JDK 版本都支持并且使用 synchronized 不用担心没有释放锁而导致死锁问题因为 JVM 会确保锁的释放 除非需要使用 ReentrantLock 的高级功能否则优先使用 synchronized这是因为 synchronized JVM 实现的一种锁机制JVM 原生地支持它 ReentrantLock 不是所有的 JDK 版本都支持并且使用 synchronized 不用担心没有释放锁而导致死锁问题因为 JVM 会确保锁的释放
# 线程之间的协作 # 线程之间的协作
当多个线程可以一起工作去解决某个问题时如果某些部分必须在其它部分之前完成那么就需要对线程进行协调 当多个线程可以一起工作去解决某个问题时如果某些部分必须在其它部分之前完成那么就需要对线程进行协调
@ -726,6 +675,54 @@ before
after after
``` ```
# 线程状态
一个线程只能处于一种状态并且这里的线程状态特指 Java 虚拟机的线程状态不能反映线程在特定操作系统下的状态
## 新建NEW
创建后尚未启动
## 可运行RUNABLE
正在 Java 虚拟机中运行但是在操作系统层面它可能处于运行状态也可能等待资源调度例如处理器资源资源调度完成就进入运行状态所以该状态的可运行是指可以被运行具体有没有运行要看底层操作系统的资源调度
## 阻塞BLOCKED
请求获取 monitor lock 从而进入 synchronized 函数或者代码块但是其它线程已经占用了该 monitor lock所以出于阻塞状态要结束该状态进入从而 RUNABLE 需要其他线程释放 monitor lock
## 无限期等待Waiting
等待其它线程显式地唤醒
阻塞和等待的区别在于阻塞是被动的它是在等待获取 monitor lock而等待是主动的通过调用 Object.wait() 等方法进入
| 进入方法 | 退出方法 |
| --- | --- |
| 没有设置 Timeout 参数的 Object.wait() 方法 | Object.notify() / Object.notifyAll() |
| 没有设置 Timeout 参数的 Thread.join() 方法 | 被调用的线程执行完毕 |
| LockSupport.park() 方法 | LockSupport.unpark(Thread) |
## 限期等待Timed Waiting
无需等待其它线程显式地唤醒在一定时间之后会被系统自动唤醒
| 进入方法 | 退出方法 |
| --- | --- |
| Thread.sleep() 方法 | 时间结束 |
| 设置了 Timeout 参数的 Object.wait() 方法 | 时间结束 / Object.notify() / Object.notifyAll() |
| 设置了 Timeout 参数的 Thread.join() 方法 | 时间结束 / 被调用的线程执行完毕 |
| LockSupport.parkNanos() 方法 | LockSupport.unpark(Thread) |
| LockSupport.parkUntil() 方法 | LockSupport.unpark(Thread) |
调用 Thread.sleep() 方法使线程进入限期等待状态时常常用使一个线程睡眠进行描述调用 Object.wait() 方法使线程进入限期等待或者无限期等待时常常用挂起一个线程进行描述睡眠和挂起是用来描述行为而阻塞和等待用来描述状态
## 死亡Terminated
可以是线程结束任务之后自己结束或者产生了异常而结束
[Java SE 9 Enum Thread.State](https://docs.oracle.com/javase/9/docs/api/java/lang/Thread.State.html)
# J.U.C - AQS # J.U.C - AQS
java.util.concurrentJ.U.C大大提高了并发性能AQS 被认为是 J.U.C 的核心 java.util.concurrentJ.U.C大大提高了并发性能AQS 被认为是 J.U.C 的核心

Binary file not shown.

After

Width:  |  Height:  |  Size: 110 KiB

Binary file not shown.

After

Width:  |  Height:  |  Size: 110 KiB