Java中的多线程(四)之线程的停止 - JAVA

Java线程的停止，线程开启了，也许有时候我们需要停止线程的执行，总体来说，停止分两种，即：

1：正常停止，比如run方法执行完毕

2：非正常停止，可能被其它线程中断等等

OK，照例先看JDK中提供的方法

我们可以看到interrupt和stZ http://www.2cto.com/kf/ware/vc/" target="_blank" class="keylink">vcLe9t6i2vL/J0tTNo9a5z9+zzKOstavKx3N0b3DS0b6tsru9qNLpyrnTw8HLo6zO0sPHzL2+v8/CzqrKssO0sru9qNLpyrnTw8TYo7+/tNS0tPrC66O6CjxwcmUgY2xhc3M9"brush:java;"> @Deprecated public final synchronized void stop(Throwable obj) { if (obj == null) ......

我们可以看到，第一点stop是一个synchronized的方法，那么前面在说synchronized关键字时，说到，一个类中的synchronized方法是没办法调用到另外一个synchronized方法的，因为两者需要的锁是相同的，所以如果我们把run方法设置为了synchronized，那么调用stop是没办法停止线程的。那么我们应该如何做呢？

具体内容请参考http://docs.oracle.com/javase/1.5.0/docs/guide/misc/threadPrimitiveDeprecation.html，上面给我们提供了一些说明和替代方法。替代stop我们可以结合volatile和interrupt。

public class ThreadStopTest1 {
	public static void main(String[] args) throws Exception {
		MyThread1 t1 = new MyThread1();
		t1.startThread();
		Thread.sleep(3000);
		t1.stopThread();
	}
}
class MyThread1 extends Thread{
	private volatile boolean isRunning;
	
	public synchronized void startThread() {
		isRunning = true;
		this.start();
	}
	@Override
	public void run() {
		while(isRunning){
			//doSomething
			System.out.println("I am working");
			try {
				Thread.sleep(1000);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
		System.out.println("停止了");
	}
	public synchronized void stopThread() {
		isRunning = false;
	}
}

但是上面的程序是有问题的，因为其实质是在判断isRunning的值，如果轮询中的代码在wait、sleep时，其可能一直等待下去，这样，线程将无法停止，OK，我们加入interrupt，关于此关键字下一篇文章再说。修改代码如下：

public class ThreadStopTest2 {
	public static void main(String[] args) throws Exception {
		MyThread2 t1 = new MyThread2();
		t1.startThread();
		Thread.sleep(1000);
		t1.stopThread();
	}
}
class MyThread2 extends Thread{
	private volatile boolean isRunning;
	
	public synchronized void startThread() {
		isRunning = true;
		this.start();
	}
	@Override
	public void run() {
		long currentTime = System.currentTimeMillis();
		while(isRunning){
			System.out.println("I am working");
			try {
				Thread.sleep(10000);
			} catch (InterruptedException e) {
				System.out.println("运行了" + (System.currentTimeMillis()-currentTime) / 1000 + "秒");
			}
		}
		System.out.println("停止了");
	}
	public synchronized void stopThread() {
		isRunning = false;
		this.interrupt();
	}
}

这样即使代码在sleep或者wait时，我们强行调用interrupt使线程抛出异常，从而达到目的。但是其实它还是有问题的，即如果代码不是在wait或者sleep，比如serversocket的accept，它会阻塞等待，这时interrupt是无法中断线程的，看代码：

public class ThreadStopTest2 {
	public static void main(String[] args) throws Exception {
		MyThread2 t1 = new MyThread2();
		t1.startThread();
		Thread.sleep(1000);
		t1.stopThread();
	}
}
class MyThread2 extends Thread{
	private volatile boolean isRunning;
	
	public synchronized void startThread() {
		isRunning = true;
		this.start();
	}
	@Override
	public void run() {
		long currentTime = System.currentTimeMillis();
		while(isRunning){
			System.out.println("I am working");
			try {
				ServerSocket sc  = new ServerSocket(80);
				System.out.println("将一直在等待着......");
				sc.accept();
			} catch (Exception e) {
				System.out.println("运行了" + (System.currentTimeMillis()-currentTime) / 1000 + "秒");
			}
		}
		System.out.p

Java中的多线程(四)之线程的停止(一)