5个步骤，教你瞬间明白线程和线程安全

时间 2019-11-08

原文原文链接

在咱们的Java程序中其实有不止一条执行线程，只有当全部的线程都运行结束的时候，这个Java程序才算运行结束。官方的话给你描述一下：当全部的非守护线程运行结束时，或者其中一个线程调用了System.exit()方法时，这个Java程序才能运行结束。性能优化

什么是线程中断？架构

在咱们的Java程序中其实有不止一条执行线程，只有当全部的线程都运行结束的时候，这个Java程序才算运行结束。官方的话给你描述一下：当全部的非守护线程运行结束时，或者其中一个线程调用了System.exit()方法时，这个Java程序才能运行结束。并发

线程中断的应用场景分布式

咱们先来举一个例子，好比咱们如今在下载一个500多M的大片，咱们点击开始下载，那个这个时候就等于开启了一个线程去下载咱们的文件，然而这个时候咱们的网速不是很给力，几十KB的在这跑，做为一个年轻人我是等不了了，我不下来，那么这个时候咱们第一个操做就是结束掉这个下载文件的操做，其实更接近程序的来讲，这个时候咱们就须要把这个线程给中断了。函数

咱们接下来写一下这个下载的代码，看一下如何中断一个线程,这里我已经默认大家已经掌握了如何建立一个线程了，这段程序咱们模拟下载，最开始获取系统时间，而后进入循环每次获取系统时间，若是时间超过10秒咱们就中断线程，不在继续下载，下载速度时每秒1M：微服务

public void run() {
int number = 0;
// 记录程序开始的时间
Long start = System.currentTimeMillis();
while (true) {
// 每次执行一次结束的时间
Long end = System.currentTimeMillis();
// 获取时间差
Long interval = end - start;
// 若是时间超过了10秒，那么咱们就结束下载
if (interval >= 10000) {
// 中断线程
interrupted();
System.err.println("太慢了，我不下了");
return;
} else if (number >= 500) {
System.out.println("文件下载完成");
// 中断线程
interrupted();
return;
}
number++;
System.out.println("已下载" + number + "M");
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}

中断线程的方式高并发

Thread类中给咱们提供了中断线程的方法，咱们先来看下这个方法究竟是如何让线程中断的：源码分析

public static boolean interrupted() {
return currentThread().isInterrupted(true);
}

这个方法是检查当前线程是否被中断，中断返回true，未中断返回false性能

private native boolean isInterrupted(boolean ClearInterrupted);

经过查看源码咱们能够发现，中断线程就是经过调用检查线程是否被中断的方法，把值设为true。这个时候你再去调用检查线程是否中断的方法时就返回true了。学习

这里你们须要注意一个问题：Thread.interrupted()方法只是修改了当前线程的状态告诉他被中断了，可是对于非阻塞中的线程，只是改变了中断状态，即 Thread.isInterrupted()返回true，对于可取消的阻塞状态中的线程，例如等待在这些函数上的线程，Thread.sleep()，这个线程收到中断信号以后就会抛出InterruptedException异常，同时会把中断状态设置为true。

线程睡眠引发InterruptedException异常的缘由

其实这样说你们也是只知其一;不知其二，我就写一个错误的示例，你们来看一下，把这个问题完全的搞清楚：

public void run() {
int number = 0;
while (true) {
// 检查线程是否被中断，中断就中止下载
if (isInterrupted()) {
System.err.println("太慢了，我不下了");
return;
} else if (number >= 500) {
System.out.println("下载完成");
return;
}
number++;
System.out.println("已下载" + number + "M");
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}

这是咱们的主程序，等待10秒后中断线程

public static void main(String[] args) throws InterruptedException {
Thread thread = new PrimeGenerator();
// 启动线程
thread.start();
// 等待10秒后中断线程
Thread.sleep(1000);
// 中断线程
thread.interrupt();
}

看起来很一般的一个程序，可是事实却并不是你看到的样子，其实这段代码是会抛出InterruptedException异常的，咱们来分析缘由。

这里咱们先要了解Thread.interrupt()方法不会中断一个正在运行的线程，调用Thread.sleep()方法时，这个时候就再也不占用CPU，咱们来分析下咱们这个程序，咱们下载是要等待10秒，每次下载的速度是0.5M/S，也就是当咱们下载到5M的时候等待时间已经到了，这个时候调用Thread.interrupt()方法中断线程，可是run()方法中的睡眠还要接着往下执行，它是不会由于中断而放弃执行下面的代码的，那么这个时候当它再执行Thread.sleep()的时候就会抛出InterruptedException异常，由于当前的线程已经被中断了。

说到这里，你是否已经明白产生这个异常的缘由了？另外还有另外的两个缘由导致线程产生InterruptedException异常的缘由，wait()、join(）两个方法使用不当也会引发线程抛出该异常。

查看线程是否中断的两种方式

在Thread类中有一个方法interrupted()能够用来检查当前线程时候被中断，还有isInterrupted()方法能够用来检查当前线程是否被中断。

中断线程的方法其实底层就是将这个属性设置为true，isInterrupted()方法只是返回了这个属性值而已。

这两个方法有一个区别就是isInterrupted()不能改变interrupted()的属性值，可是interrupted()方法却能改变interrupted的属性值，因此在判断一个线程时候被中断的时候咱们更推荐使用isInterrupted()。

最后顺便给你们推荐一个Java架构方面的交流学习群：698581634，里面会分享一些资深架构师录制的视频录像：有Spring，MyBatis，Netty源码分析，高并发、高性能、分布式、微服务架构的原理，JVM性能优化这些成为架构师必备的知识体系，主要针对Java开发人员提高本身，突破瓶颈，相信你来学习，会有提高和收获。在这个群里会有你须要的内容朋友们请抓紧时间加入进来吧。