vc/mfc 2009-02-07 16:30:26 阅读 109 评论 0 字号： 大 中 小 订阅

如果一个线程由于等待某些事件的发生而被阻塞，又该如何实现该线程的中断呢？比如当一个线程由于需要等候键盘输入而被阻塞，处于不可运行状态时，即使主程序中将该线程的共享变量设置为true，但该线程此时根本无法检查循环标志，当然也就无法立即中断。

其实，这种情况经常会发生，比如调用Thread.join()方法，或者Thread.sleep()方法，在网络中调用ServerSocket.accept()方法，或者调用了DatagramSocket.receive()方法时，都有可能导致线程阻塞。即便这样，仍然不要使用stop()方法，而是使用Thread提供的interrupt()方法，因为该方法虽然不会中断一个正在运行的线程，但是它可以使一个被阻塞的线程抛出一个中断异常，从而使线程提前结束阻塞状态，退出堵塞代码。

下面看一个例子来说明这个问题：

// 例4.4.3  InterruptThreadDemo3.java

class MyThread extends Thread

{

volatile boolean stop = false;

public void run()

{

while(!stop)

{

System.out.println(getName()+" is running");

try

{

sleep(1000);

}catch(InterruptedException e){ 

System.out.println("week up from blcok...");

stop=true;     // 在异常处理代码中修改共享变量的状态

}

}

System.out.println(getName()+" is exiting...");

}

}

class InterruptThreadDemo3

{

public static void main(String[] args) throws InterruptedException

{

MyThread m1=new MyThread();

System.out.println("Starting thread...");

m1.start();

Thread.sleep(3000); 

System.out.println("Interrupt thread...:"+m1.getName());

m1.stop=true;      // 设置共享变量为true

m1.interrupt();  // 阻塞时退出阻塞状态

Thread.sleep(3000);  // 主线程休眠3秒以便观察线程m1的中断情况

System.out.println("Stopping application...");

}

}

程序中如果线程m1发生了阻塞，那么虽然执行了m1.stop=true;语句，但是stop的值并未改变。为了能够中断该线程，必须在异常处理语句中对共享变量的值进行重新设置，从而实现了在任何情况下都能够中断线程的目的。

一定要记住，m1.interrupt();语句只有当线程发生阻塞时才有效。它的作用就是抛出一个InterruptedException类的异常对象，使try…catch语句捕获异常，并对其进行处理。请读者仔细研究这个程序，以便能够看出其中的巧妙之处。