Welcome 微信登录

首页 / 软件开发 / JAVA / java的线程机制(二) Thread的生命周期

java的线程机制(二) Thread的生命周期2013-12-07 cnblogs 文酱之前讲到Thread的创建,那是Thread生命周期的第一步,其后就是通过start()方法来启动Thread,它会 执行一些内部的管理工作然后调用Thread的run()方法,此时该Thread就是alive(活跃)的,而且我们还可以通 过isAlive()方法来确定该线程是否启动还是终结。

一旦启动Thread后,我们就只能执行一个方 法:run(),而run()方法就是负责执行Thread的任务,所以终结Thread的方法很简单,就是终结run()方法。仔 细查看文档,我们会发现里面有一个方法:stop(),似乎可以用来停止Thread,但是这个方法已经被废除了, 因为它存在着内部的竞争。

我们经常需要一个不断执行的Thread,然后在某个特定的条件下才会终结 它,方法有很多,但最常用的有设定标记和中断Thread两种方式。

我们将之前例子中的Thread改写一 下:

public class RandomCharacterGenerator extends Thread implements CharacterSource {static char[] chars;static String charArray = "abcdefghijklmnopqrstuvwxyz0123456789";static {chars = charArray.toCharArray();}private volatile boolean done = false;Random random;CharacterEventHandler handler;public RandomCharacterGenerator() {random = new Random();handler = new CharacterEventHandler();}public int getPauseTime() {return (int) (Math.max(1000, 5000 * random.nextDouble()));}@Overridepublic void addCharacterListener(CharacterListener cl) {handler.addCharacterListener(cl);}@Overridepublic void removeCharacterListener(CharacterListener cl) {handler.removeCharacterListener(cl);}@Overridepublic void nextCharacter() {handler.fireNewCharacter(this,(int) chars[random.nextInt(chars.length)]);}public void run() {while(!done){nextCharacter();try {Thread.sleep(getPauseTime());} catch (InterruptedException ie) {return;}}}public void setDone(){done = true;}}
现在我们多了一个标记:done,这样我们就可以在代码中通过调用setDone()来决定什么时候停止 该Thread。这里使用了volatile关键字,它主要是为了同步。这点会放在同步这里讲。

设定标记的最大问 题就是我们必须等待标记的状态,这样就会造成延迟。当然,这种延迟是无法避免的,但必须想办法缩短到最 小。于是,中断Thread这种方法就有它的发挥地方了。

我们可以通过interrupt()方法来中断Thread, 该方法会造成两个副作用:

1.它会导致任何的阻塞方法都会抛出InterruptedException,我们必须强 制性的捕获这个错误哪怕我们根本就不需要处理它,这也是java的异常处理机制让人诟病的一个地方。

2.设定Thread对象内部的标记来指示此Thread已经被中断了,像是这样:

public void run(){ while(!isInterrupted()){...}}
虽然无法避免延迟,但是延迟已经被缩短了。

无论是采用标记还是中断的方法,我们之所以无 法消除延迟的原因是我们无法确定是检查标记先还是调用方法先,这就是所谓的race condition,是线程处理 中永远无法避免的话题。

Thread不仅可以被终结,还可以暂停,挂起和恢复。

Thread原本有 suspend()方法和resume()方法来执行挂起和恢复,但它们和stop()出于同样的原因,都被废除了。

我 们可以通过sleep()方法来挂起Thread,当在指定的时间后,它就会自动恢复。严格意义上讲,sleep并不等同 于suspend,真正的suspend应该是由一个线程来挂起另一个线程,但是sleep只会影响当前的Thread。要想真 正实现挂起和恢复,我们可以使用等待和通知机制,但这个机制最大的问题就是我们的Thread必须使用该技术 来编写。

Thread在终结后,如果有可能,我们还需要对它进行善后。即使Thread已经被终结了,但是 其他对象只要还持有它的引用,它们就可以调用该Thread的资源,这也会导致该Thread无法被回收。

但我们有时候还是希望继续保持该Thread的引用,因为我们想要判别它是否真的已经完成了工作,可以使用 join()方法。join()方法会被阻塞住直到Thread完成它的run()方法,但是这个存在风险:第一次对join()方 法的调用可能会一直被阻塞住很长时间直到Thread真正完成,所以,一般情况下我们还是使用isAlive()方法 来判断。

由于我们可以通过实现一个Runnable接口来定义我们的任务,所以在判断所在线程是否已经 中断的时候,就有一个问题:该任务还没有绑定到任何线程上。我们可以通过currentThread()方法来获得当 前Thread的引用,接着调用isInterrupted()来判断线程是否中断。