java 多线程详解
在这篇文章里,我们关注多线程。多线程是一个复杂的话题,包含了很多内容,这篇文章主要关注线程的基本属性、如何创建线程、线程的状态切换以及线程通信。
线程是操作系统运行的基本单位,它被封装在进程中,一个进程可以包含多个线程。即使我们不手动创造线程,进程也会有一个默认的线程在运行。
对于JVM来说,当我们编写一个单线程的程序去运行时,JVM中也是有至少两个线程在运行,一个是我们创建的程序,一个是垃圾回收。
线程基本信息
我们可以通过Thread.currentThread()方法获取当前线程的一些信息,并对其进行修改。
我们来看以下代码:
查看并修改当前线程的属性 String name = Thread.currentThread().getName(); int priority = Thread.currentThread().getPriority(); String groupName = Thread.currentThread().getThreadGroup().getName(); boolean isDaemon = Thread.currentThread().isDaemon(); System.out.println("Thread Name:" + name); System.out.println("Priority:" + priority); System.out.println("Group Name:" + groupName); System.out.println("IsDaemon:" + isDaemon); Thread.currentThread().setName("Test"); Thread.currentThread().setPriority(Thread.MAX_PRIORITY); name = Thread.currentThread().getName(); priority = Thread.currentThread().getPriority(); groupName = Thread.currentThread().getThreadGroup().getName(); isDaemon = Thread.currentThread().isDaemon(); System.out.println("Thread Name:" + name); System.out.println("Priority:" + priority);</div>
其中列出的属性说明如下:
- GroupName,每个线程都会默认在一个线程组里,我们也可以显式的创建线程组,一个线程组中也可以包含子线程组,这样线程和线程组,就构成了一个树状结构。
- Name,每个线程都会有一个名字,如果不显式指定,那么名字的规则是“Thread-xxx”。
- Priority,每个线程都会有自己的优先级,JVM对优先级的处理方式是“抢占式”的。当JVM发现优先级高的线程时,马上运行该线程;对于多个优先级相等的线程,JVM对其进行轮询处理。Java的线程优先级从1到10,默认是5,Thread类定义了2个常量:MIN_PRIORITY和MAX_PRIORITY来表示最高和最低优先级。
我们可以看下面的代码,它定义了两个不同优先级的线程:
线程优先级示例 public static void priorityTest() { Thread thread1 = new Thread("low") { public void run() { for (int i = 0; i < 5; i++) { System.out.println("Thread 1 is running."); } } }; Thread thread2 = new Thread("high") { public void run() { for (int i = 0; i < 5; i++) { System.out.println("Thread 2 is running."); } } }; thread1.setPriority(Thread.MIN_PRIORITY); thread2.setPriority(Thread.MAX_PRIORITY); thread1.start(); thread2.start(); }</div>
从运行结果可以看出,是高优先级线程运行完成后,低优先级线程才运行。
isDaemon,这个属性用来控制父子线程的关系,如果设置为true,当父线程结束后,其下所有子线程也结束,反之,子线程的生命周期不受父线程影响。
我们来看下面的例子:
IsDaemon 示例 public static void daemonTest() { Thread thread1 = new Thread("daemon") { public void run() { Thread subThread = new Thread("sub") { public void run() { for(int i = 0; i < 100; i++) { System.out.println("Sub Thread Running " + i); } } }; subThread.setDaemon(true); subThread.start(); System.out.println("Main Thread end."); } }; thread1.start(); }</div>
上面代码的运行结果,在和删除subThread.setDaemon(true);后对比,可以发现后者运行过程中子线程会完成执行后再结束,而前者中,子线程很快就结束了。
如何创建线程
上面的内容,都是演示默认线程中的一些信息,那么应该如何创建线程呢?在Java中,我们有3种方式可以用来创建线程。
Java中的线程要么继承Thread类,要么实现Runnable接口,我们一一道来。
使用内部类来创建线程
我们可以使用内部类的方式来创建线程,过程是声明一个Thread类型的变量,并重写run方法。示例代码如下:
使用内部类创建线程 public static void createThreadByNestClass() { Thread thread = new Thread() { public void run() { for (int i =0; i < 5; i++) { System.out.println("Thread " + Thread.currentThread().getName() + " is running."); } System.out.println("Thread " + Thread.currentThread().getName() + " is finished."); } }; thread.start(); }</div>
继承Thread以创建线程
我们可以从Thread中派生一个类,重写其run方法,这种方式和上面相似。示例代码如下:
派生Thread类以创建线程 class MyThread extends Thread { public void run() { for (int i =0; i < 5; i++) { System.out.println("Thread " + Thread.currentThread().getName() + " is running."); } System.out.println("Thread " + Thread.currentThread().getName() + " is finished."); } } public static void createThreadBySubClass() { MyThread thread = new MyThread(); thread.start(); }</div>
实现Runnable接口以创建线程
我们可以定义一个类,使其实现Runnable接口,然后将该类的实例作为构建Thread变量构造函数的参数。示例代码如下:
实现Runnable接口以创建线程 class MyRunnable implements Runnable { public void run() { for (int i =0; i < 5; i++) { System.out.println("Thread " + Thread.currentThread().getName() + " is running."); } System.out.println("Thread " + Thread.currentThread().getName() + " is finished."); } } public static void createThreadByRunnable() { MyRunnable runnable = new MyRunnable(); Thread thread = new Thread(runnable); thread.start(); }</div>
上述3种方式都可以创建线程,而且从示例代码上看,线程执行的功能是一样的,那么这三种创建方式有什么不同呢?
这涉及到Java中多线程的运行模式,对于Java来说,多线程在运行时,有“多对象多线程”和“单对象多线程”的区别:
- 多对象多线程,程序在运行过程中创建多个线程对象,每个对象上运行一个线程。
- 单对象多线程,程序在运行过程中创建一个线程对象,在其上运行多个线程。
显然,从线程同步和调度的角度来看,多对象多线程要简单一些。上述3种线程创建方式,前两种都属于“多对象多线程”,第三种既可以使用“多对象多线程”,也可以使用“单对象单线程”。
我们来看下面的示例代码,里面会用到Object.notify方法,这个方法会唤醒对象上的一个线程;而Object.notifyAll方法,则会唤醒对象上的所有线程。
notify示例 public class NotifySample { public static void main(String[] args) throws InterruptedException { notifyTest(); notifyTest2(); notifyTest3(); } private static void notifyTest() throws InterruptedException { MyThread[] arrThreads = new MyThread[3]; for (int i = 0; i < arrThreads.length; i++) { arrThreads[i] = new MyThread(); arrThreads[i].id = i; arrThreads[i].setDaemon(true); arrThreads[i].start(); } Thread.sleep(500); for (int i = 0; i < arrThreads.length; i++) { synchronized(arrThreads[i]) { arrThreads[i].notify(); } } } private static void notifyTest2() throws InterruptedException { MyRunner[] arrMyRunners = new MyRunner[3]; Thread[] arrThreads = new Thread[3];