上周写了一篇多线程的文章,其实更多方面是偏基础一点的文章,并且也比较大白话,争取人人都能看的明白,再举一些常见的例子,能很好的帮助你们理解多线程,文章发表以后我投给了几个大号和CSDN反应都挺好的,你们表示但愿能写更多这样的文章,但愿再多写写线程相关的文章,因此我打算从线程的基础开始写起,每周写那么两三篇,你们闲的时候能够看看,也能够多吸取一点东西。java
另外,但愿你们在阅读完以后能来个互动点赞什么的,也让我有点创做的动力,另外说说大家的想法什么的,我也好写出更好的文章来,废话很少说了,咱们开始今天的知识点学习吧!多线程
在咱们的Java程序中其实有不止一条执行线程,只有当全部的线程都运行结束的时候,这个Java程序才算运行结束。 官方的话给你描述一下:当全部的非守护线程运行结束时,或者其中一个线程调用了System.exit()方法时,这个Java程序才能运行结束。函数
咱们先来举一个例子,好比咱们如今在下载一个500多M的大片,咱们点击开始下载,那个这个时候就等于开启了一个线程去下载咱们的文件,然而这个时候咱们的网速不是很给力,几十KB的在这跑,做为一个年轻人我是等不了了,我不下来,那么这个时候咱们第一个操做就是结束掉这个下载文件的操做,其实更接近程序的来讲,这个时候咱们就须要把这个线程给中断了。学习
咱们接下来写一下这个下载的代码,看一下如何中断一个线程,这里我已经默认大家已经掌握了如何建立一个线程了,这段程序咱们模拟下载,最开始获取系统时间,而后进入循环每次获取系统时间,若是时间超过10秒咱们就中断线程,不在继续下载,下载速度时每秒1M: spa
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 code
private native boolean isInterrupted(boolean ClearInterrupted);
经过查看源码咱们能够发现,中断线程就是经过调用检查线程是否被中断的方法,把值设为true。这个时候你再去调用检查线程是否中断的方法时就返回true了。blog
这里你们须要注意一个问题:Thread.interrupted()方法只是修改了当前线程的状态告诉他被中断了,可是对于非阻塞中的线程,只是改变了中断状态,即 Thread.isInterrupted()返回true,对于可取消的阻塞状态中的线程,例如等待在这些函数上的线程 ,Thread.sleep(),这个线程收到中断信号以后就会抛出InterruptedException异常,同时会把中断状态设置为true。源码
其实这样说你们也是只知其一;不知其二,我就写一个错误的示例,你们来看一下,把这个问题完全的搞清楚:it
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()。