当线程被创建并启动以后,它既不是一启动就进入了执行状态,也不是一直处于执行状态。在线程的生命周期中,它要经过 新建(New)、就绪(Runnable)、运行(Running)、阻塞(Blocked)和死亡(Dead)5种状态 。尤其是当线程启动以后,它不可能一直"霸占"着CPU独自运行,所以CPU需要在多条线程之间切换,于是 线程状态也会多次在运行、阻塞之间切换 。
当程序使用new关键字创建了一个线程之后,该线程就处于 新建状态 ,此时的线程情况如下:
当线程对象调用了start()方法之后,该线程处于 就绪状态 。此时的线程情况如下:
程序可以使用Thread.sleep(1) 来让当前运行的线程(主线程)睡眠1毫秒,1毫秒就够了, 因为在这1毫秒内CPU不会空闲,它会去执行另一个处于就绪状态的线程,这样就可以让子线程立即开始执行 ;
当CPU开始调度处于 就绪状态 的线程时,此时线程获得了CPU时间片才得以真正开始执行run()方法的线程执行体,则该线程处于 运行状态 。
处于运行状态的线程最为复杂,它 不可能一直处于运行状态(除非它的线程执行体足够短,瞬间就执行结束了) ,线程在运行过程中需要被中断, 目的是使其他线程获得执行的机会 ,线程调度的细节取决于底层平台所采用的策略。线程状态可能会变为 阻塞状态、就绪状态和死亡状态 。比如:
处于运行状态的线程在某些情况下,让出CPU并暂时停止自己的运行,进入 阻塞状态 。
在阻塞状态的线程只能进入就绪状态,无法直接进入运行状态。而就绪和运行状态之间的转换通常不受程序控制, 而是由系统线程调度所决定 。当处于就绪状态的线程获得处理器资源时,该线程进入运行状态; 当处于运行状态的线程失去处理器资源时,该线程进入就绪状态 。但有一个方法例外, 调用yield()方法可以让运行状态的线程转入就绪状态 。
线程处于 无限制等待状态 ,等待一个特殊的事件来重新唤醒,如:
以上两种一旦通过相关事件唤醒线程,线程就进入了 就绪(RUNNABLE)状态 继续运行。
线程进入了一个 时限等待状态 ,如:
sleep(3000),等待3秒后线程重新进行 就绪(RUNNABLE)状态 继续运行。
线程会以如下3种方式结束,结束后就处于 死亡状态 :
处于死亡状态的线程对象也许是活的,但是,它已经不是一个单独执行的线程。线程一旦死亡,就不能复生。 如果在一个死去的线程上调用start()方法,会抛出java.lang.IllegalThreadStateException异常 。
线程执行完毕后,进入终止(TERMINATED)状态。
public class Thread{ // 线程的启动 public void start(); // 线程体 public void run(); // 已废弃 public void stop(); // 已废弃 public void resume(); // 已废弃 public void suspend(); // 在指定的毫秒数内让当前正在执行的线程休眠 public static void sleep(long millis); // 同上,增加了纳秒参数 public static void sleep(long millis, int nanos); // 测试线程是否处于活动状态 public boolean isAlive(); // 中断线程 public void interrupt(); // 测试线程是否已经中断 public boolean isInterrupted(); // 测试当前线程是否已经中断 public static boolean interrupted(); // 等待该线程终止 public void join() throws InterruptedException; // 等待该线程终止的时间最长为 millis 毫秒 public void join(long millis) throws InterruptedException; // 等待该线程终止的时间最长为 millis 毫秒 + nanos 纳秒 public void join(long millis, int nanos) throws InterruptedException; }
当调用线程中的yield()方法时,线程从运行状态转换为就绪状态, 但接下来CPU调度就绪状态中的那个线程具有一定的随机性 ,因此,可能会出现A线程调用了yield()方法后,接下来CPU仍然调度了A线程的情况。
通过调用start启动线程,线程执行时会执行run方法中的代码。
sleep():通过sleep(millis)使线程进入休眠一段时间, 该方法在指定的时间内无法被唤醒,同时也不会释放对象锁 ;
/** * 可以明显看到打印的数字在时间上有些许的间隔 */ public class Test1 { public static void main(String[] args) throws InterruptedException { for(int i=0;i<100;i++){ System.out.println("main"+i); Thread.sleep(100); } } }
public class Test1 { public static void main(String[] args) throws InterruptedException { System.out.println(Thread.currentThread().getName()); MyThread myThread=new MyThread(); myThread.start(); myThread.sleep(1000);//这里sleep的就是main线程,而非myThread线程 Thread.sleep(10); for(int i=0;i<100;i++){ System.out.println("main"+i); } } }
public class Test1 { public static void main(String[] args) throws InterruptedException { new MyThread().start(); new MyThread().start(); } } class MyThread extends Thread { @Override public void run() { for (int i = 0; i < 3; i++) { System.out.println(this.getName()+"线程" + i + "次执行!"); try { Thread.sleep(50); } catch (InterruptedException e) { e.printStackTrace(); } } } }看某一次的运行结果 :可以发现,线程0首先执行,然后线程1执行一次,又了执行一次。发现并不是按照sleep的顺序执行的。
Thread-0线程0次执行! Thread-1线程0次执行! Thread-1线程1次执行! Thread-0线程1次执行! Thread-0线程2次执行! Thread-1线程2次执行!
yield():与sleep类似,也是Thread类提供的一个静态的方法,它也可以让当前正在执行的线程暂停,让出CPU资源给其他的线程。但是和sleep()方法不同的是, 它不会进入到阻塞状态,而是进入到就绪状态 。yield()方法只是让当前线程暂停一下,重新进入就绪线程池中,让系统的线程调度器重新调度器重新调度一次,完全可能出现这样的情况: 当某个线程调用yield()方法之后,线程调度器又将其调度出来重新进入到运行状态执行 。
实际上, 当某个线程调用了yield()方法暂停之后,优先级与当前线程相同,或者优先级比当前线程更高的就绪状态的线程更有可能获得执行的机会 ,当然,只是有可能,因为我们不可能精确的干涉cpu调度线程。
public class Test1 { public static void main(String[] args) throws InterruptedException { new MyThread("低级", 1).start(); new MyThread("中级", 5).start(); new MyThread("高级", 10).start(); } } class MyThread extends Thread { public MyThread(String name, int pro) { super(name);// 设置线程的名称 this.setPriority(pro);// 设置优先级 } @Override public void run() { for (int i = 0; i < 30; i++) { System.out.println(this.getName() + "线程第" + i + "次执行!"); if (i % 5 == 0) Thread.yield(); } } }
线程的合并的含义就是 将几个并行线程的线程合并为一个单线程执行 ,应用场景是 当一个线程必须等待另一个线程执行完毕才能执行时 ,Thread类提供了join方法来完成这个功能, 注意,它不是静态方法 。
void join() 当前线程等该加入该线程后面,等待该线程终止。 void join(long millis) 当前线程等待该线程终止的时间最长为 millis 毫秒。 如果在millis时间内,该线程没有执行完,那么当前线程进入就绪状态,重新等待cpu调度 void join(long millis,int nanos) 等待该线程终止的时间最长为 millis 毫秒 + nanos 纳秒。如果在millis时间内,该线程没有执行完,那么当前线程进入就绪状态,重新等待cpu调度
/** * 在主线程中调用thread.join(); 就是将主线程加入到thread子线程后面等待执行。不过有时间限制,为1毫秒。 */ public class Test1 { public static void main(String[] args) throws InterruptedException { MyThread thread=new MyThread(); thread.start(); thread.join(1);//将主线程加入到子线程后面,不过如果子线程在1毫秒时间内没执行完,则主线程便不再等待它执行完,进入就绪状态,等待cpu调度 for(int i=0;i<30;i++){ System.out.println(Thread.currentThread().getName() + "线程第" + i + "次执行!"); } } } class MyThread extends Thread { @Override public void run() { for (int i = 0; i < 1000; i++) { System.out.println(this.getName() + "线程第" + i + "次执行!"); } } }
suspend- 线程进入阻塞状态,但不会释放锁 。此方法已不推荐使用, 因为同步时不会释放锁,会造成死锁的问题 。
resume- 使线程重新进入可执行状态 。
不推荐使用,且以后可能去除,因为它不安全。它会解除由线程获取的所有锁定, 当在一个线程对象上调用stop()方法时,这个线程对象所运行的线程就会立即停止 ,由此可能造成数据的不完整(后面的代码没执行完就停止了),很难检查出问题所在。
wait & notify/notifyAll这三个都是Object类的方法。
wait-使得线程进入阻塞状态,会释放持有的对象锁,使得其他线程可以访问需要该对象锁的同步方法or同步块。
notify-选择一个锁对象上wait的线程唤醒,使这个唤醒的线程继续执行,其他线程仍然是wait状态。
每个线程执行时都有一个优先级的属性, 优先级高的线程可以获得较多的执行机会,而优先级低的线程则获得较少的执行机会 。与线程休眠类似,线程的优先级仍然无法保障线程的执行次序。只不过, 优先级高的线程获取CPU资源的概率较大,优先级低的也并非没机会执行 。
Thread类提供了setPriority(int newPriority)和getPriority()方法来设置和返回一个指定线程的优先级,其中setPriority方法的参数是一个整数,范围是1~10之间,也可以使用Thread类提供的三个静态常量:
MAX_PRIORITY =10 MIN_PRIORITY =1 NORM_PRIORITY =5
public class Test1 { public static void main(String[] args) throws InterruptedException { new MyThread("高级", 10).start(); new MyThread("低级", 1).start(); } } class MyThread extends Thread { public MyThread(String name,int pro) { super(name);//设置线程的名称 setPriority(pro);//设置线程的优先级 } @Override public void run() { for (int i = 0; i < 100; i++) { System.out.println(this.getName() + "线程第" + i + "次执行!"); } } }
从执行结果可以看到 , 一般情况下,高级线程更显执行完毕 。
虽然Java提供了10个优先级别,但这些优先级别需要操作系统的支持。 不同的操作系统的优先级并不相同,而且也不能很好的和Java的10个优先级别对应 。所以我们应该使用MAX_PRIORITY、MIN_PRIORITY和NORM_PRIORITY三个静态常量来设定优先级, 这样才能保证程序最好的可移植性 。
守护线程与普通线程写法上基本没啥区别,调用线程对象的方法setDaemon(true),则可以将其设置为守护线程。
守护线程使用的情况较少,但并非无用,举例来说, JVM的垃圾回收、内存管理等线程都是守护线程 。还有就是在做数据库应用时候,使用的数据库连接池, 连接池本身也包含着很多后台线程,监控连接个数、超时时间、状态等等 。
public final void setDaemon(boolean on):将该线程标记为守护线程或用户线程。 当正在运行的线程都是守护线程时,Java 虚拟机退出 。
该方法必须在启动线程前调用。 该方法首先调用该线程的 checkAccess 方法,且不带任何参数。这可能抛出 SecurityException(在当前线程中)。
on - 如果为 true,则将该线程标记为守护线程。
IllegalThreadStateException - 如果该线程处于活动状态。 SecurityException - 如果当前线程无法修改该线程。
/** * Java线程:线程的调度-守护线程 */ public class Test { public static void main(String[] args) { Thread t1 = new MyCommon(); Thread t2 = new Thread(new MyDaemon()); t2.setDaemon(true); //设置为守护线程 t2.start(); t1.start(); } } class MyCommon extends Thread { public void run() { for (int i = 0; i < 5; i++) { System.out.println("线程1第" + i + "次执行!"); try { Thread.sleep(7); } catch (InterruptedException e) { e.printStackTrace(); } } } } class MyDaemon implements Runnable { public void run() { for (long i = 0; i < 9999999L; i++) { System.out.println("后台线程第" + i + "次执行!"); try { Thread.sleep(7); } catch (InterruptedException e) { e.printStackTrace(); } } } }
执行结果:
后台线程第0次执行! 线程1第0次执行! 线程1第1次执行! 后台线程第1次执行! 后台线程第2次执行! 线程1第2次执行! 线程1第3次执行! 后台线程第3次执行! 线程1第4次执行! 后台线程第4次执行! 后台线程第5次执行! 后台线程第6次执行! 后台线程第7次执行!
从上面的执行结果可以看出: 前台线程是保证执行完毕的,后台线程还没有执行完毕就退出了 。
实际上: JRE判断程序是否执行结束的标准是所有的前台执线程行完毕了,而不管后台线程的状态,因此,在使用后台线程时候一定要注意这个问题 。
Thread.stop()、Thread.suspend、Thread.resume、Runtime.runFinalizersOnExit这些终止线程运行的方法已经被废弃了,使用它们是极端不安全的!想要安全有效的结束一个线程,可以使用下面的方法。
比如说run方法这样写:只要保证在一定的情况下,run方法能够执行完毕即可。而不是while(true)的无限循环。
class MyThread extends Thread { int i=0; @Override public void run() { while (true) { if(i==10) break; i++; System.out.println(i); } } } 或者 class MyThread extends Thread { int i=0; boolean next=true; @Override public void run() { while (next) { if(i==10) next=false; i++; System.out.println(i); } } } 或者 class MyThread extends Thread { int i=0; @Override public void run() { while (true) { if(i==10) return; i++; System.out.println(i); } } }
诚然,使用上面方法的标识符来结束一个线程,是一个不错的方法,但其也有弊端,如果 该线程是处于sleep、wait、join的状态时候,while循环就不会执行 ,那么我们的标识符就无用武之地了, 当然也不能再通过它来结束处于这3种状态的线程了 。
所以,此时可以使用interrupt这个巧妙的方式结束掉这个线程。我们先来看看sleep、wait、join方法的声明:
public final void wait() throws InterruptedException public static native void sleep(long millis) throws InterruptedException public final void join() throws InterruptedException
可以看到,这三者有一个共同点,都抛出了一个InterruptedException的异常。 在什么时候会产生这样一个异常呢 ?
每个Thread都有一个中断状状态,默认为false。可以通过Thread对象的isInterrupted()方法来判断该线程的中断状态。可以通过Thread对象的interrupt()方法将中断状态设置为true。
当一个线程处于sleep、wait、join这三种状态之一的时候,如果此时他的中断状态为true,那么它就会抛出一个InterruptedException的异常,并将中断状态重新设置为false。
看下面的简单的例子:
public class Test1 { public static void main(String[] args) throws InterruptedException { MyThread thread=new MyThread(); thread.start(); } } class MyThread extends Thread { int i=1; @Override public void run() { while (true) { System.out.println(i); System.out.println(this.isInterrupted()); try { System.out.println("我马上去sleep了"); Thread.sleep(2000); this.interrupt(); } catch (InterruptedException e) { System.out.println("异常捕获了"+this.isInterrupted()); return; } i++; } } }
测试结果:
1 false 我马上去sleep了 2 true 我马上去sleep了 异常捕获了false
可以看到,首先执行第一次while循环,在第一次循环中,睡眠2秒,然后将中断状态设置为true。 当进入到第二次循环的时候,中断状态就是第一次设置的true,当它再次进入sleep的时候,马上就抛出了InterruptedException异常,然后被我们捕获了 。然后中断状态又被重新自动设置为false了(从最后一条输出可以看出来)。
所以,我们可以使用interrupt方法结束一个线程。具体使用如下:
public class Test1 { public static void main(String[] args) throws InterruptedException { MyThread thread=new MyThread(); thread.start(); Thread.sleep(3000); thread.interrupt(); } } class MyThread extends Thread { int i=0; @Override public void run() { while (true) { System.out.println(i); try { Thread.sleep(1000); } catch (InterruptedException e) { System.out.println("中断异常被捕获了"); return; } i++; } } }
多测试几次,会发现一般有两种执行结果:
0 1 2 中断异常被捕获了
或者
0 1 2 3 中断异常被捕获了
这两种结果恰恰说明了, 只要一个线程的中断状态一旦为true,只要它进入sleep等状态,或者处于sleep状态,立马回抛出InterruptedException异常 。
第一种情况,是当主线程从3秒睡眠状态醒来之后,调用了子线程的interrupt方法,此时子线程正处于sleep状态,立马抛出InterruptedException异常。
第二种情况,是当主线程从3秒睡眠状态醒来之后,调用了子线程的interrupt方法,此时子线程还没有处于sleep状态。然后再第3次while循环的时候,在此进入sleep状态,立马抛出InterruptedException异常。