interruptthreaddemo3.java

java入门经典教程 java入门经典教程 java入门经典教程

// 例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...");
	}
}