使用标志位

很简单地设置一个标志位，名称就叫做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{@Overridepublic 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 InterruptedExceptionif 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 {@Overridepublic 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，表示任务是否能够接收到中断。

• mayInterruptIfRunning=true时，任务如果在某个线程中运行，那么这个线程能够被中断；
• mayInterruptIfRunning=false时，任务如果还未启动，就不要运行它，应用于不处理中断的任务

要注意，mayInterruptIfRunning=true表示线程能接收中断，但线程是否实现了中断不得而知。线程要正确响应中断，才能真正被cancel。

线程池的shutdownNow()会尝试停止池内所有在执行的线程，原理也是发出中断请求。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。