java多线程之停止线程

在多线程开发中停止线程是非常重要的技术点。

停止线程在Java语言中并不像break语句那样干脆。须要一些技巧性的处理。

一、  异常法

採用异常法来停止一个线程。首先我们须要了解一下两个方法的使用方法：

1、interrupt()方法

public class MyThread extends Thread{
	@Override
	public void run() {
		for (int i = 1; i <= 10000; i++) {
			System.out.println("i="+i);
		}
	}
	public static void main(String[] args)throws Exception {
		MyThread thread=new MyThread();
		thread.start();
		thread.sleep(10);
		thread.interrupt();
	}
}

上面的样例调用interrupt()方法来停止线程，但interrupt()方法的使用效果并不像for+break语句那样。立即就能停止循环。

调用interrupt()方法不过在当前线程打了一个停止的标记，并非真的停止。那么假设停止线程了？我们接着往以下看。

2、推断线程是否是停止状态

1)、  interrupted()

public class MyThread extends Thread{
	@Override
	public void run() {
		for (int i = 1; i <= 10000; i++) {
			System.out.println("i="+i);
		}
	}
	public static void main(String[] args)throws Exception {
		try{
			MyThread thread=new MyThread();
			thread.start();
			thread.sleep(100);
			thread.interrupt();
			System.out.println("线程停止了吗1？--->"+thread.interrupted());
			System.out.println("线程停止了吗2？--->"+thread.interrupted());
		}catch(Exception e){
			e.printStackTrace();
		}
		System.out.println("end");
		
	}
}

从控制台打印的结果来看，线程没有停止。这就是说，interrupted()測试当前线程是否中断，由于这个当前线程就是main。它没有中断过，所以打印的结果是两个false。

怎样使main线程产生中断效果了。我们在看下，以下的样例：

public class MyThread{
	public static void main(String[] args){
		Thread.currentThread().interrupt();
		System.out.println("线程停止了吗1？---->"+Thread.interrupted());
		System.out.println("线程停止了吗2？---->"+Thread.interrupted());
		System.out.println("end");
	}
}

从上面的结果来看。interrupted()方法的确推断当前线程是否是停止状态。

可是为什么第2个值是false。原来。连续两次调用该方法第一次会清除中断状态后。第二次调用所以返回flase。

2)、  isInterrupted()

public class MyThread extends Thread{
	@Override
	public void run() {
		for (int i = 1; i <= 10000; i++) {
			System.out.println("i="+i);
		}
	}
	public static void main(String[] args){
		try{
			MyThread thread=new MyThread();
			thread.start();
			thread.sleep(10);
			thread.interrupt();
			System.out.println("线程停止了吗1？--->"+thread.isInterrupted());
			System.out.println("线程停止了吗2？--->"+thread.isInterrupted());
		}catch(Exception e){
			e.printStackTrace();
		}
		System.out.println("end");
		
	}
}

从结果看出方法isInterrupted()并未清除，所以打印出了两个true.

3、停止线程

public class MyThread extends Thread{
	@Override
	public void run() {
		for (int i = 1; i <= 10000; i++) {
			if(this.interrupted()){
				System.out.println("线程是停止状态了,我要退出了.");
				break;
			}
			System.out.println("i="+i);
		}
		System.out.println("假设此处还是循环,那么我就会继续运行.线程并没有停止");
	}
	public static void main(String[] args){
		try{
			MyThread thread=new MyThread();
			thread.start();
			thread.sleep(10);
			thread.interrupt();
			System.out.println("end");
		}catch(Exception e){
			e.printStackTrace();
		}
	}
}

假设这么写的话，线程并没有停止。如今我们在改动下代码。也就是所谓的异常法停止线程。

public class MyThread extends Thread{
	@Override
	public void run() {
		try{
			for (int i = 1; i <= 10000; i++) {
				if(this.interrupted()){
					System.out.println("线程是停止状态了,我要退出了.");
					throw new InterruptedException();
				}
				System.out.println("i="+i);
			}
			System.out.println("我被运行了吗？");
		}catch(InterruptedException e){
			System.out.println("---这次线程停了---");
			e.printStackTrace();
		}
	}
	public static void main(String[] args){
		try{
			MyThread thread=new MyThread();
			thread.start();
			thread.sleep(10);
			thread.interrupt();
			System.out.println("end");
		}catch(Exception e){
			e.printStackTrace();
		}
	}
}

二、  在沉睡中停止

假设线程在sleep()状态下停止线程会有什么效果了？

public class MyThread extends Thread{
	@Override
	public void run() {
		try{
			System.out.println("run start");
			Thread.sleep(1000000);
			System.out.println("run end");
		}catch(InterruptedException e){
			System.out.println("sleep被停止，状态:--->"+this.isInterrupted());
			e.printStackTrace();
		}
	}
	public static void main(String[] args){
		try{
			MyThread thread=new MyThread();
			thread.start();
			thread.interrupt();
			thread.sleep(1000);
		}catch(Exception e){
			System.out.println("main catch");
			e.printStackTrace();
		}
	}
}

从结果我们能够看出，在线程睡眠时候停止某一线程，会异常。而且清除停止状态。我们前面异常停止线程，都是先睡眠，在停止线程，与之相反的操作，我写代码的时候须要注意下。

public class MyThread extends Thread{
	@Override
	public void run() {
		try{
			for (int i = 1; i <= 10000; i++) {
				System.out.println("i="+i);
			}
			System.out.println("run start");
			Thread.sleep(1000000);
			System.out.println("run end");
		}catch(InterruptedException e){
			System.out.println("线程被停止了。在sleep，状态:--->"+this.isInterrupted());
			e.printStackTrace();
		}
	}
	public static void main(String[] args){
		try{
			MyThread thread=new MyThread();
			thread.start();
			thread.interrupt();
		}catch(Exception e){
			System.out.println("main catch");
			e.printStackTrace();
		}
	}
}

三、  暴力停止

public class MyThread extends Thread{
	private int i=0;
	@Override
	public void run() {
		try{
			while (true) {
				i++;
				System.out.println("i="+i);
				Thread.sleep(1000);
			}
		}catch(Exception e){
			e.printStackTrace();
		}
	}
	public static void main(String[] args){
		try{
			MyThread thread=new MyThread();
			thread.start();
			Thread.sleep(6000);
			thread.stop();
		}catch(Exception e){
			e.printStackTrace();
		}
	}
}

stop()方法已经被弃用，假设强制让线程停止。能够会有一些清理工作没得到完毕。还有就是对锁定的对象进行了解锁，导致数据不同步的现象，所以开发时候禁止使用该方法去暴力停止线程。

四、  使用return停止线程

public class MyThread extends Thread{
	private int i=0;
	@Override
	public void run() {
		try{
			while (true) {
				i++;
				if(this.interrupted()){
					System.out.println("线程停止了");
					return;
				}
				System.out.println("i="+i);
			}
		}catch(Exception e){
			e.printStackTrace();
		}
	}
	public static void main(String[] args){
		try{
			MyThread thread=new MyThread();
			thread.start();
			Thread.sleep(2000);
			thread.interrupt();
		}catch(Exception e){
			e.printStackTrace();
		}
	}
}

PS:只是还是建议使用异常法来停止线程，由于在catch块中还能够将异常向上抛，使线程停止事件得到传播。