多线程作为Java中很重要的一个知识点，在此还是有必要总结一下的。
一. 线程的生命周期及五种基本状态
关于Java中线程的生命周期，首先看一下下面这张较为经典的图：
上图中基本上囊括了Java中多线程各重要知识点。掌握了上图中的各知识点，Java中的多线程也就基本上掌握了。主要包括：
Java线程具有五种基本状态
新建状态（New）：当线程对象对创建后，即进入了新建状态，如：Thread t = new MyThread();
就绪状态（Runnable）：当调用线程对象的start()方法（t.start();），线程即进入就绪状态。处于就绪状态的线程，只是说明此线程已经做好了准备，随时等待CPU调度执行，并不是说执行了t.start()此线程立即就会执行；
运行状态（Running）：当CPU开始调度处于就绪状态的线程时，此时线程才得以真正执行，即进入到运行状态。注：就 绪状态是进入到运行状态的唯一入口，也就是说，线程要想进入运行状态执行，首先必须处于就绪状态中；
阻塞状态（Blocked）：处于运行状态中的线程由于某种原因，暂时放弃对CPU的使用权，停止执行，此时进入阻塞状态，直到其进入到就绪状态，才 有机会再次被CPU调用以进入到运行状态。根据阻塞产生的原因不同，阻塞状态又可以分为三种：
1.等待阻塞：运行状态中的线程执行wait()方法，使本线程进入到等待阻塞状态；
2.同步阻塞 -- 线程在获取synchronized同步锁失败(因为锁被其它线程所占用)，它会进入同步阻塞状态；
3.其他阻塞 -- 通过调用线程的sleep()或join()或发出了I/O请求时，线程会进入到阻塞状态。当sleep()状态超时、join()等待线程终止或者超时、或者I/O处理完毕时，线程重新转入就绪状态。
死亡状态（Dead）：线程执行完了或者因异常退出了run()方法，该线程结束生命周期。
二. Java多线程的创建及启动
Java中线程的创建常见有以下两种基本形式
1. 继承Thread类，重写该类的run()方法。
1 class MyThread extends Thread {
2
3 private int i = 0;
4
5 @Override
6 public void run() {
7 for (i = 0; i < 100; i++) {
8 System.out.println(Thread.currentThread().getName() + " " + i);
9 }
10 }
11 }
1 public class ThreadTest {
2
3 public static void main(String[] args) {
4 for (int i = 0; i < 100; i++) {
5 System.out.println(Thread.currentThread().getName() + " " + i);
6 if (i == 30) {
7 Thread myThread1 = new MyThread(); // 创建一个新的线程 myThread1 此线程进入新建状态
8 Thread myThread2 = new MyThread(); // 创建一个新的线程 myThread2 此线程进入新建状态
9 myThread1.start(); // 调用start()方法使得线程进入就绪状态
10 myThread2.start(); // 调用start()方法使得线程进入就绪状态
11 }
12 }
13 }
14 }
2. 实现Runnable接口，并重写该接口的run()方法，该run()方法同样是线程执行体，创建Runnable实现类的实例，并以此实例作为Thread类的target来创建Thread对象，该Thread对象才是真正的线程对象。
1 class MyRunnable implements Runnable {
2 private int i = 0;
3
4 @Override
5 public void run() {
6 for (i = 0; i < 100; i++) {
7 System.out.println(Thread.currentThread().getName() + " " + i);
8 }
9 }
10 }
1 public class ThreadTest {
2
3 public static void main(String[] args) {
4 for (int i = 0; i < 100; i++) {
5 System.out.println(Thread.currentThread().getName() + " " + i);
6 if (i == 30) {
7 Runnable myRunnable = new MyRunnable(); // 创建一个Runnable实现类的对象
8 Thread thread1 = new Thread(myRunnable); // 将myRunnable作为Thread target创建新的线程
9 Thread thread2 = new Thread(myRunnable);
10 thread1.start(); // 调用start()方法使得线程进入就绪状态
11 thread2.start();
12 }
13 }
14 }
15 }
三. Java多线程的就绪、运行和死亡状态
就绪状态转换为运行状态：当此线程得到处理器资源；
运行状态转换为就绪状态：当此线程主动调用yield()方法或在运行过程中失去处理器资源。
运行状态转换为死亡状态：当此线程线程执行体执行完毕或发生了异常。
此处需要特别注意的是：当调用线程的yield()方法时，线程从运行状态转换为就绪状态，但接下来CPU调度就绪状态中的哪个线程具有一定的随机性，因此，可能会出现A线程调用了yield()方法后，接下来CPU仍然调度了A线程的情况。
由于实际的业务需要，常常会遇到需要在特定时机终止某一线程的运行，使其进入到死亡状态。目前最通用的做法是设置一boolean型的变量，当条件满足时，使线程执行体快速执行完毕。如：
1 public class ThreadTest {
2
3 public static void main(String[] args) {
4
5 MyRunnable myRunnable = new MyRunnable();
6 Thread thread = new Thread(myRunnable);
7
8 for (int i = 0; i < 100; i++) {
9 System.out.println(Thread.currentThread().getName() + " " + i);
10 if (i == 30) {
11 thread.start();
12 }
13 if(i == 40){
14 myRunnable.stopThread();
15 }
16 }
17 }
18 }
19
20 class MyRunnable implements Runnable {
21
22 private boolean stop;
23
24 @Override
25 public void run() {
26 for (int i = 0; i < 100 && !stop; i++) {
27 System.out.println(Thread.currentThread().getName() + " " + i);
28 }
29 }
30
31 public void stopThread() {
32 this.stop = true;
33 }
34
35 }
四. Java多线程的阻塞状态与线程控制
上文已经提到Java阻塞的几种具体类型。下面分别看下引起Java线程阻塞的主要方法。
1. join()
join —— 让一个线程等待另一个线程完成才继续执行。如A线程线程执行体中调用B线程的join()方法，则A线程被阻塞，直到B线程执行完为止，A才能得以继续执行。
1 public class ThreadTest {
2
3 public static void main(String[] args) {
4
5 MyRunnable myRunnable = new MyRunnable();
6 Thread thread = new Thread(myRunnable);
7
8 for (int i = 0; i < 100; i++) {
9 System.out.println(Thread.currentThread().getName() + " " + i);
10 if (i == 30) {
11 thread.start();
12 try {
13 thread.join(); // main线程需要等待thread线程执行完后才能继续执行
14 } catch (InterruptedException e) {
15 e.printStackTrace();
16 }
17 }
18 }
19 }
20 }
21
22 class MyRunnable implements Runnable {
23
24 @Override
25 public void run() {
26 for (int i = 0; i < 100; i++) {
27 System.out.println(Thread.currentThread().getName() + " " + i);
28 }
29 }
30 }
2. sleep()
sleep —— 让当前的正在执行的线程暂停指定的时间，并进入阻塞状态。在其睡眠的时间段内，该线程由于不是处于就绪状态，因此不会得到执行的机会。即使此时系统中没有任何其他可执行的线程，出于sleep()中的线程也不会执行。因此sleep()方法常用来暂停线程执行。
前面有讲到，当调用了新建的线程的start()方法后，线程进入到就绪状态，可能会在接下来的某个时间获取CPU时间片得以执行，如果希望这个新线程必然性的立即执行，直接调用原来线程的sleep(1)即可。
1 public class ThreadTest {
2
3 public static void main(String[] args) {
4
5 MyRunnable myRunnable = new MyRunnable();
6 Thread thread = new Thread(myRunnable);
7
8 for (int i = 0; i < 100; i++) {
9 System.out.println(Thread.currentThread().getName() + " " + i);
10 if (i == 30) {
11 thread.start();
12 try {
13 Thread.sleep(1); // 使得thread必然能够马上得以执行
14 } catch (InterruptedException e) {
15 e.printStackTrace();
16 }
17 }
18 }
19 }
20 }
21
22 class MyRunnable implements Runnable {
23
24 @Override
25 public void run() {
26 for (int i = 0; i < 100; i++) {
27 System.out.println(Thread.currentThread().getName() + " " + i);
28 }
29 }
30 }
3. 后台线程（Daemon Thread）
概念/目的：后台线程主要是为其他线程（相对可以称之为前台线程）提供服务，或“守护线程”。如JVM中的垃圾回收线程。
生命周期：后台线程的生命周期与前台线程生命周期有一定关联。主要体现在：当所有的前台线程都进入死亡状态时，后台线程会自动死亡(其实这个也很好理解，因为后台线程存在的目的在于为前台线程服务的，既然所有的前台线程都死亡了，那它自己还留着有什么用...伟大啊 ! !)。
设置后台线程：调用Thread对象的setDaemon(true)方法可以将指定的线程设置为后台线程。
1 public class ThreadTest {
2
3 public static void main(String[] args) {
4 Thread myThread = new MyThread();
5 for (int i = 0; i < 100; i++) {
6 System.out.println("main thread i = " + i);
7 if (i == 20) {
8 myThread.setDaemon(true);
9 myThread.start();
10 }
11 }
12 }
13
14 }
15
16 class MyThread extends Thread {
17
18 public void run() {
19 for (int i = 0; i < 100; i++) {
20 System.out.println("i = " + i);
21 try {
22 Thread.sleep(1);
23 } catch (InterruptedException e) {
24 // TODO Auto-generated catch block
25 e.printStackTrace();
26 }
27 }
28 }
29 }
注：main线程默认是前台线程，前台线程创建中创建的子线程默认是前台线程，后台线程中创建的线程默认是后台线程。调用setDeamon(true)方法将前台线程设置为后台线程时，需要在start()方法调用之前。前台线程都死亡后，JVM通知后台线程死亡，但从接收指令到作出响应，需要一定的时间。
4. 改变线程的优先级/setPriority()：
每个线程在执行时都具有一定的优先级，优先级高的线程具有较多的执行机会。每个线程默认的优先级都与创建它的线程的优先级相同。main线程默认具有普通优先级。
设置线程优先级：setPriority(int priorityLevel)。参数priorityLevel范围在1-10之间，常用的有如下三个静态常量值：
MAX_PRIORITY:10
MIN_PRIORITY:1
NORM_PRIORITY:5
获取线程优先级：getPriority()。
注：具有较高线程优先级的线程对象仅表示此线程具有较多的执行机会，而非优先执行。
1 public class ThreadTest { 2 3 public static void main(String[] args) { 4 Thread myThread = new MyThread(); 5 for (int i = 0; i < 100; i++) { 6 System.out.println("main thread i = " + i); 7 if (i == 20) { 8 myThread.setPriority(Thread.MAX_PRIORITY); 9 myThread.start(); 10 } 11 } 12 } 13 14 } 15 16 class MyThread extends Thread { 17 18 public void run() { 19 for (int i = 0; i < 100; i++) { 20 System.out.println("i = " + i); 21 } 22 } 23 }
5. 线程让步：yield()
上一篇博文中已经讲到了yield()的基本作用，同时，yield()方法还与线程优先级有关，当某个线程调用yiled()方法从运行状态转换到就绪状态后，CPU从就绪状态线程队列中只会选择与该线程优先级相同或优先级更高的线程去执行。
1 public class ThreadTest {
2
3 public static void main(String[] args) {
4 Thread myThread1 = new MyThread1();
5 Thread myThread2 = new MyThread2();
6 myThread1.setPriority(Thread.MAX_PRIORITY);
7 myThread2.setPriority(Thread.MIN_PRIORITY);
8 for (int i = 0; i < 100; i++) {
9 System.out.println("main thread i = " + i);
10 if (i == 20) {
11 myThread1.start();
12 myThread2.start();
13 Thread.yield();
14 }
15 }
16 }
17
18 }
19
20 class MyThread1 extends Thread {
21
22 public void run() {
23 for (int i = 0; i < 100; i++) {
24 System.out.println("myThread 1 -- i = " + i);
25 }
26 }
27 }
28
29 class MyThread2 extends Thread {
30
31 public void run() {
32 for (int i = 0; i < 100; i++) {
33 System.out.println("myThread 2 -- i = " + i);
34 }
35 }
36 }
五. 线程同步
1. 同步方法
对共享资源进行访问的方法定义中加上synchronized关键字修饰，使得此方法称为同步方法。可以简单理解成对此方法进行了加锁，其锁对象为当前方法所在的对象自身。多线程环境下，当执行此方法时，首先都要获得此同步锁（且同时最多只有一个线程能够获得），只有当线程执行完此同步方法后，才会释放锁对象，其他的线程才有可能获取此同步锁，以此类推...
1 public synchronized void run() {
2
3 // ....
4
5 }
2. 同步代码块
正如上面所分析的那样，解决线程安全问题其实只需限制对共享资源访问的不确定性即可。使用同步方法时，使得整个方法体都成为了同步执行状态，会使得可能出现同步范围过大的情况，于是，针对需要同步的代码可以直接另一种同步方式——同步代码块来解决。
同步代码块的格式为：
1 synchronized (obj) {
2
3 //...
4
5 }
其中，obj为锁对象，因此，选择哪一个对象作为锁是至关重要的。一般情况下，都是选择此共享资源对象作为锁对象。
3. Lock对象同步锁
上面我们可以看出，正因为对同步锁对象的选择需要如此小心，有没有什么简单点的解决方案呢？以方便同步锁对象与共享资源解耦，同时又能很好的解决线程安全问题。
使用Lock对象同步锁可以方便的解决此问题，唯一需要注意的一点是Lock对象需要与资源对象同样具有一对一的关系。Lock对象同步锁一般格式为：
1 class X {
2
3 // 显示定义Lock同步锁对象，此对象与共享资源具有一对一关系
4 private final Lock lock = new ReentrantLock();
5
6 public void m(){
7 // 加锁
8 lock.lock();
9
10 //... 需要进行线程安全同步的代码
11
12 // 释放Lock锁
13 lock.unlock();
14 }
15
16 }
4. wait()/notify()/notifyAll()线程通信
wait()：导致当前线程等待并使其进入到等待阻塞状态。直到其他线程调用该同步锁对象的notify()或notifyAll()方法来唤醒此线程。
notify()：唤醒在此同步锁对象上等待的单个线程，如果有多个线程都在此同步锁对象上等待，则会任意选择其中某个线程进行唤醒操作，只有当前线程放弃对同步锁对象的锁定，才可能执行被唤醒的线程。
notifyAll()：唤醒在此同步锁对象上等待的所有线程，只有当前线程放弃对同步锁对象的锁定，才可能执行被唤醒的线程。
1 package com.qqyumidi; 2 3 public class ThreadTest { 4 5 public static void main(String[] args) { 6 Account account = new Account("123456", 0); 7 8 Thread drawMoneyThread = new DrawMoneyThread("取钱线程", account, 700); 9 Thread depositeMoneyThread = new DepositeMoneyThread("存钱线程", account, 700); 10 11 drawMoneyThread.start(); 12 depositeMoneyThread.start(); 13 } 14 15 } 16 17 class DrawMoneyThread extends Thread { 18 19 private Account account; 20 private double amount; 21 22 public DrawMoneyThread(String threadName, Account account, double amount) { 23 super(threadName); 24 this.account = account; 25 this.amount = amount; 26 } 27 28 public void run() { 29 for (int i = 0; i < 100; i++) { 30 account.draw(amount, i); 31 } 32 } 33 } 34 35 class DepositeMoneyThread extends Thread { 36 37 private Account account; 38 private double amount; 39 40 public DepositeMoneyThread(String threadName, Account account, double amount) { 41 super(threadName); 42 this.account = account; 43 this.amount = amount; 44 } 45 46 public void run() { 47 for (int i = 0; i < 100; i++) { 48 account.deposite(amount, i); 49 } 50 } 51 } 52 53 class Account { 54 55 private String accountNo; 56 private double balance; 57 // 标识账户中是否已有存款 58 private boolean flag = false; 59 60 public Account() { 61 62 } 63 64 public Account(String accountNo, double balance) { 65 this.accountNo = accountNo; 66 this.balance = balance; 67 } 68 69 public String getAccountNo() { 70 return accountNo; 71 } 72 73 public void setAccountNo(String accountNo) { 74 this.accountNo = accountNo; 75 } 76 77 public double getBalance() { 78 return balance; 79 } 80 81 public void setBalance(double balance) { 82 this.balance = balance; 83 } 84 85 /** 86 * 存钱 87 * 88 * @param depositeAmount 89 */ 90 public synchronized void deposite(double depositeAmount, int i) { 91 92 if (flag) { 93 // 账户中已有人存钱进去，此时当前线程需要等待阻塞 94 try { 95 System.out.println(Thread.currentThread().getName() + " 开始要执行wait操作" + " -- i=" + i); 96 wait(); 97 // 1 98 System.out.println(Thread.currentThread().getName() + " 执行了wait操作" + " -- i=" + i); 99 } catch (InterruptedException e) { 100 e.printStackTrace(); 101 } 102 } else { 103 // 开始存钱 104 System.out.println(Thread.currentThread().getName() + " 存款:" + depositeAmount + " -- i=" + i); 105 setBalance(balance + depositeAmount); 106 flag = true; 107 108 // 唤醒其他线程 109 notifyAll(); 110 111 // 2 112 try { 113 Thread.sleep(3000); 114 } catch (InterruptedException e) { 115 e.printStackTrace(); 116 } 117 System.out.println(Thread.currentThread().getName() + "-- 存钱 -- 执行完毕" + " -- i=" + i); 118 } 119 } 120 121 /** 122 * 取钱 123 * 124 * @param drawAmount 125 */ 126 public synchronized void draw(double drawAmount, int i) { 127 if (!flag) { 128 // 账户中还没人存钱进去，此时当前线程需要等待阻塞 129 try { 130 System.out.println(Thread.currentThread().getName() + " 开始要执行wait操作" + " 执行了wait操作" + " -- i=" + i); 131 wait(); 132 System.out.println(Thread.currentThread().getName() + " 执行了wait操作" + " 执行了wait操作" + " -- i=" + i); 133 } catch (InterruptedException e) { 134 e.printStackTrace(); 135 } 136 } else { 137 // 开始取钱 138 System.out.println(Thread.currentThread().getName() + " 取钱：" + drawAmount + " -- i=" + i); 139 setBalance(getBalance() - drawAmount); 140 141 flag = false; 142 143 // 唤醒其他线程 144 notifyAll(); 145 146 System.out.println(Thread.currentThread().getName() + "-- 取钱 -- 执行完毕" + " -- i=" + i); // 3 147 } 148 } 149 150 }
上面的例子演示了wait()/notify()/notifyAll()的用法。部分输出结果为：
1 取钱线程 开始要执行wait操作 执行了wait操作 -- i=0
2 存钱线程 存款:700.0 -- i=0
3 存钱线程-- 存钱 -- 执行完毕 -- i=0
4 存钱线程 开始要执行wait操作 -- i=1
5 取钱线程 执行了wait操作 执行了wait操作 -- i=0
6 取钱线程 取钱：700.0 -- i=1
7 取钱线程-- 取钱 -- 执行完毕 -- i=1
8 取钱线程 开始要执行wait操作 执行了wait操作 -- i=2
9 存钱线程 执行了wait操作 -- i=1
10 存钱线程 存款:700.0 -- i=2
11 存钱线程-- 存钱 -- 执行完毕 -- i=2
12 取钱线程 执行了wait操作 执行了wait操作 -- i=2
13 取钱线程 取钱：700.0 -- i=3
14 取钱线程-- 取钱 -- 执行完毕 -- i=3
15 取钱线程 开始要执行wait操作 执行了wait操作 -- i=4
16 存钱线程 存款:700.0 -- i=3
17 存钱线程-- 存钱 -- 执行完毕 -- i=3
18 存钱线程 开始要执行wait操作 -- i=4
19 取钱线程 执行了wait操作 执行了wait操作 -- i=4
20 取钱线程 取钱：700.0 -- i=5
21 取钱线程-- 取钱 -- 执行完毕 -- i=5
22 取钱线程 开始要执行wait操作 执行了wait操作 -- i=6
23 存钱线程 执行了wait操作 -- i=4
24 存钱线程 存款:700.0 -- i=5
25 存钱线程-- 存钱 -- 执行完毕 -- i=5
26 存钱线程 开始要执行wait操作 -- i=6
27 取钱线程 执行了wait操作 执行了wait操作 -- i=6
28 取钱线程 取钱：700.0 -- i=7
29 取钱线程-- 取钱 -- 执行完毕 -- i=7
30 取钱线程 开始要执行wait操作 执行了wait操作 -- i=8
31 存钱线程 执行了wait操作 -- i=6
32 存钱线程 存款:700.0 -- i=7
由此，我们需要注意如下几点：
1.wait()方法执行后，当前线程立即进入到等待阻塞状态，其后面的代码不会执行；
2.notify()/notifyAll()方法执行后，将唤醒此同步锁对象上的（任意一个-notify()/所有-notifyAll()）线程对象，但是，此时还并没有释放同步锁对象，也就是说，如果notify()/notifyAll()后面还有代码，还会继续进行，直到当前线程执行完毕才会释放同步锁对象；
3.notify()/notifyAll()执行后，如果右面有sleep()方法，则会使当前线程进入到阻塞状态，但是同步对象锁没有释放，依然自己保留，那么一定时间后还是会继续执行此线程，接下来同2；
4.wait()/notify()/nitifyAll()完成线程间的通信或协作都是基于不同对象锁的，因此，如果是不同的同步对象锁将失去意义，同时，同步对象锁最好是与共享资源对象保持一 一对应关系；
5.当wait线程唤醒后并执行时，是接着上次执行到的wait()方法代码后面继续往下执行的。
当然，上面的例子相对来说比较简单，只是为了简单示例wait()/notify()/noitifyAll()方法的用法，但其本质上说，已经是一个简单的生产者-消费者模式了。
原文地址：http://blog.csdn.net/aoshilang2249/article/details/46287413
