如何正确的结束Java线程

如何正确的结束Java线程？很多新手对此不是很清楚，为了帮助大家解决这个难题，下面小编将为大家详细讲解，有这方面需求的人可以来学习下，希望你能有所收获。

成都创新互联公司2013年成立，是专业互联网技术服务公司，拥有项目成都网站制作、网站设计网站策划，项目实施与项目整合能力。我们以让每一个梦想脱颖而出为使命，1280元鄂伦春做网站,已为上家服务,为鄂伦春各地企业和个人服务,联系电话:13518219792

使用标志位

很简单地设置一个标志位，名称就叫做isCancelled。启动线程后，定期检查这个标志位。如果isCancelled=true，那么线程就马上结束。

public class MyThread implements Runnable{
private volatile boolean isCancelled;
public void run(){
while(!isCancelled){
//do something
}
}
public void cancel(){ isCancelled=true; }
}

注意的是，isCancelled需要为volatile，保证线程读取时isCancelled是最新数据。
我以前经常用这种简单方法，在大多时候也很有效，但并不完善。考虑下，如果线程执行的方法被阻塞，那么如何执行isCancelled的检查呢？线程有可能永远不会去检查标志位，也就卡住了。

使用中断

Java提供了中断机制，Thread类下有三个重要方法。

public void interrupt()
public boolean isInterrupted()
public static boolean interrupted(); // 清除中断标志，并返回原状态

每个线程都有个boolean类型的中断状态。当使用Thread的interrupt()方法时，线程的中断状态会被设置为true。
下面的例子启动了一个线程，循环执行打印一些信息。使用isInterrupted()方法判断线程是否被中断，如果是就结束线程。

public class InterruptedExample {
public static void main(String[] args) throws Exception {
InterruptedExample interruptedExample = new InterruptedExample();
interruptedExample.start();
}
public void start() {
MyThread myThread = new MyThread();
myThread.start();
try {
Thread.sleep(3000);
myThread.cancel();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
private class MyThread extends Thread{
@Override
public void run() {
while (!Thread.currentThread().isInterrupted()) {
try {
System.out.println("test");
Thread.sleep(1000);
} catch (InterruptedException e) {
System.out.println("interrupt");
//抛出InterruptedException后中断标志被清除，标准做法是再次调用interrupt恢复中断
Thread.currentThread().interrupt();
}
}
System.out.println("stop");
}
public void cancel(){
interrupt();
}
}
}

对线程调用interrupt()方法，不会真正中断正在运行的线程，只是发出一个请求，由线程在合适时候结束自己。

例如Thread.sleep这个阻塞方法，接收到中断请求，会抛出InterruptedException，让上层代码处理。这个时候，你可以什么都不做，但等于吞掉了中断。因为抛出InterruptedException后，中断标记会被重新设置为false！看sleep()的注释，也强调了这点。

@throws InterruptedException
if any thread has interrupted the current thread. 
The interrupted status of the current thread is 
cleared when this exception is thrown.
public static native void sleep(long millis) throws InterruptedException;

记得这个规则：什么时候都不应该吞掉中断！每个线程都应该有合适的方法响应中断！

所以在InterruptedExample例子里，在接收到中断请求时，标准做法是执行Thread.currentThread().interrupt()恢复中断，让线程退出。

从另一方面谈起，你不能吞掉中断，也不能中断你不熟悉的线程。如果线程没有响应中断的方法，你无论调用多少次interrupt()方法，也像泥牛入海。

用Java库的方法比自己写的要好

自己手动调用interrupt()方法来中断程序，OK。但是Java库提供了一些类来实现中断，更好更强大。

Executor框架提供了Java线程池的能力，ExecutorService扩展了Executor，提供了管理线程生命周期的关键能力。其中，ExecutorService.submit返回了Future对象来描述一个线程任务，它有一个cancel()方法。

下面的例子扩展了上面的InterruptedExample，要求线程在限定时间内得到结果，否则触发超时停止。

public class InterruptByFuture {
public static void main(String[] args) throws Exception {
ExecutorService es = Executors.newSingleThreadExecutor();
Future<?> task = es.submit(new MyThread());
try {
//限定时间获取结果
task.get(5, TimeUnit.SECONDS);
} catch (TimeoutException e) {
//超时触发线程中止
System.out.println("thread over time");
} catch (ExecutionException e) {
throw e;
} finally {
boolean mayInterruptIfRunning = true;
task.cancel(mayInterruptIfRunning);
}
}
private static class MyThread extends Thread {
@Override
public void run() {
while (!Thread.currentThread().isInterrupted()) { 
try {
System.out.println("count");
Thread.sleep(1000);
} catch (InterruptedException e) {
System.out.println("interrupt");
Thread.currentThread().interrupt();
}
}
System.out.println("thread stop");
}
public void cancel() {
interrupt();
}
}
}

Future的get方法可以传入时间，如果限定时间内没有得到结果，将会抛出TimeoutException。此时，可以调用Future的cancel()方法，对任务所在线程发出中断请求。
cancel()有个参数mayInterruptIfRunning，表示任务是否能够接收到中断。