package old.interruptThread.model;

/**
 * 线程关闭模型2 
 * 宗旨：外部线程通知该线程中断，该线程自行业务结束 
 * 存在阻塞的循环业务操作，如Thread.sleep(),Thread.wait(),Thread.join() 等
 * 外部线程执行thread.interrupt();该线程会抛出异常InterruptedException
 * 即 须要增加对该异常的捕捉处理
 * 
 * @date Feb 21, 2013 10:30:53 AM
 * @author ZhangGang
 * 
 */
public class SimpleModel2 implements Runnable{
volatile boolean stop = false;

public static void main(String[] args) throws Exception {
	Thread thread = new Thread(new SimpleModel2(), "My Thread2");
	System.out.println("Starting thread...");
	thread.start();
	Thread.sleep(4000);
	System.out.println("Interrupting thread...");
	thread.interrupt(); //等同于 future.cancel(true) ;
	System.out.println("线程是否中断：" + thread.isInterrupted());
	Thread.sleep(3000);
	System.out.println("Stopping application...");
}

public void run() {
	while (!stop && true) {
		
		/* 模拟睡眠1秒操作 替换为完整的业务 */
		long time = System.currentTimeMillis();
		while ((System.currentTimeMillis() - time < 1000)) {
		}
		
		/**
		 * Thread.currentThread().isInterrupted() 为获取线程中断状态，获取后不改变状态值
		 * ps：catch(InterruptedException e)异常捕获 上面的取值会改变为false
		 */
		System.out.println("My Thread is running... isInterrupted? "+Thread.currentThread().isInterrupted());

		if (Thread.currentThread().isInterrupted()) { // 该值为读取 线程中断状态，不会改变中断状态的值
			System.out.println("结束线程...");
			stop = true;
		}
		
		try {
			Thread.sleep(1);	//sleep 
		} catch (InterruptedException e) {
			e.printStackTrace();
			//异常被捕获后 Thread.currentThread().isInterrupted() 值 将变为false
			System.out.println("结束线程1...?"+Thread.currentThread().isInterrupted());
			Thread.currentThread().interrupt();
			System.out.println("结束线程2...?"+Thread.currentThread().isInterrupted());
			stop = true;
		}
		//线程中断操作 循环中使用 --End
	}
	
	System.out.println("My Thread exiting under request...");
}
}