[多线程]Java线程详解

Author：唐宋丶
发布时间：January 19, 2020
4666 views
3 comments
17179 words
Categories： Java

整理了网上大部分java线程相关的知识，并加入一些自己的理解以及代码示例。

#### 线程概述

一个Thread类实例只是一个对象，像Java中的任何其他对象一样，具有变量和方法，生死于堆上。
Java中，每个线程都有一个调用栈，即使不在程序中创建任何新的线程，线程也在后台运行着。
一个Java应用总是从main()方法开始运行，mian()方法运行在一个线程内，它被称为主线程。
一旦创建一个新的线程，就产生一个新的调用栈。
线程总体分两类：**用户线程**和**守护线程**。
当所有用户线程执行完毕的时候，JVM自动关闭。但是守候线程却不独立于JVM，守候线程一般是由操作系统或者用户自己创建的，随着JVM关闭也随之结束。
用个比较通俗的比如，任何一个守护线程都是整个JVM中所有非守护线程的保姆：
只要当前JVM实例中尚存在任何一个非守护线程没有结束，守护线程就全部工作；只有当最后一个非守护线程结束时，守护线程随着JVM一同结束工作。
Daemon的作用是为其他线程的运行提供便利服务，守护线程最典型的应用就是 GC (垃圾回收器)，它就是一个很称职的守护者。（后文有守护线程详解）

---

#### Java线程：创建与启动

##### 一、定义线程

**1、继承（extends）java.lang.Thread类。**
此类中有个run()方法，应该注意其用法：

```Java
    private Runnable target;

@Override
    public void run() {
        if (target != null) {
            target.run();
        }
    }
```

Thread的子类应该重写该方法，否则，该方法不执行任何操作并返回。

**2、实现（implements）java.lang.Runnable接口。**
源码如下：

```Java
@FunctionalInterface
public interface Runnable {
    public abstract void run();
}
```

使用实现接口Runnable的对象创建一个线程时，启动该线程将导致在独立执行的线程中调用对象实现的run方法。
方法run的常规协定是，它可能执行任何所需的操作。
**实现Runnable接口所具有的优势：**
1、避免Java单继承的问题
2、适合多线程处理同一资源
3、代码可以被多线程共享，数据独立，很容易实现资源共享

##### 二、实例化线程

1、如果是扩展java.lang.Thread类的线程，则直接new即可。
2、如果是实现了java.lang.Runnable接口的类，则用Thread的构造方法：
`Thread(Runnable target) `
`Thread(Runnable target, String name) `
`Thread(ThreadGroup group, Runnable target) `
`Thread(ThreadGroup group, Runnable target, String name) `
`Thread(ThreadGroup group, Runnable target, String name, long stackSize)`
即在xxxDemo的start()中：

```Java
Thread thread= new Thread();
Thread runnable= new Thread(new Runnable(){
    @Override
    public void run() {
    ...
    }
);
```

一般用法：

```java
Thread thread = new Thread(this,threadName);
```

若继承Thread类或实现Runnable接口，只重写了 `run()`方法，那么只需要如下这般创建：

```java
Thread thread = new ThreadDemo();
Thread runnable = new Thread(new RunnableDemo());
```

##### 三、启动线程

通俗来讲，在线程中，把需要处理的代码放到run()方法中，用户自定义的 `public void start()`会写入Thread的thread.start()方法启动线程，该方法将自动调用run()方法，这个由java的内存机制规定的。并且run()方法必需是public访问权限，返回值类型为void。
Thread.start()源码如下：

```Java
public synchronized void start() {
        /**
         * This method is not invoked for the main method thread or "system"
         * group threads created/set up by the VM. Any new functionality added
         * to this method in the future may have to also be added to the VM.
         *
         * A zero status value corresponds to state "NEW".
         */
        if (threadStatus != 0)
            throw new IllegalThreadStateException();
        /* Notify the group that this thread is about to be started
         * so that it can be added to the group's list of threads
         * and the group's unstarted count can be decremented. */
        group.add(this);
        boolean started = false;
        try {
            start0();
            started = true;
        } finally {
            try {
                if (!started) {
                    group.threadStartFailed(this);
                }
            } catch (Throwable ignore) {
                /* do nothing. If start0 threw a Throwable then
                  it will be passed up the call stack */
            }
        }
    }
```

当然直接调用Thread中的run()方法而不调用start()，程序也可以正常运行，但只是当成类中的方法调用，失去了线程的意义，具体区别如下：

* Thread.start()：创建了一个新的线程并处于就绪状态，当获得CPU时间片后开始执行，自动执行run()方法（回调机制）；该方法不能重复调用，会抛出 `java.lang.IllegalThreadStateException`。
* Thread.run()：直接调用该方法只会顺序执行，相当于调用普通的方法，可重复执行。（没有创建新的线程）

##### 四、例子

[Runnable](https://github.com/TangSong99/Thread_Demo/tree/master/out/production/threaddemo/runnable)
[Thread](https://github.com/TangSong99/Thread_Demo/tree/master/out/production/threaddemo/thread)
[Callable](https://github.com/TangSong99/Thread_Demo/tree/master/out/production/threaddemo/callable)

##### 五、一些常见问题

1、线程的名字，一个运行中的线程总是有名字的，名字有两个来源，一个是虚拟机自己给的名字，一个是你自己的定的名字。在没有指定线程名字的情况下，虚拟机总会为线程指定名字，并且主线程的名字总是mian，非主线程的名字不确定。

2、线程都可以设置名字，也可以获取线程的名字，连主线程也不例外。
`thread = new Thread(this,threadName);`
`Thread.currentThread().getName();`

3、获取当前线程的对象的方法是：`Thread.currentThread();`

4、在上面的代码中，只能保证：每个线程都将启动，每个线程都将运行直到完成。**一系列线程以某种顺序启动并不意味着将按该顺序执行**。对于任何一组启动的线程来说，调度程序不能保证其执行次序，持续时间也无法保证。（依赖于不同的调度算法）

5、**当线程目标run()方法结束时该线程完成。**

6、一旦线程启动，它就永远不能再重新启动（死线程）。只有一个新的线程可以被启动，并且只能一次。

7、线程的调度是JVM的一部分，在一个CPU的机器上，实际上一次只能运行一个线程。一次只有一个线程栈执行。JVM线程调度程序决定实际运行哪个处于可运行状态的线程。(**宏观并行，微观串行**)
众多可运行线程中的某一个会被选中做为当前线程。可运行线程被选择运行的顺序是没有保障的。

8、尽管通常采用队列形式，但这是没有保障的。队列形式是指当一个线程完成“一轮”时，它移到可运行队列的尾部等待，直到它最终排队到该队列的前端为止，它才能被再次选中。事实上，我们把它称为「**可运行池**」而不是一个可运行队列，目的是帮助认识线程并不都是以某种有保障的顺序排列成一个一个队列的事实。

9、尽管我们无法控制线程调度程序，但可以通过别的方式来影响线程调度的方式。（操作系统中的各种调度算法）
(以下涉及到操作系统)经典的调度算法：
FIFS先来先服务调度算法、SJF短作业优先调度算法、优先级调度算法（高响应比优先调度算法、时间片轮转调度算法、多级反馈队列调度算法）

---

#### Java线程：线程栈模型与线程的变量

要理解线程调度的原理，以及线程执行过程，必须理解线程栈模型。
线程栈是指某时刻时内存中线程调度的栈信息，当前调用的方法总是位于栈顶。线程栈的内容是随着程序的运行动态变化的，因此研究线程栈必须选择一个运行的时刻（实际上指代码运行到什么地方)。
下面通过一个示例性的代码说明线程（调用）栈的变化过程。
![](https://s2.ax1x.com/2020/01/19/1CfM2d.png)
这幅图描述在代码执行到两个不同时刻1、2时候，虚拟机线程调用栈示意图。
当程序执行到t.start();时候，程序多出一个分支（增加了一个调用栈B），这样，栈A、栈B并行执行。
从这里就可以看出方法调用和线程启动的区别了。

---

#### Java线程：线程状态的转换

##### 一、线程状态

![](https://s2.ax1x.com/2020/01/19/1Cf1KI.png)
![](https://s2.ax1x.com/2020/01/19/1CfIqx.png)
死亡态：当线程的run()方法完成时就认为它死去。这个线程对象也许是活的，但是，它已经不是一个单独执行的线程。线程一旦死亡，就不能复生。如果在一个死去的线程上调用start()方法，会抛出 `java.lang.IllegalThreadStateException`异常。

##### 二、阻止线程执行

对于线程的阻止，考虑一下三个方面，不考虑IO阻塞的情况：
睡眠；
等待；
因为需要一个对象的锁定而被阻塞。

###### **1、睡眠sleep()**

`Thread.sleep(long millis)`和 `Thread.sleep(long millis, int nanos)`静态方法强制当前正在执行的线程休眠（暂停执行），以“减慢线程”。当线程睡眠时，它入睡在某个地方，在苏醒之前不会返回到可运行状态。当睡眠时间到期，则返回到可运行(就绪)状态。
线程睡眠的原因：线程执行太快，或者需要强制进入下一轮，因为Java规范不保证合理的轮换。
睡眠的位置：为了让其他线程有机会执行，可以**将Thread.sleep()的调用放线程run()之内**。这样才能保证该线程执行过程中会睡眠。

**注意：**
1、线程睡眠是帮助所有线程获得运行机会的最好方法。
2、**线程睡眠到期自动苏醒，并返回到可运行(就绪)状态，不是运行状态**。sleep()中指定的时间是线程不会运行的最短时间。因此，sleep()方法不能保证该线程睡眠到期后就开始执行。
3、sleep()是静态方法，只能控制当前正在运行的线程。

###### **2、线程的优先级和线程让步yield()**

线程的让步是通过 `Thread.yield()`来实现的。yield()方法的作用是：暂停当前正在执行的线程对象，并执行其他线程。

要理解yield()，必须了解线程的优先级的概念。线程总是存在优先级，优先级范围在1~10之间。JVM线程调度程序是基于优先级的抢先调度机制。在大多数情况下，当前运行的线程优先级将大于或等于线程池中任何线程的优先级。但这仅仅是大多数情况。

注意：当设计多线程应用程序的时候，一定不要依赖于线程的优先级。因为线程调度优先级操作是没有保障的，只能把线程优先级作用作为一种提高程序效率的方法，但是要保证程序不依赖这种操作。

当线程池中线程都具有相同的优先级，调度程序的JVM实现自由选择它喜欢的线程。这时候调度程序的操作有两种可能：一是选择一个线程运行，直到它阻塞或者运行完成为止。二是时间分片，为池内的每个线程提供均等的运行机会。

设置线程的优先级：线程默认的优先级是创建它的执行线程的优先级。可以通过 `setPriority(int newPriority)`更改线程的优先级。例如：

```Java
        Thread t = new MyThread();
        t.setPriority(8);
        t.start();
```

线程优先级为1~10之间的正整数，JVM从不会改变一个线程的优先级。然而，1~10之间的值是没有保证的。一些JVM可能不能识别10个不同的值，而将这些优先级进行每两个或多个合并，变成少于10个的优先级，则两个或多个优先级的线程可能被映射为一个优先级。

线程默认优先级是5，Thread类中有三个常量，定义线程优先级范围：
`static int MAX_PRIORITY `线程可以具有的最高优先级。
`static int MIN_PRIORITY `线程可以具有的最低优先级。
`static int NORM_PRIORITY `分配给线程的默认优先级。

**结论1：优先级高非先运行，只是获得cpu资源的可能性更大**。

**yield()应该做的是让当前运行线程回到可运行状态，以允许具有相同优先级的其他线程获得运行机会**。因此，使用yield()的目的是让相同优先级的线程之间能适当的轮转执行。但是，实际中无法保证yield()达到让步目的，因为让步的线程还有可能被线程调度程序再次选中。

**结论2：yield()从未导致线程转到等待/睡眠/阻塞状态。在大多数情况下，yield()将导致线程从运行状态转到可运行状态，但有可能没有效果**。

###### 3、join()方法

Thread的非静态方法join()让一个线程B“加入”到另外一个线程A的尾部。在A执行完毕之前，B不能工作。例如：

```Java
        Thread t = new MyThread();
        t.start();
        t.join();
```

**main方法运行thread.join(),这是会让主线程mian等待新的线程thread执行完了，再执行主线程mian下面的代码，thread.join()是然主线程main wait**。

另外，join()方法还有带超时限制的重载版本。例如 `t.join(5000);`则让线程等待5000毫秒，如果超过这个时间，则停止等待，变为可运行状态。
线程的加入join()对线程栈导致的结果是线程栈发生了变化，当然这些变化都是瞬时的。

##### 小结

到目前位置，介绍了线程离开运行状态的3种方法：

1. 调用Thread.sleep()：使当前线程睡眠至少多少毫秒（尽管它可能在指定的时间之前被中断）。
2. 调用Thread.yield()：不能保障太多事情，尽管通常它会让当前运行线程回到可运行性状态，使得有相同优先级的线程有机会执行。
3. 调用join()方法：保证当前线程停止执行，直到该线程所加入的线程完成为止。然而，如果它加入的线程没有存活，则当前线程不需要停止。

除了以上三种方式外，还有下面几种特殊情况可能使线程离开运行状态：

1. 线程的run()方法完成。
2. 在对象上调用wait()方法（不是在线程上调用）。
3. 线程不能在对象上获得锁定，它正试图运行该对象的方法代码。
4. 线程调度程序(策略)可以决定将当前运行状态移动到可运行状态，以便让另一个线程获得运行机会，而不需要任何理由。

---

#### Java线程：线程的同步与锁

以卖票的例子来介绍多线程和资源共享。
　　卖票是包含一系列动作的过程，有各种操作，例如查询票、收钱、数钱、出票等，其中有一个操作是每次卖掉一张，就将总的票数减去1。有10张票，如果一个人卖票，先做查票、收钱、数钱等各种操作，再将总的票数减去1，效率很低。如果多个人卖票，每个人都是做同样的操作，数钱、检查钱，最后将总的票数减1，这样效率高。但是有一个问题，如果出现两个人同时将总的票数减掉了1，例如，A、B两个人同时读取到票的总数是10，A从中减去1，同时B也从中减去1，总数显示是9，其实票只有8张。导致数据错误。
　　按照正常逻辑，同一时刻只允许一个人来从总票数中减去1，A读取总票数，再减去1的过程中，B必须等待，等A操作完了，B才能进行。其实票就是共享资源，一次只能由一个人访问。这里就要用到同步机制，即锁机制，使用关键词 `synchronized`将读取总的票数，并减去1的操作锁定，使得一次只能由一个人访问。每个售票员就是一个线程，多个售票员进行同一项卖票任务。
　　synchronized原理是，执行synchronized部分代码的时候必须需要对象锁，而一个对象只有一个锁，只有执行完synchronized里面的代码后释放锁，其他线程才可以获得锁，那么就保证了同一时刻只有一个线程访问synchronized里面的代码。使得资源共享的关键是，只有一个实例，synchronized使用的是同一把锁，用实例的锁或者定义一个实例。**这就需要使用实现Runnable接口的方式，实现多线程，这样传入的是一个实例。继承Thread的方式，传入的是多个实例，每个实例都有一个锁，那就无法实现控制。**
　　**synchronized是Java中的关键字，是一种同步锁。**

##### 一、同步问题提出

线程的同步是为了防止多个线程访问一个数据对象时，对数据造成的破坏（脏数据、脏读、不可重复读、幻读等）。

##### 二、同步和锁定

**1、锁的原理**
Java中每个对象都有一个内置锁
当程序运行到非静态的synchronized同步方法上时，自动获得与正在执行代码类的当前实例（this实例）有关的锁。获得一个对象的锁也称为获取锁、锁定对象、在对象上锁定或在对象上同步。

当程序运行到synchronized同步方法或代码块时该对象锁才起作用。

一个对象只有一个锁。所以，如果一个线程获得该锁，就没有其他线程可以获得锁，直到第一个线程释放（或返回）锁。这也意味着任何其他线程都不能进入该对象上的synchronized方法或代码块，直到该锁被释放。

释放锁是指持锁线程退出了synchronized同步方法或代码块。

关于锁和同步，有一下几个要点：

1. 只能同步方法，而不能同步变量和类；
2. 每个对象只有一个锁；当提到同步时，应该清楚在什么上同步？也就是说，在哪个对象上同步？
3. 不必同步类中所有的方法，类可以同时拥有同步和非同步方法。
4. 如果两个线程要执行一个类中的synchronized方法，并且两个线程使用相同的实例来调用方法，那么一次只能有一个线程能够执行方法，另一个需要等待，直到锁被释放。也就是说：**如果一个线程在对象上获得一个锁，就没有任何其他线程可以进入（该对象的）类中的任何一个同步方法。**
5. 如果线程拥有同步和非同步方法，则非同步方法可以被多个线程自由访问而不受锁的限制。
6. **线程睡眠时，它所持的任何锁都不会释放。**
7. 线程可以获得多个锁。比如，在一个对象的同步方法里面调用另外一个对象的同步方法，则获取了两个对象的同步锁。
8. 同步损害并发性，应该尽可能缩小同步范围。同步不但可以同步整个方法，还可以同步方法中一部分代码块。
9. 在使用同步代码块时候，应该指定在哪个对象上同步，也就是说要获取哪个对象的锁。例如：

```Java
/*同步方法*/
    public synchronized int getX() {
        return x++;
    }
```

当然，同步方法也可以改写为同步代码块，但功能完全一样的，例如：

```Java
/*同步代码块*/
    public int fix(int y) {
        synchronized (this) {
            x = x - y;
        }
        return x;
    }
```

与

```Java
/*同步代码块
优势：减小锁的粒度，提高性能。
*/
    public int getX() {
        synchronized (this) {
            return x++;
        }
    }
```

效果是完全一样的。

##### 三、静态方法同步

要同步静态方法，需要一个用于整个类对象的锁，这个对象是就是这个类（XXX.class)。

例如：

```Java
public static synchronized int setName(String name){
      Xxx.name = name;
}
```

等价于

```Java
public static int setName(String name){
      synchronized(Xxx.class){
            Xxx.name = name;
      }
}
```

即：
synchronized主要有两种方法
1.1、**synchronized块（对象级）**：` synchronized(this){}`
1.2、**synchronized块（类级别）**：类在堆中存在一个class 对象（注意这里的class是小写），所以所谓的类锁，**本质上还是对一个对象**，在这里也就是class对象进行同步获取。当然体现出来的效果是在类上进行了同步。` synchronized（类名.class）`
2、  **synchronized方法** `public synchronized String setID(){}`

**补充：**
1.**方法锁(同步方法、同步代码块两者的别称)和私有锁，都属于对象锁**，但与执行非同步方法不会产生冲突。
2.静态同步方法(static+synchronized)，属于类锁。
3.类锁和对象锁不发生冲突，但对象锁之间会发生冲突，同一时刻对象只能执行一个同步方法或同步代码块。

##### 四、如果线程不能获得锁会怎么样

如果线程试图进入同步方法，而其锁已经被占用，则线程在该对象上被阻塞。实质上，线程进入该对象的的一种池中，必须在哪里等待，直到其锁被释放，该线程再次变为可运行或运行为止。

当考虑阻塞时，一定要注意哪个对象正被用于锁定：

1. 调用同一个对象中非静态同步方法的线程将彼此阻塞。如果是不同对象，则每个线程有自己的对象的锁，线程间彼此互不干预。
2. 调用同一个类中的静态同步方法的线程将彼此阻塞，它们都是锁定在相同的Class对象上。
3. 静态同步方法和非静态同步方法将永远不会彼此阻塞，因为静态方法锁定在Class对象上，非静态方法锁定在该类的对象上。
4. 对于同步代码块，要看清楚什么对象已经用于锁定（synchronized后面括号的内容）。在同一个对象上进行同步的线程将彼此阻塞，在不同对象上锁定的线程将永远不会彼此阻塞。

##### 五、何时需要同步

在多个线程同时访问互斥（可交换）数据时，应该同步以保护数据，确保两个线程不会同时修改更改它。

对于非静态字段中可更改的数据，通常使用非静态方法访问。
对于静态字段中可更改的数据，通常使用静态方法访问。

##### 六、线程安全类

当一个类已经很好的同步以保护它的数据时，这个类就称为“线程安全的”。
即使是线程安全类，也应该特别小心，因为操作的线程之间仍然不一定安全。

例如：
对线程安全的集合进行判断非空和删除所有元素操作的时候，线程一二都查询非空，但是线程一删除元素后线程二再重复执行是错误的。
方法：对所有方法增加一个同步锁，这样，当一个线程访问其中一个同步方法时，其他线程只有等待。

##### 七、线程死锁（涉及操作系统）

所谓死锁是指两个或两个以上的线程在执行过程中，因争夺资源而造成的一种互相等待的现象，若无外力作用，它们都将无法推进下去。
[DeadLockRiskTest](https://github.com/TangSong99/Thread_Demo/tree/master/out/production/threaddemo/test/deadlockrisk)

**死锁产生的必要条件：**
（1）互斥
（2）不剥夺
（3）请求和保持等待
（4）循环等待

**避免死锁：**

* 加锁顺序（线程按照一定的顺序加锁）
* 加锁时限（线程尝试获取锁的时候加上一定的时限，超过时限则放弃对该锁的请求，并释放自己占有的锁）
* 死锁检测（LOCK）

**总结：避免死锁的方式**

1. 让程序每次至多只能获得一个锁。当然，在多线程环境下，这种情况通常并不现实。
2. 设计时考虑清楚锁的顺序，尽量减少嵌在的加锁交互数量。
3. 既然死锁的产生是两个线程无限等待对方持有的锁，那么只要等待时间有个上限不就好了。当然synchronized不具备这个功能，但是我们可以使用Lock类中的tryLock方法去尝试获取锁，这个方法可以指定一个超时时限，在等待超过该时限之后便会返回一个失败信息。
   我们可以使用 `ReentrantLock.tryLock()`方法，在一个循环中，如果tryLock()返回失败，那么就释放以及获得的锁，并睡眠一小段时间。这样就打破了死锁的闭环。比如：线程T1持有锁L1并且申请获得锁L2，而线程T2持有锁L2并且申请获得锁L3，而线程T3持有锁L3并且申请获得锁L1。此时如果T3申请锁L1失败，那么T3释放锁L3，并进行睡眠，那么T2就可以获得L3了，然后T2执行完之后释放L2, L3，所以T1也可以获得L2了执行完然后释放锁L1, L2，然后T3睡眠醒来，也可以获得L1, L3了。打破了死锁的闭环。

##### 八、线程同步小结

1. 线程同步的目的是为了保护多个线程访问一个资源时对资源的破坏。
2. 线程同步方法是通过锁来实现，每个对象都有切仅有一个锁，这个锁与一个特定的对象关联，线程一旦获取了对象锁，其他访问该对象的线程就无法再访问该对象的其他同步方法。
   **注意：方法锁和私有锁都属于对象锁**
3. 对于静态同步方法，锁是针对这个类的，锁对象是该类的Class对象。静态和非静态方法的锁互不干预。一个线程获得锁，当在一个同步方法中访问另外对象上的同步方法时，会获取这两个对象锁。
   （对象锁是在一个类的对象上加的的锁，只有一把，不管有几个方法进行了同步。
   这些同步方法都共有一把锁，只要一个线程获得了这个对象锁，其他的线程就不能访问该对象的任何一个同步方法。）
4. 对于同步，要时刻清醒在哪个对象上同步，这是关键。
5. 编写线程安全的类，需要时刻注意对多个线程竞争访问资源的逻辑和安全做出正确的判断，对“原子”操作做出分析，并保证原子操作期间别的线程无法访问竞争资源。
6. 当多个线程等待一个对象锁时，没有获取到锁的线程将发生阻塞。
7. 死锁是线程间相互等待锁锁造成的，在实际中发生的概率非常的小。

---

#### Java线程：线程的交互

##### 线程交互的基础知识

###### wait、notify/notifyAll 详解

void notify() 唤醒在此对象监视器上等待的单个线程。
void notifyAll() 唤醒在此对象监视器上等待的所有线程。
void wait() 导致当前的线程等待（前提是先获得锁，即在synchronized同步代码块里使用），直到其他线程调用此对象的 notify()方法或 notifyAll()方法。

三个方法都是Object的本地final方法，无法被重写。由于 wait()、notify/notifyAll() 在synchronized 代码块执行，说明当前线程一定是获取了锁的。
当线程执行wait()方法时候，会释放当前的锁，然后让出CPU，进入等待状态。
只有当 notify/notifyAll() 被执行时候，才会唤醒一个或多个正处于等待状态的线程，然后继续往下执行，直到执行完synchronized 代码块的代码或是中途遇到wait() ，再次释放锁。
也就是说，notify/notifyAll() 的执行只是唤醒沉睡的线程，而不会立即释放锁，锁的释放要看代码块的具体执行情况。所以在编程中，**尽量在使用了notify/notifyAll() 后立即退出临界区，以唤醒其他线程让其获得锁。**

wait() 需要被try catch包围，以便发生异常中断也可以使wait等待的线程唤醒。

###### notify 和 notifyAll的区别

notify方法只唤醒一个等待（对象的）线程并使该线程开始执行。所以如果有多个线程等待一个对象，这个方法只会唤醒其中一个线程，选择哪个线程取决于操作系统对多线程管理的实现。notifyAll 会唤醒所有等待(对象的)线程，尽管哪一个线程将会第一个处理取决于操作系统的实现。如果当前情况下有多个线程需要被唤醒，推荐使用notifyAll 方法。比如在生产者-消费者里面的使用，每次都需要唤醒所有的消费者或是生产者，以判断程序是否可以继续往下执行。

```Java
public class K {
    //状态锁
    private Object lock;
    //条件变量
    private int now,need;
    public void produce(int num){
        //同步
        synchronized (lock){
           //当前有的不满足需要，进行等待，直到满足条件
            while(now < need){
                try {
                    //等待阻塞
                    lock.wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("我被唤醒了！");
            }
           // 做其他的事情
        }
    }
}
```

显然，只有当前值满足需要值的时候，线程才可以往下执行，所以，必须使用while 循环阻塞。注意，wait() 当被唤醒时候，只是让while循环继续往下走.如果此处用if的话，意味着if继续往下走，会跳出if语句块。

**总结：**
当等待的事件发生时，需要能够检查notifyAll()通知事件是否已经发生。
通常，解决上面问题的最佳方式是利用某种循环，该循环检查某个条件表达式，只有当正在等待的事情还没有发生的情况下，它才继续等待。

**生产者-消费者问题:**
[生产者-消费者问题代码](https://github.com/TangSong99/Thread_Demo/tree/master/out/production/threaddemo/test/producer_consumer)

---

#### Java线程：线程的调度-休眠

线程休眠的目的是使线程让出CPU的最简单的做法之一，线程休眠时候，会将CPU资源交给其他线程，以便能轮换执行，当休眠一定时间后，线程会苏醒，进入准备状态等待执行。
线程休眠的方法是Thread.sleep(long millis)和Thread.sleep(long millis, int nanos)，均为静态方法，哪个线程调用sleep，就休眠哪个线程。

---

#### Java线程：线程的调度-优先级

与线程休眠类似，线程的优先级仍然无法保障线程的执行次序。只不过，优先级高的线程获取CPU资源的概率较大，优先级低的并非没机会执行。

线程的优先级用1-10之间的整数表示，数值越大优先级越高，默认的优先级为5。

在一个线程中开启另外一个新线程，则新开线程称为该线程的子线程，子线程初始优先级与父线程相同。

```Java
public class Test {
        public static void main(String[] args) {
                Thread t1 = new MyThread1();
                Thread t2 = new Thread(new MyRunnable());
                t1.setPriority(10); 
                t2.setPriority(1); 
                t2.start(); 
                t1.start(); 
        } 
} 
```

---

#### Java线程：线程的调度-让步

线程的让步含义就是使当前运行着线程让出CPU资源，但是然给谁不知道，仅仅是让出，线程状态回到可运行状态。

线程的让步使用Thread.yield()方法，yield()为静态方法，功能是暂停当前正在执行的线程对象，并执行其他线程。

详见：Java线程：线程状态的转换——阻止线程执行

---

#### Java线程：线程的调度-合并

线程的合并的含义就是将几个并行线程的线程合并为一个单线程执行，应用场景是当一个线程必须等待另一个线程执行完毕才能执行时可以使用join方法。

详见：Java线程：线程状态的转换——阻止线程执行
[joinTest](https://github.com/TangSong99/Thread_Demo/tree/master/out/production/threaddemo/test/join)

---

#### Java线程：线程的调度-守护线程

只要当前JVM实例中尚存在任何一个非守护线程没有结束，守护线程就全部工作；只有当最后一个非守护线程结束时，守护线程随着JVM一同结束工作。
Daemon的作用是为其他线程的运行提供便利服务，守护线程最典型的应用就是 GC (垃圾回收器)，它就是一个很称职的守护者。

User和Daemon两者几乎没有区别，唯一的不同之处就在于虚拟机的离开：如果 User Thread已经全部退出运行了，只剩下Daemon Thread存在了，虚拟机也就退出了。因为没有了被守护者，Daemon也就没有工作可做了，也就没有继续运行程序的必要了。
[daemontest](https://github.com/TangSong99/Thread_Demo/tree/master/out/production/threaddemo/daemontest)

---

#### Java线程：线程的同步-同步方法、同步块

详见上文：Java线程：线程的同步与锁

注意：
在使用synchronized关键字时候，应该尽可能避免在synchronized方法或synchronized块中使用sleep或者yield方法，因为synchronized程序块占有着对象锁，你休息那么其他的线程只能一边等着你醒来执行完了才能执行。不但严重影响效率，也不合逻辑。
同样，在同步程序块内调用yeild方法让出CPU资源也没有意义，因为你占用着锁，其他互斥线程还是无法访问同步程序块。当然与同步程序块无关的线程可以获得更多的执行时间。
[同步块](https://github.com/TangSong99/Thread_Demo/tree/master/out/production/threaddemo/test/synchronize)

---

#### Java线程：并发协作-死锁

详见Java线程：线程的同步与锁——线程死锁

---

#### Java线程：volatile关键字

Java 语言中的 volatile 变量可以被看作是一种 “程度较轻的 synchronized”；与 synchronized 块相比，volatile 变量所需的编码较少，并且运行时开销也较少，但是它所能实现的功能也仅是 synchronized 的一部分。

解释：
Volatile 变量具有 synchronized 的可见性特性，但是不具备原子特性。这就是说线程能够自动发现 volatile 变量的最新值。Volatile 变量可用于提供线程安全，但是只能应用于非常有限的一组用例：多个变量之间或者某个变量的当前值与修改后值之间没有约束。因此，单独使用 volatile 还不足以实现计数器、互斥锁或任何具有与多个变量相关的不变式（Invariants）的类（例如 “start <=end”）。

出于简易性或可伸缩性的考虑，您可能倾向于使用 volatile 变量而不是锁。当使用 volatile 变量而非锁时，某些习惯用法（idiom）更加易于编码和阅读。此外，volatile 变量不会像锁那样造成线程阻塞，因此也很少造成可伸缩性问题。在某些情况下，如果读操作远远大于写操作，volatile 变量还可以提供优于锁的性能优势。

**volatile、synchronized**
volatile 功能，声明了volatile的变量，进行写操作的时候，jvm会向处理器发送一条Lock的前缀指令，会把这个变量所在缓存行的数据写回到系统内存。
在多处理器的情况下，保证各个处理器缓存一致性的特点，会实现缓存一致性协议。改变了值的volatile变量，在其他行程被指为失效状态其他线程要使用这个变量，需要重新到驻村里面去取。

**synchronized：可重入锁、互斥性、可见性**
**volatile 可以做到原子性，可见性，不能做到复合操作的原子性**

比如： volatile int i;
i++ 读取i的值，给i加1，把新的值赋值给i，这个i++操作在多线程环境下是无法保证原子性的

synchronized后面锁定的对象，可以是一个类对象，也可以是一个成员变量。
第一个线程进来调用monitorener 和monitorexit实现，获取对象的监视器，释放对象监视器
后续进程过来，如果monitor还没有释放，那么他获取不到这个对象的monitor，会放到一个对列里面：synthronizedQueue。 等到对象的锁释放了，通知synthronizedQueue出队列，获取那个monitor。

**volatile 的限制——只有在状态真正独立于程序内其他内容时才能使用 volatile**

详细说明请看此文章：[volatile 关键字的最全总结](https://mp.weixin.qq.com/s/snxOvuED1KvrOVexdsutSg)

---

#### Java线程：新特征-线程池

##### 一、固定大小的线程池

//创建一个可重用固定线程数的线程池
`ExecutorService pool = Executors.newFixedThreadPool(2); `

##### 二、单任务线程池

//创建一个使用单个 worker线程的 Executor，以无界队列方式来运行该线程。
`ExecutorService pool = Executors.newSingleThreadExecutor();`

##### 三、可变尺寸的线程池

//创建一个可根据需要创建新线程的线程池，但是在以前构造的线程可用时将重用它们。
`ExecutorService pool = Executors.newCachedThreadPool();`

##### 四、延迟连接池

//创建一个线程池，它可安排在给定延迟后运行命令或者定期地执行。
`ScheduledExecutorService pool = Executors.newScheduledThreadPool(2);`
//使用延迟执行风格的方法
`pool.schedule(t4, 10, TimeUnit.MILLISECONDS); `

##### 五、单任务延迟连接池

//创建一个单线程执行程序，它可安排在给定延迟后运行命令或者定期地执行。
`ScheduledExecutorService pool = Executors.newSingleThreadScheduledExecutor();`

##### 六、自定义线程池

//创建等待队列
`BlockingQueue<Runnable> bqueue = new ArrayBlockingQueue<Runnable>(20);`
//创建一个单线程执行程序，它可安排在给定延迟后运行命令或者定期地执行。
`ThreadPoolExecutor pool = new ThreadPoolExecutor(2,3,2,TimeUnit.MILLISECONDS,bqueue);`

##### 七、代码参考

[ThreadPool](https://github.com/TangSong99/Thread_Demo/tree/master/out/production/threaddemo/threadpool)
[DIYThreadPool](https://github.com/TangSong99/Thread_Demo/tree/master/out/production/threaddemo/test/threadpool)

---

#### Java线程：新特征-锁

在Java5中，专门提供了锁对象，利用锁可以方便的实现资源的封锁，用来控制对竞争资源并发访问的控制，这些内容主要集中在java.util.concurrent.locks包下面，里面有三个重要的接口Condition、Lock、ReadWriteLock。

**Condition：**
Condition将Object监视器方法（wait、notify和 notifyAll）分解成截然不同的对象，以便通过将这些对象与任意Lock实现组合使用，为每个对象提供多个等待 set（wait-set）。

**Lock：**
Lock实现提供了比使用synchronized方法和语句可获得的更广泛的锁定操作。

**ReadWriteLock：**
ReadWriteLock维护了一对相关的锁定，一个用于只读操作，另一个用于写入操作。
ReentrantReadWriteLock：把它理解成一个数据库的事务锁（拆分成读锁和写锁、写锁之间互斥，读锁不互斥、要获取写锁必须除当前线程外不能存在其他的读锁）。

```Java
ReadWriteLock lock = new ReentrantReadWriteLock(false);
sync = fair ? new FairSync() : new NonfairSync();
```

注意：lock必须lock.unlock()释放，否则如果受保护的代码抛出异常，锁就可能永远得不到释放。

```Java
Lock lock = new ReentrantLock();
lock.lock();
try { 
  // update object state
}
finally {
  lock.unlock(); 
}
```

**关于ReentrantLock：**

[ReenTrantLock可重入锁（和synchronized的区别）总结](https://blog.csdn.net/qq838642798/article/details/65441415)
[轻松学习java可重入锁\(ReentrantLock\)的实现原理](https://blog.csdn.net/yanyan19880509/article/details/52345422)

在上文中提到了Lock接口以及对象，使用它，很优雅的控制了竞争资源的安全访问，但是这种锁不区分读写，称这种锁为普通锁。为了提高性能，Java提供了读写锁，在读的地方使用读锁，在写的地方使用写锁，灵活控制，在一定程度上提高了程序的执行效率。
Java中读写锁有个接口 `java.util.concurrent.locks.ReadWriteLock`，也有具体的实现

**在实际开发中，最好能用读写锁的情况下使用读写锁，而不要用普通锁，以求更好的性能。**

[锁相关代码](https://github.com/TangSong99/Thread_Demo/tree/master/out/production/threaddemo/lock)

---

#### Java线程：新特征-信号量

Java的信号量实际上是一个功能完毕的计数器，对控制一定资源的消费与回收有着很重要的意义，信号量常常用于多线程的代码中，并能监控有多少数目的线程等待获取资源，并且通过信号量可以得知可用资源的数目等等，这里总是在强调“数目”二字，但不能指出来有哪些在等待，哪些资源可用。

观点：信号量类如果能返回数目，还能知道哪些对象在等待，哪些资源可使用，就非常完美了，仅仅拿到这些概括性的数字，对精确控制意义不是很大。目前还没想到更好的用法。

[信号量代码](https://github.com/TangSong99/Thread_Demo/tree/master/out/production/threaddemo/semaphore)

---

#### Java线程：新特征-阻塞队列

阻塞队列是Java5线程新特征中的内容，Java定义了阻塞队列的接口 `java.util.concurrent.BlockingQueue`，阻塞队列的概念是，一个指定长度的队列，如果队列满了，添加新元素的操作会被阻塞等待，直到有空位为止。同样，当队列为空时候，请求队列元素的操作同样会阻塞等待，直到有可用元素为止。
有了这样的功能，就为多线程的排队等候的模型实现开辟了便捷通道，非常有用。
java.util.concurrent.BlockingQueue继承了java.util.Queue接口，可以参看API文档。

[BlockingQueue代码](https://github.com/TangSong99/Thread_Demo/tree/master/out/production/threaddemo/blocking)

**BlockingQueue核心方法**

```Java
public interface BlockingQueue<E> extends Queue<E> {

//将给定元素设置到队列中，如果设置成功返回true, 否则返回false。如果是往限定了长度的队列中设置值，推荐使用offer()方法。
    boolean add(E e);

//将给定的元素设置到队列中，如果设置成功返回true, 否则返回false. e的值不能为空，否则抛出空指针异常。
    boolean offer(E e);

//将元素设置到队列中，如果队列中没有多余的空间，该方法会一直阻塞，直到队列中有多余的空间。
    void put(E e) throws InterruptedException;

//将给定元素在给定的时间内设置到队列中，如果设置成功返回true, 否则返回false.
    boolean offer(E e, long timeout, TimeUnit unit)
        throws InterruptedException;

//从队列中获取值，如果队列中没有值，线程会一直阻塞，直到队列中有值，并且该方法取得了该值。
    E take() throws InterruptedException;

//在给定的时间里，从队列中获取值，时间到了直接调用普通的poll方法，为null则直接返回null。
    E poll(long timeout, TimeUnit unit)
        throws InterruptedException;

//获取队列中剩余的空间。
    int remainingCapacity();

//从队列中移除指定的值。
    boolean remove(Object o);

//判断队列中是否拥有该值。
    public boolean contains(Object o);

//将队列中值，全部移除，并发设置到给定的集合中。
    int drainTo(Collection<? super E> c);

//指定最多数量限制将队列中值，全部移除，并发设置到给定的集合中。
    int drainTo(Collection<? super E> c, int maxElements);
}
```

成员详解：
**ArrayBlockingQueue**
　　基于数组的阻塞队列实现，在ArrayBlockingQueue内部，维护了一个定长数组，以便缓存队列中的数据对象，这是一个常用的阻塞队列，除了一个定长数组外，ArrayBlockingQueue内部还保存着两个整形变量，分别标识着队列的头部和尾部在数组中的位置。
　　ArrayBlockingQueue在生产者放入数据和消费者获取数据，都是共用同一个锁对象，由此也意味着两者无法真正并行运行，这点尤其不同于LinkedBlockingQueue；按照实现原理来分析，ArrayBlockingQueue完全可以采用分离锁，从而实现生产者和消费者操作的完全并行运行。Doug Lea之所以没这样去做，也许是因为ArrayBlockingQueue的数据写入和获取操作已经足够轻巧，以至于引入独立的锁机制，除了给代码带来额外的复杂性外，其在性能上完全占不到任何便宜。 ArrayBlockingQueue和LinkedBlockingQueue间还有一个明显的不同之处在于，前者在插入或删除元素时不会产生或销毁任何额外的对象实例，而后者则会生成一个额外的Node对象。这在长时间内需要高效并发地处理大批量数据的系统中，其对于GC的影响还是存在一定的区别。而在创建ArrayBlockingQueue时，我们还可以控制对象的内部锁是否采用公平锁，默认采用非公平锁。

**LinkedBlockingQueue**
　　基于链表的阻塞队列，同ArrayListBlockingQueue类似，其内部也维持着一个数据缓冲队列（该队列由一个链表构成），当生产者往队列中放入一个数据时，队列会从生产者手中获取数据，并缓存在队列内部，而生产者立即返回；只有当队列缓冲区达到最大值缓存容量时（LinkedBlockingQueue可以通过构造函数指定该值），才会阻塞生产者队列，直到消费者从队列中消费掉一份数据，生产者线程会被唤醒，反之对于消费者这端的处理也基于同样的原理。而LinkedBlockingQueue之所以能够高效的处理并发数据，还因为其对于生产者端和消费者端分别采用了独立的锁来控制数据同步，这也意味着在高并发的情况下生产者和消费者可以并行地操作队列中的数据，以此来提高整个队列的并发性能。
作为开发者，我们需要注意的是，如果构造一个LinkedBlockingQueue对象，而没有指定其容量大小，LinkedBlockingQueue会默认一个类似无限大小的容量（Integer.MAX_VALUE），这样的话，如果生产者的速度一旦大于消费者的速度，也许还没有等到队列满阻塞产生，系统内存就有可能已被消耗殆尽了。

**DelayQueue**
　　DelayQueue中的元素只有当其指定的延迟时间到了，才能够从队列中获取到该元素。DelayQueue是一个没有大小限制的队列，因此往队列中插入数据的操作（生产者）永远不会被阻塞，而只有获取数据的操作（消费者）才会被阻塞。
使用场景：
　　DelayQueue使用场景较少，但都相当巧妙，常见的例子比如使用一个DelayQueue来管理一个超时未响应的连接队列。

**PriorityBlockingQueue**
　　基于优先级的阻塞队列（优先级的判断通过构造函数传入的Compator对象来决定），但需要注意的是PriorityBlockingQueue并不会阻塞数据生产者，而只会在没有可消费的数据时，阻塞数据的消费者。因此使用的时候要特别注意，生产者生产数据的速度绝对不能快于消费者消费数据的速度，否则时间一长，会最终耗尽所有的可用堆内存空间。在实现PriorityBlockingQueue时，内部控制线程同步的锁采用的是公平锁。

**SynchronousQueue**
　　一种无缓冲的等待队列，类似于无中介的直接交易，有点像原始社会中的生产者和消费者，生产者拿着产品去集市销售给产品的最终消费者，而消费者必须亲自去集市找到所要商品的直接生产者，如果一方没有找到合适的目标，那么对不起，大家都在集市等待。相对于有缓冲的BlockingQueue来说，少了一个中间经销商的环节（缓冲区），如果有经销商，生产者直接把产品批发给经销商，而无需在意经销商最终会将这些产品卖给那些消费者，由于经销商可以库存一部分商品，因此相对于直接交易模式，总体来说采用中间经销商的模式会吞吐量高一些（可以批量买卖）；但另一方面，又因为经销商的引入，使得产品从生产者到消费者中间增加了额外的交易环节，单个产品的及时响应性能可能会降低。
　　声明一个SynchronousQueue有两种不同的方式，它们之间有着不太一样的行为。公平模式和非公平模式的区别:
　　如果采用公平模式：SynchronousQueue会采用公平锁，并配合一个FIFO队列来阻塞多余的生产者和消费者，从而体系整体的公平策略；
　　但如果是非公平模式（SynchronousQueue默认）：SynchronousQueue采用非公平锁，同时配合一个LIFO队列来管理多余的生产者和消费者，而后一种模式，如果生产者和消费者的处理速度有差距，则很容易出现饥渴的情况，即可能有某些生产者或者是消费者的数据永远都得不到处理。

[参考链接:https://www.jianshu.com/p/6ba87c7508e4](https://www.jianshu.com/p/6ba87c7508e4)

阻塞队列还有更多实现类，用来满足各种复杂的需求：ArrayBlockingQueue, DelayQueue, LinkedBlockingQueue, PriorityBlockingQueue, SynchronousQueue，具体的API差别也很小。

---

#### Java线程：新特征-阻塞栈

对于阻塞栈，与阻塞队列相似。不同点在于栈是“后入先出”的结构，每次操作的是栈顶，而队列是“先进先出”的结构，每次操作的是队列头。
这里要特别说明一点的是，阻塞栈是Java6的新特征。
[BlockingDeque代码](https://github.com/TangSong99/Thread_Demo/tree/master/out/production/threaddemo/blocking)

---

#### Java线程：新特征-条件变量

条件变量是Java5线程中很重要的一个概念，顾名思义，条件变量就是表示条件的一种变量。但是必须说明，这里的条件是没有实际含义的，仅仅是个标记而已，并且条件的含义往往通过代码来赋予其含义。这里的条件和普通意义上的条件表达式有着天壤之别。他不是自然语言中的条件概念，而是程序控制的一种手段。

条件变量都实现了java.util.concurrent.locks.Condition接口，条件变量的实例化是通过一个Lock对象上调用newCondition()方法来获取的，这样，条件就和一个锁对象绑定起来了。因此，Java中的条件变量只能和锁配合使用，来控制并发程序访问竞争资源的安全。
条件变量的出现是为了更精细控制线程等待与唤醒，在Java5之前，线程的等待与唤醒依靠的是Object对象的wait()和notify()/notifyAll()方法，这样的处理不够精细。
而在Java5中，一个锁可以有多个条件，每个条件上可以有多个线程等待，通过调用await()方法，可以让线程在该条件下等待。当调用signalAll()方法，又可以唤醒该条件下的等待的线程。
[条件变方法](https://github.com/TangSong99/Thread_Demo/tree/master/out/production/threaddemo/condition)
[非条件变量方法](https://github.com/TangSong99/Thread_Demo/tree/master/out/production/threaddemo/uncondition)

---

#### Java线程：新特征-原子量

所谓的原子量即操作变量的操作是“原子的”，该操作不可再分，因此是线程安全的。
为何要使用原子变量呢，原因是多个线程对单个变量操作也会引起一些问题。在Java5之前，可以通过volatile、synchronized关键字来解决并发访问的安全问题，但这样太麻烦。
Java5之后，专门提供了用来进行单变量多线程并发安全访问的工具包 `java.util.concurrent.atomic`，其中的类也很简单。
原子量虽然可以保证单个变量在某一个操作过程的安全，但无法保证你整个代码块，或者整个程序的安全性。因此，通常还应该使用锁等同步机制来控制整个程序的安全性。

[atomicTest](https://github.com/TangSong99/Thread_Demo/tree/master/out/production/threaddemo/atomic)

原子仅仅是保证变量操作的原子性，但整个程序还需要考虑线程安全的。

---

#### Java线程：新特征-障碍器

Java5中，添加了障碍器类，为了适应一种新的设计需求，比如一个大型的任务，常常需要分配好多子任务去执行，只有当所有子任务都执行完成时候，才能执行主任务，这时候，就可以选择障碍器了。
障碍器是多线程并发控制的一种手段。

CyclicBarrier栅栏类似于闭锁，它能阻塞一组线程直到某个事件的发生。栅栏与闭锁的关键区别在于，**所有的线程必须同时到达栅栏位置，才能继续执行**。闭锁用于等待事件，而栅栏用于等待其他线程。
CyclicBarrier可以使一定数量的线程反复地在栅栏位置处汇集。当线程到达栅栏位置时将调用await方法，这个方法将阻塞直到所有线程都到达栅栏位置。如果所有线程都到达栅栏位置，那么栅栏将打开，此时所有的线程都将被释放，而栅栏将被重置以便下次使用。

CyclicBarrier默认的构造方法是CyclicBarrier(int parties)，其参数表示屏障拦截的线程数量，每个线程使用await()方法告诉CyclicBarrier我已经到达了屏障，然后当前线程被阻塞。
CyclicBarrier的另一个构造函数CyclicBarrier(int parties, Runnable barrierAction)，用于线程到达屏障时，优先执行barrierAction，方便处理更复杂的业务场景。
调用await方法的线程告诉CyclicBarrier自己已经到达同步点，然后当前线程被阻塞。直到parties个参与线程调用了await方法，CyclicBarrier同样提供带超时时间的await和不带超时时间的await方法。
[cyclicbarrier代码](https://github.com/TangSong99/Thread_Demo/tree/master/out/production/threaddemo/cyclicbarrier)

---

#### 不可不说的Java“锁”事

[【基本功】不可不说的Java“锁”事](https://mp.weixin.qq.com/s/g5WZbR711mIvsgjXdVAP3g)

#### 写在最后

相关的面试笔试题会另开一篇文章来更新。重新整理了文章的同时也对线程有了更深层次的理解。现在很多博客、公众号只会搬运，很多原文错漏之处全网竟找不到有人修改，现在的乱象就是如此，很多人都太浮躁了静不下心来好好写文章，很多人为了快速掌握都是选择找前人的文章，包括我也如此，所以在此也是惊醒自己，别人的东西要去消化去理解去修正，这样才能变成自己的东西。

Last modification：August 10, 2022

喵ฅฅ

3 comments

Inkedus
January 29th, 2020 at 03:12 pm

牛逼，，，牛逼

Reply
1. 唐宋丶
  January 29th, 2020 at 03:13 pm
  
  @Inkedus
  
  ୧(๑•̀⌄•́๑)૭
  
  Reply
Inkedus
January 29th, 2020 at 03:12 pm

牛逼，，，牛逼

Reply

[多线程]Java线程详解

唐宋丶 • 2020 年 01 月 19 日

整理了网上大部分java线程相关的知识，并加入一些自己的理解以及代码示例。

#### 线程概述

---

#### Java线程：创建与启动

##### 一、定义线程

**1、继承（extends）java.lang.Thread类。**
此类中有个run()方法，应该注意其用法：

```Java
    private Runnable target;

@Override
    public void run() {
        if (target != null) {
            target.run();
        }
    }
```

Thread的子类应该重写该方法，否则，该方法不执行任何操作并返回。

**2、实现（implements）java.lang.Runnable接口。**
源码如下：

```Java
@FunctionalInterface
public interface Runnable {
    public abstract void run();
}
```

##### 二、实例化线程

```Java
Thread thread= new Thread();
Thread runnable= new Thread(new Runnable(){
    @Override
    public void run() {
    ...
    }
);
```

一般用法：

```java
Thread thread = new Thread(this,threadName);
```

若继承Thread类或实现Runnable接口，只重写了 `run()`方法，那么只需要如下这般创建：

```java
Thread thread = new ThreadDemo();
Thread runnable = new Thread(new RunnableDemo());
```

##### 三、启动线程

当然直接调用Thread中的run()方法而不调用start()，程序也可以正常运行，但只是当成类中的方法调用，失去了线程的意义，具体区别如下：

##### 四、例子

##### 五、一些常见问题

2、线程都可以设置名字，也可以获取线程的名字，连主线程也不例外。
`thread = new Thread(this,threadName);`
`Thread.currentThread().getName();`

3、获取当前线程的对象的方法是：`Thread.currentThread();`

5、**当线程目标run()方法结束时该线程完成。**

6、一旦线程启动，它就永远不能再重新启动（死线程）。只有一个新的线程可以被启动，并且只能一次。

---

#### Java线程：线程栈模型与线程的变量

---

#### Java线程：线程状态的转换

##### 一、线程状态

##### 二、阻止线程执行

对于线程的阻止，考虑一下三个方面，不考虑IO阻塞的情况：
睡眠；
等待；
因为需要一个对象的锁定而被阻塞。

###### **1、睡眠sleep()**

###### **2、线程的优先级和线程让步yield()**

线程的让步是通过 `Thread.yield()`来实现的。yield()方法的作用是：暂停当前正在执行的线程对象，并执行其他线程。

设置线程的优先级：线程默认的优先级是创建它的执行线程的优先级。可以通过 `setPriority(int newPriority)`更改线程的优先级。例如：

```Java
        Thread t = new MyThread();
        t.setPriority(8);
        t.start();
```

**结论1：优先级高非先运行，只是获得cpu资源的可能性更大**。

**结论2：yield()从未导致线程转到等待/睡眠/阻塞状态。在大多数情况下，yield()将导致线程从运行状态转到可运行状态，但有可能没有效果**。

###### 3、join()方法

Thread的非静态方法join()让一个线程B“加入”到另外一个线程A的尾部。在A执行完毕之前，B不能工作。例如：

```Java
        Thread t = new MyThread();
        t.start();
        t.join();
```

**main方法运行thread.join(),这是会让主线程mian等待新的线程thread执行完了，再执行主线程mian下面的代码，thread.join()是然主线程main wait**。

##### 小结

到目前位置，介绍了线程离开运行状态的3种方法：

除了以上三种方式外，还有下面几种特殊情况可能使线程离开运行状态：

---

#### Java线程：线程的同步与锁

##### 一、同步问题提出

线程的同步是为了防止多个线程访问一个数据对象时，对数据造成的破坏（脏数据、脏读、不可重复读、幻读等）。

##### 二、同步和锁定

当程序运行到synchronized同步方法或代码块时该对象锁才起作用。

释放锁是指持锁线程退出了synchronized同步方法或代码块。

关于锁和同步，有一下几个要点：

```Java
/*同步方法*/
    public synchronized int getX() {
        return x++;
    }
```

当然，同步方法也可以改写为同步代码块，但功能完全一样的，例如：

```Java
/*同步代码块*/
    public int fix(int y) {
        synchronized (this) {
            x = x - y;
        }
        return x;
    }
```

与

```Java
/*同步代码块
优势：减小锁的粒度，提高性能。
*/
    public int getX() {
        synchronized (this) {
            return x++;
        }
    }
```

效果是完全一样的。

##### 三、静态方法同步

要同步静态方法，需要一个用于整个类对象的锁，这个对象是就是这个类（XXX.class)。

例如：

```Java
public static synchronized int setName(String name){
      Xxx.name = name;
}
```

等价于

```Java
public static int setName(String name){
      synchronized(Xxx.class){
            Xxx.name = name;
      }
}
```

##### 四、如果线程不能获得锁会怎么样

当考虑阻塞时，一定要注意哪个对象正被用于锁定：

##### 五、何时需要同步

在多个线程同时访问互斥（可交换）数据时，应该同步以保护数据，确保两个线程不会同时修改更改它。

对于非静态字段中可更改的数据，通常使用非静态方法访问。
对于静态字段中可更改的数据，通常使用静态方法访问。

##### 六、线程安全类

##### 七、线程死锁（涉及操作系统）

**死锁产生的必要条件：**
（1）互斥
（2）不剥夺
（3）请求和保持等待
（4）循环等待

**避免死锁：**

**总结：避免死锁的方式**

##### 八、线程同步小结

---

#### Java线程：线程的交互

##### 线程交互的基础知识

###### wait、notify/notifyAll 详解

wait() 需要被try catch包围，以便发生异常中断也可以使wait等待的线程唤醒。

###### notify 和 notifyAll的区别

**生产者-消费者问题:**
[生产者-消费者问题代码](https://github.com/TangSong99/Thread_Demo/tree/master/out/production/threaddemo/test/producer_consumer)

---

#### Java线程：线程的调度-休眠

---

#### Java线程：线程的调度-优先级

与线程休眠类似，线程的优先级仍然无法保障线程的执行次序。只不过，优先级高的线程获取CPU资源的概率较大，优先级低的并非没机会执行。

线程的优先级用1-10之间的整数表示，数值越大优先级越高，默认的优先级为5。

在一个线程中开启另外一个新线程，则新开线程称为该线程的子线程，子线程初始优先级与父线程相同。

---

#### Java线程：线程的调度-让步

线程的让步含义就是使当前运行着线程让出CPU资源，但是然给谁不知道，仅仅是让出，线程状态回到可运行状态。

线程的让步使用Thread.yield()方法，yield()为静态方法，功能是暂停当前正在执行的线程对象，并执行其他线程。

详见：Java线程：线程状态的转换——阻止线程执行

---

#### Java线程：线程的调度-合并

详见：Java线程：线程状态的转换——阻止线程执行
[joinTest](https://github.com/TangSong99/Thread_Demo/tree/master/out/production/threaddemo/test/join)

---

#### Java线程：线程的调度-守护线程

---

#### Java线程：线程的同步-同步方法、同步块

详见上文：Java线程：线程的同步与锁

---

#### Java线程：并发协作-死锁

详见Java线程：线程的同步与锁——线程死锁

---

#### Java线程：volatile关键字

**synchronized：可重入锁、互斥性、可见性**
**volatile 可以做到原子性，可见性，不能做到复合操作的原子性**

比如： volatile int i;
i++ 读取i的值，给i加1，把新的值赋值给i，这个i++操作在多线程环境下是无法保证原子性的

**volatile 的限制——只有在状态真正独立于程序内其他内容时才能使用 volatile**

详细说明请看此文章：[volatile 关键字的最全总结](https://mp.weixin.qq.com/s/snxOvuED1KvrOVexdsutSg)

---

#### Java线程：新特征-线程池

##### 一、固定大小的线程池

//创建一个可重用固定线程数的线程池
`ExecutorService pool = Executors.newFixedThreadPool(2); `

##### 二、单任务线程池

//创建一个使用单个 worker线程的 Executor，以无界队列方式来运行该线程。
`ExecutorService pool = Executors.newSingleThreadExecutor();`

##### 三、可变尺寸的线程池

//创建一个可根据需要创建新线程的线程池，但是在以前构造的线程可用时将重用它们。
`ExecutorService pool = Executors.newCachedThreadPool();`

##### 四、延迟连接池

##### 五、单任务延迟连接池

//创建一个单线程执行程序，它可安排在给定延迟后运行命令或者定期地执行。
`ScheduledExecutorService pool = Executors.newSingleThreadScheduledExecutor();`

##### 六、自定义线程池

##### 七、代码参考

---

#### Java线程：新特征-锁

**Lock：**
Lock实现提供了比使用synchronized方法和语句可获得的更广泛的锁定操作。

```Java
ReadWriteLock lock = new ReentrantReadWriteLock(false);
sync = fair ? new FairSync() : new NonfairSync();
```

注意：lock必须lock.unlock()释放，否则如果受保护的代码抛出异常，锁就可能永远得不到释放。

```Java
Lock lock = new ReentrantLock();
lock.lock();
try { 
  // update object state
}
finally {
  lock.unlock(); 
}
```

**关于ReentrantLock：**

**在实际开发中，最好能用读写锁的情况下使用读写锁，而不要用普通锁，以求更好的性能。**

[锁相关代码](https://github.com/TangSong99/Thread_Demo/tree/master/out/production/threaddemo/lock)

---

#### Java线程：新特征-信号量

[信号量代码](https://github.com/TangSong99/Thread_Demo/tree/master/out/production/threaddemo/semaphore)

---

#### Java线程：新特征-阻塞队列

[BlockingQueue代码](https://github.com/TangSong99/Thread_Demo/tree/master/out/production/threaddemo/blocking)

**BlockingQueue核心方法**

```Java
public interface BlockingQueue<E> extends Queue<E> {

//将给定元素设置到队列中，如果设置成功返回true, 否则返回false。如果是往限定了长度的队列中设置值，推荐使用offer()方法。
    boolean add(E e);

//将给定的元素设置到队列中，如果设置成功返回true, 否则返回false. e的值不能为空，否则抛出空指针异常。
    boolean offer(E e);

//将元素设置到队列中，如果队列中没有多余的空间，该方法会一直阻塞，直到队列中有多余的空间。
    void put(E e) throws InterruptedException;

//将给定元素在给定的时间内设置到队列中，如果设置成功返回true, 否则返回false.
    boolean offer(E e, long timeout, TimeUnit unit)
        throws InterruptedException;

//从队列中获取值，如果队列中没有值，线程会一直阻塞，直到队列中有值，并且该方法取得了该值。
    E take() throws InterruptedException;

//获取队列中剩余的空间。
    int remainingCapacity();

//从队列中移除指定的值。
    boolean remove(Object o);

//判断队列中是否拥有该值。
    public boolean contains(Object o);

//将队列中值，全部移除，并发设置到给定的集合中。
    int drainTo(Collection<? super E> c);

//指定最多数量限制将队列中值，全部移除，并发设置到给定的集合中。
    int drainTo(Collection<? super E> c, int maxElements);
}
```

[参考链接:https://www.jianshu.com/p/6ba87c7508e4](https://www.jianshu.com/p/6ba87c7508e4)

阻塞队列还有更多实现类，用来满足各种复杂的需求：ArrayBlockingQueue, DelayQueue, LinkedBlockingQueue, PriorityBlockingQueue, SynchronousQueue，具体的API差别也很小。

---

#### Java线程：新特征-阻塞栈

---

#### Java线程：新特征-条件变量

---

#### Java线程：新特征-原子量

[atomicTest](https://github.com/TangSong99/Thread_Demo/tree/master/out/production/threaddemo/atomic)

原子仅仅是保证变量操作的原子性，但整个程序还需要考虑线程安全的。

---

#### Java线程：新特征-障碍器

---

#### 不可不说的Java“锁”事

[【基本功】不可不说的Java“锁”事](https://mp.weixin.qq.com/s/g5WZbR711mIvsgjXdVAP3g)

#### 写在最后

3 comments

Leave a Comment Cancel reply

[多线程]Java线程详解