`

与InterruptedException相关的知识点

阅读更多

可能会花一些时间,但是可以取消掉

 

   在编写多线程程序时,我们都会习惯去看看方法后是否跟着throws InterruptedException.当方法后面跟着throws InterruptedException时,表示这个方法内可能会抛出InterruptedException异常.

   这通常暗示了我们两个信息:


  1.    这是"需要花费点时间"的方法
  2.    这是"可以取消"

后面接着throws InterruptedExceptoin的方法


   Java中,有三种方法再调用时是必须声明抛出InterruptedException的


  1.      Object类的wait方法
  2.      Thread类的sleep方法
  3.      Thread类的join方法

 

◆需要花费点时间的方法


  1.     执行wait方法的线程,会进入等待区等待被notify/notifyAll.在等待期间,线程是不会活动的!因此需要花费等待notify/notifyAll的时间.
  2.     执行sleep方法的线程,会暂停执行参数内所设置的时间,这也是需要花费时间的.
  3.     执行join方法的线程,需要等待到指定线程结束为止.也是需要花费时间知道指定线程结束为止.

 

◆可以取消的方法


     因为需要花费时间的操作,会降低程序的响应速度,所以我们会希望像下面一样可以在中途放弃执行这个方法.


  1.      取消wait方法等待notify/notifyAll的操作
  2.      取消sleep方法等待设置长度时间的操作
  3.      取消join方法等待其它线程结束的操作

     而恰恰Thraed类中的Interrupt方法就能完成这样的操作.

 

Sleep(),Wait(),Join()分别与Interrupt()的关系

 

Sleep方法与Interrupt方法

  以下面的例子为例

     /**

 * 模拟线程读取文件
 * @author manming
 *
 */


public class FileThread extends Thread {

	private static Thread waitThread = null; //用于保存处于等待状态的线程实例


	
	public void run(){
		if(waitThread !=null){	// 当等待线程不为空时,中断等待线程


			waitThread.interrupt();
		}else{	//当等待线程为空时,执行读取操作


			try {
				read();
			} catch (InterruptedException e) {
				System.out.println("线程被中断...");
			}
		}
	}
	public void read() throws InterruptedException{
		/* 模拟读取文件时出现堵塞,让线程睡眠等待若干时间 */	

	
		waitThread = Thread.currentThread(); // 保存当前线程为等待线程


		Thread.sleep(10000000);
	}
	
	public static void main(String[] args) {
		
                //创建两个线程对象


		FileThread  t1 = new FileThread ();
		t1.start();
		FileThread  t2 = new FileThread ();
		t2.start();
	}
}

 
   上面的例子中,当线程对象t1进入run方法后,首先调用read()方法,t1线程保存为等待线程并进入睡眠状态.此时,如果我们想取消t1线程的等待状态(等待的时间可能无法估计).因为线程t1暂停着,所以取消操作必须由其它线程来执行.因此,我们创建了第二个线程t2,当t2进入run方法后,发现t1被设置为等待线程了,因此调用了waitThread.interrupt();(这里waitThread==t1).要求t1放弃等待操作.

   在这里使用的interrupt方法,是Thread类的实例方法.执行interrupt方法时,不需要获取Thread实例的锁定.任何线程在任何时刻,都可以调用其它线程的interrupt方法.

   当sleep方法的线程被调用interrupt方法时,就会放弃暂停的状态,并抛出InterruptedException.

 

Wait方法与interrupt方法

 

   同样以上一个例子为例,当t1以wait方法等待时,与sleep一样可以取消.使用interrupt方法,可以对wait中的线程传达"不用等notify/notifyAll了,从等待中出来"的信号.

   但是当线程wait时,有一点需要注意的,那就是锁的问题.线程进入等待状态时,会将自己拥有的锁释放,当对wait中的线程调用interrupt方法是,等待线程会重新获取锁,然后再抛出interruptedException.获取锁定之前,并无法抛出InterruptedException异常.

 

Join方法与interrupt方法

 

   当线程以join方法等待其它线程结束时,一样可以使用interrupt方法取消.因为调用join方法不需要获取锁定.

 

interrupt方法只是改变中断状态而已


   或许有很多人都是这样认为的,当调用了interrupt方法后,目的线程就会抛出InterruptedExceptoin异常,但其实是误解.事实上,interrupt这个方法改变线程的中断状态而已.

   所谓中断状态,是用来表示这个线程有没有被中断的状态.

   当线程A在执行sleep,wait,join时,另一个线程B调用了interrupt方法,的确这个时候线程A会有InterruptedException异常抛出.但这其实是在sleep,wait,join这些方法内部会不断检查中断状态的值,而自己抛出的InterruptedException.

   如果线程A正在执行一些复杂的计算,那么,就算此时线程B调用A的interrupt方法,线程A也不会抛出InterruptedException异常,而会继续处理自己后续的操作.当线程执行到sleep,wait,join这些方法,或是没有在线程里自己检查中断状态,自己抛出InterruptedException,那InterruptedException是不会被抛出的.

 

isInterrupted方法 -- 检查中断状态

 

   Thread类的实例方法isInterrupted方法可用来检查指定线程的中断状态.当线程为中断状态时,会返回true;而线程为不是中断状态时,会返回false.isInterrupted不会自己改变中断状态.

 

Thread.interrupted方法 -- 检查并清除中断状态


   而Thread.interrupted方法会检查线程的中断状态,并清除线程的状态.当线程的线程为中断状态时,就返回true,若非中断状态时,则返回false.调用Thread.interrupted方法后,中断状态会被清除.

   除了这个方法以外,没有其它用来清除中断状态的方法.Thread.interrupted方法检查的对象是现在的线程,所以我们无法清除其它线程的中断状态.

 

 

 

分享到:
评论

相关推荐

    Java理论与实践:处理InterruptedException

    但是编译器或IDE报错说没有处理检查到的InterruptedException。对于InterruptedException,一种常见的处理方式是“生吞” 它,然后什么也不做。本文还介绍了用Java平台提供的协作中断机制来构造灵活的取消策略。各...

    处理 InterruptedException1

    处理 InterruptedException1

    JAVA InterruptedException

    NULL 博文链接:https://pingfang.iteye.com/blog/1124433

    Java处理InterruptedException异常的理论与实践

    在使用Java的过程中,有个情景或许很多人见过,您在编写一个测试程序...但是编译器或 IDE 报错说没有处理检查到的 InterruptedException。InterruptedException 是什么呢,为什么必须处理它?下面跟着小编一起来看看。

    InterruptedException和interrup

    InterruptedException和interruptingthreads的一些说明编程开发技术共5页.pdf.zip

    [bugfix]重新理解Thread的InterruptedException

    NULL 博文链接:https://sw1982.iteye.com/blog/654409

    Java检测线程中断状态的方法示例

    主要介绍了Java检测线程中断状态的方法,结合实例形式分析了java针对线程中断状态检测的相关实现技巧,需要的朋友可以参考下

    飞机大战java源码

    public static void main String args[] throws InterruptedException { MainFrame mainFrame; try { mainFrame new MainFrame ; mainFrame loadGame ; } catch Exception e { e printStackTrace ; } }...

    java开发飞机大战(可运行)

    public static void main String args[] throws InterruptedException { MainFrame mainFrame; try { mainFram e new MainFrame ; mainFrame loadGame ; } catch Exception e { e printStackTrace ; } } }...

    大数据平台构建:一个简单的MapReduce程序.pptx

    public void reduce(Text key, Iterable<IntWritable> values, Context context) throws IOException, InterruptedException {…} 二、代码实现 对于main函数的调用。 Main方法的实现 Configuration conf = new ...

    java中redis锁的封装

    public Object onGetLock() throws InterruptedException { //拿到锁,进行处理,返回结果【result】 return true; } @Override public Object onTimeout() throws InterruptedException { //没拿到锁,返回...

    空指针异常

    对空指针异常进行举例,并对实例进行解释,

    操作系统写者优先程序

    } catch (InterruptedException e) { e.printStackTrace(); } if(writercount==1){ try { sem.acquire(); //拿到对sem的控制权 } catch (InterruptedException e) { e....

    concurrent 多线程 教材

    j-concurrent 00 IBM developerWorks 中国 : Java 多线程与并发编程专题 ...36 Java 理论与实践 处理 InterruptedException.mht 37 Java 理论与实践 正确使用 Volatile 变量.mht 38 使用泛型和并发改善集合.mht

    一个简单的发送线程与接收线程实例

    } catch(InterruptedException e) { System.out.println(e.getMessage()); } } } public static void main(String args[]) { buffer1 bf=new buffer1(); (new sender1(bf)).start(); (new receiver1(bf)).start(); ...

    揭密FutureTask.docx

    Future Future是一个接口,它定义了5个方法: boolean cancel(boolean mayInterruptIfRunning);...V get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException;

    线程超时死掉

    参数timeout指定超时时间,uint指定时间的单位,在枚举类TimeUnit中有相关的定义。如果计 算超时,将抛出TimeoutException Future的实现类有java.util.concurrent.FutureTask即 javax.swing.SwingWorker,V>。通常...

    java多线程机制 -- 源码详解

    catch(InterruptedException e){} } } } class Righthand extends Thread { public void run() { for(int I=0;I;I++) { System.out.println("I am oookkk"); try{sleep(300);} catch...

    多线程实例 有讲解

    多线程实例 生产者、消费者有讲解 下面是其中一小部分代码 ... } catch (InterruptedException e) { e.printStackTrace(); } } this.c = c; isProduced = true; // 标记已经生产 notify(); } // 同步方法

    AsyncTask Demo

    // protected Void doInBackground(Void... params) { // int count = 0; // while (count ) { ...// } catch (InterruptedException e) { // e.printStackTrace(); // } // } // return null; // }

Global site tag (gtag.js) - Google Analytics