之前对操作系统和组成原理回顾了一下，又稍微理解了操作系统是怎样调度应用程序进程，以及CPU在这个过程中起到了什么作用。
在这里先以进程为引子，引出线程。
进程是操作系统能够看到的最小单位，也是就说，操作系统调度进程，把时间片分配给某个进程。如果这个进程在执行的时候阻塞了，比如他要执行I/O操作，那么他会执行系统调用，后面操作系统的代码会以内核态在CPU上执行，那么用户进程就处于阻塞状态了。
所谓阻塞，在用户看来就是"不可响应了"，比如正在执行I/O操作，用户怎么点这个界面都没反应。对于一个应用来说，他可不想这么快就陷入阻塞态，所以，他希望在执行I/O操作的时候也不会陷入阻塞操作，那么在时间片内，该进程还是可以继续执行代码，同时呢，CPU也在内核态帮他执行I/O操作，这就需要线程的帮助了。
对进程来说，I/O操作必须是异步的，CPU执行了进程的I/O操作后，还必须执行后面的指令。
线程是由JVM实现的，对应着CPU看到的就是跳转指令，也就是另外一条执行流。用java代码开启一个新的线程，在底层就是开启一条新的执行流。
那么，现在应该怎么理解线程呢？对进程来说，他相当于一个异步任务，对CPU来说，他是另外一条指令流。
计算机是一层层实现的，上层的高级抽象的概念都是由底层实现的，如果CPU不能执行跳转指令，那么上层可能也就没有多线程的概念了。
线程的创建
线程在java中是一个Thread类，当Thread类被启动时，它执行Runnable接口中的run()方法。如果Thread类没有对应的Runnable对象，那么什么也不做。
线程的结束
创建线程的目的是为了执行异步任务，如果任务执行完了，或者中途取消了，那么线程应该停止执行任务，毕竟，创建Thread类是需要耗费资源的，而资源是有限的。
java并没有一种方法能够立刻是线程结束，而线程能不能中断，是有所执行的方法决定的，如sleep()方法，也就是该方法每次都会检查标志位，判断线程是否被中断，如果被中断，则抛出中断异常。
所以，中断线程实际上是给线程设置一个中断标志位，而中断方法回去检查这个标志位，如果该方法响应了该方法，则抛出中断异常，然后结束线程的执行；而有的中断方法，可能太过重要，可以忽视中断标志位，继续执行。这是对中断整体的理解，后面就是各个中断方法的不同处理了。
1.run()方法正常结束
当run()方法正常结束，那么Thread后面会被Java虚拟机回收。
2.手动设置“标志位”中断非阻塞状态的进程
public void run() {
while (!cancelled){
//do something
}
}
问题：如果run方法中有阻塞方法，一旦陷入阻塞，如果条件得不到满足，那么"标志位"将永远不会得到检查，那么线程也就无法结束。
3.使用interrupt()中断非阻塞线程
如果run()方法中有阻塞方法，如wait,sleep方法，即使线程是阻塞状态，也会检查阻塞标志位，检测线程是否被阻塞，一旦阻塞标志位是true，则抛出InterruptedException异常。
interrupt()方法
一旦调用了该方法，相当于给线程设置了一个中断标志位,对于中断方法(如sleep)，他们会主动检查这个标志位；而如果没有阻塞方法，我们需要手动去检查。
isInterrupted()会检查线程的中断标志位
while (!Thread.currentThread().isInterrupted()) {
//do something
}
4.使用interrupt()中断 阻塞线程
所谓阻塞线程，这里指线程执行了阻塞方法，如sleep()。
当interrupt()方法被中断后，会设置该线程的中断标志位，如果线程此时处于阻塞状态(wait,sleep方法)，则interrupt状态被清除，抛出InterruptedException异常；如果线程正常执行，将会设置中断位,线程正常执行，知道它执行了阻塞方法，抛出InterruptedException异常。
public void run() { //注意try的位置
while (!Thread.currentThread().isInterrupted()) {
System.out.println("Thread running...");
try {
/*
* 如果线程阻塞，将不会去检查中断信号量stop变量，所 以thread.interrupt()
* 会使阻塞线程从阻塞的地方抛出异常，让阻塞线程从阻塞状态逃离出来，并
* 进行异常块进行 相应的处理
*/
Thread.sleep(1000);// 线程阻塞，如果线程收到中断操作信号将抛出异常
} catch (InterruptedException e) {
System.out.println("Thread interrupted...");
/*
* 如果线程在调用 Object.wait()方法，或者该类的 join() 、sleep()方法
* 过程中受阻，则其中断状态将被清除
*/
System.out.println(this.isInterrupted());// false
//中不中断由自己决定，如果需要真真中断线程，则需要重新设置中断位，如果
//不需要，则不用调
//如果这里不调用interrupt()方法，代码会接着执行
Thread.currentThread().interrupt();
}
}
System.out.println("Thread exiting under request...");
}
中断I/O操作
在网络操作中，对于阻塞的判定是需要考虑很多的，比如你的请求时间，你的响应时间，如果请求时间很长，而网络信号可能不好，用户处于等待状态，那么此时是不能算作I/O阻塞的，同样的道理可以用于服务器响应。
对应到java语言中，实现了InterruptibleChannel接口的通道是可中断的，也就是说，实现了InterruptibleChannel的方法会主动去检测中断标志位，其逻辑和sleep()方法一样，只是抛出了ClosedByInterruptException异常。
不抛出InterruptedException异常的I/O阻塞方法
InputStream的read()方法
API里对read()方法的解释是，如果已经到达流末尾而没有可用的字节，则返回-1。在输入数据可用、检测到流末尾或者抛出异常前，此方法一直阻塞。而Socket在关闭之前是不会关闭流的，所以read()方法就不知道什么时候到达流末尾，就会一直阻塞。
解决办法:服务器在发送完数据后关闭输出流
网友评论