死锁
死锁
发生在并发中，发生在两个线程或多个线程之间。
互不相让：当两个（或更多）线程（或进程）相互持有对方所需要的资源，又不主动释放，导致所有人都无法继续前进，导致程序陷入无尽的阻塞（等待状态），这就是死锁。
多个线程造成死锁的情况
如果多个线程之间的依赖关系是环形，存在环路的锁的依赖关系，那么也可能会发生死锁。
死锁的影响
- 死锁的影响在不同系统中是不一样的，这取决于系统对死锁的处理能力。
1* 数据库中：检测并放弃事务（事务之间发生死锁）
2* JVM中：无法自动处理
几率不高但危害大
- 不一定发生，但是遵循“墨菲定律”。
- 一旦发生，多是高并发场景，影响用户多。
- 整个系统崩溃，子系统崩溃、性能降低。
- 压力测试无法找出所有潜在的死锁。（死锁和并发量只是一个正相关的关系，并不是必然的关系，所以无法通过增加并发量来模拟出死锁，也无法保证高并发的情况下可以 100% 的模拟出死锁。）
发生死锁的例子
最简单的情况
1/**
2 * 描述： 必定发生死锁的情况
3 */
4public class MustDeadLock implements Runnable {
5
6 int flag = 1;
7
8 static Object o1 = new Object();
9 static Object o2 = new Object();
10
11 public static void main(String[] args) {
12 MustDeadLock r1 = new MustDeadLock();
13 MustDeadLock r2 = new MustDeadLock();
14 r1.flag = 1;
15 r2.flag = 0;
16 Thread t1 = new Thread(r1);
17 Thread t2 = new Thread(r2);
18 t1.start();
19 t2.start();
20 }
21
22 @Override
23 public void run() {
24 System.out.println("flag = " + flag);
25 if (flag == 1) {
26 synchronized (o1) {
27 try {
28 Thread.sleep(500);
29 } catch (InterruptedException e) {
30 e.printStackTrace();
31 }
32 synchronized (o2) {
33 System.out.println("线程1成功拿到两把锁");
34 }
35 }
36 }
37 if (flag == 0) {
38 synchronized (o2) {
39 try {
40 Thread.sleep(500);
41 } catch (InterruptedException e) {
42 e.printStackTrace();
43 }
44 synchronized (o1) {
45 System.out.println("线程2成功拿到两把锁");
46 }
47 }
48 }
49 }
50}
1flag = 1
2flag = 0
实际生产中的例子：转账
- 需要两把锁
- 获取两把锁成功，且余额大于 0，则扣除转出人，增加收款人的余额，是原子操作。
- 顺序相反导致死锁
1/**
2 * 描述： 转账时候遇到死锁，一旦打开注释，便会发生死锁
3 */
4public class TransferMoneyDemo implements Runnable {
5
6 int flag = 1;
7 static Account a = new Account(500);
8 static Account b = new Account(500);
9 static Object lock = new Object();
10
11 public static void main(String[] args) throws InterruptedException {
12 TransferMoneyDemo r1 = new TransferMoneyDemo();
13 TransferMoneyDemo r2 = new TransferMoneyDemo();
14 r1.flag = 1;
15 r2.flag = 0;
16 Thread t1 = new Thread(r1);
17 Thread t2 = new Thread(r2);
18 t1.start();
19 t2.start();
20 t1.join();
21 t2.join();
22 System.out.println("a的余额" + a.balance);
23 System.out.println("b的余额" + b.balance);
24 }
25
26 @Override
27 public void run() {
28 if (flag == 1) {
29 transferMoney(a, b, 200);
30 }
31 if (flag == 0) {
32 transferMoney(b, a, 200);
33 }
34 }
35
36 public static void transferMoney(Account from, Account to, int amount) {
37 synchronized (from) {
38 try {
39 Thread.sleep(500);//发生死锁的
40 } catch (InterruptedException e) {
41 e.printStackTrace();
42 }
43 synchronized (to) {//卡在这里
44 if (from.balance - amount < 0) {
45 System.out.println("余额不足，转账失败");
46 }
47 from.balance -= amount;
48 to.balance += amount;
49 System.out.println("成功转账" + amount + "元");
50 }
51 }
52 }
53
54 static class Account {
55 public Account(int balance) {
56 this.balance = balance;
57 }
58
59 int balance;
60 }
61}
模拟多人随机转账
1import java.util.Random;
2
3/**
4 * 描述： 多人同时转账，依然很危险
5 */
6public class MultiTransferMoney {
7 //账户数
8 private static final int NUM_ACCOUNTS = 500;
9 //金额
10 private static final int NUM_MONEY = 1000;
11 //重复次数
12 private static final int NUM_ITERATIONS = 1000000;
13 //线程数
14 private static final int NUM_THREADS = 20;
15 //随机工具类
16 public static Random rnd = new Random();
17 //初始化Account数组
18 public static Account[] accounts = new Account[NUM_ACCOUNTS];
19
20 /**
21 * 转账方法
22 * @param from
23 * @param to
24 * @param amount
25 */
26 public static void transferMoney(Account from, Account to, int amount) {
27 synchronized (from) {
28/* try {
29 Thread.sleep(500);//发生死锁的
30 } catch (InterruptedException e) {
31 e.printStackTrace();
32 }*/
33 synchronized (to) {//卡在这里
34 if (from.balance - amount < 0) {
35 System.out.println("余额不足，转账失败");
36 }
37 from.balance -= amount;
38 to.balance += amount;
39 System.out.println("成功转账" + amount + "元");
40 }
41 }
42 }
43
44 //初始化账户
45 static {
46 for (int i = 0; i < accounts.length; i++) {
47 accounts[i] = new Account(NUM_MONEY);
48 }
49 }
50
51 //Account类
52 static class Account {
53 public Account(int balance) {
54 this.balance = balance;
55 }
56 int balance;
57 }
58
59 //线程类
60 static class TransferThread extends Thread {
61 @Override
62 public void run() {
63 for (int i = 0; i < NUM_ITERATIONS; i++) {
64 //生成随机账户、 转账金额
65 int fromAcct = rnd.nextInt(NUM_ACCOUNTS);
66 int toAcct = rnd.nextInt(NUM_ACCOUNTS);
67 int amount = rnd.nextInt(NUM_MONEY);
68 //调用转账方法
69 transferMoney(accounts[fromAcct], accounts[toAcct], amount);
70 }
71 System.out.println("运行结束");
72 }
73 }
74
75 public static void main(String[] args) {
76 //开启20个线程
77 for (int i = 0; i < NUM_THREADS; i++) {
78 new TransferThread().start();
79 }
80 }
81}
死锁的 4 个必要条件
- 互斥条件：一把锁同一时间只能被一个线程占用。
- 请求与保持条件：阻塞在请求第二把锁的同时还不愿意释放自己持有的锁。
- 不剥夺条件：无权终止任意一个发生死锁的线程。
- 循环等待条件：a 等 b、b 等 c、 c 等 a。形成环路。
案例分析：分别把四个必要条件标注出来
1/**
2 * 描述： 必定发生死锁的情况
3 */
4public class MustDeadLock implements Runnable {
5
6 int flag = 1;
7
8 static Object o1 = new Object();
9 static Object o2 = new Object();
10
11 public static void main(String[] args) {
12 MustDeadLock r1 = new MustDeadLock();
13 MustDeadLock r2 = new MustDeadLock();
14 r1.flag = 1;
15 r2.flag = 0;
16 Thread t1 = new Thread(r1);//互斥条件
17 Thread t2 = new Thread(r2);
18 t1.start();
19 t2.start();
20 }
21
22 @Override
23 public void run() {
24 System.out.println("flag = " + flag);
25 if (flag == 1) {
26 synchronized (o1) {//请求与保持条件
27 try {
28 Thread.sleep(500);
29 } catch (InterruptedException e) {
30 e.printStackTrace();
31 }
32 synchronized (o2) { //循环等待条件
33 System.out.println("线程1成功拿到两把锁");
34 }
35 }
36 }
37 if (flag == 0) {
38 synchronized (o2) {
39 try {
40 Thread.sleep(500);
41 } catch (InterruptedException e) {
42 e.printStackTrace();
43 }
44 synchronized (o1) {
45 System.out.println("线程2成功拿到两把锁");
46 }
47 }
48 }
49 }
50}
如何定位死锁
jps (JVM Process Status Tool）是其中的典型 jvm 工具。除了名字像 UNIX 的 ps 命令之外，它的功能也和 ps 命令类似：可以列出正在运行的虚拟机进程，并显示虚拟机执行主类（Main Class, main（）函数所在的类）名称以及这些进程的本地虚拟机唯- ID (Local Virtual Machine Identifier, LVMID），虽然功能比较单一，但它是使用频率最高的 JDK 命令行工具
1-l #展示类全限定名，如果进程执行的是 Jar 包则输出 Jar 路径。
2-v #输出虚拟机进程启动时 JVM 参数
3
4C:\Users\Ryzen-7-3800X>jps -l
525364 org.jetbrains.jps.cmdline.Launcher
625652 com.xdclass.couponapp.test.deadlock.MustDeadLock
733912 sun.tools.jps.Jps
85912 org.jetbrains.kotlin.daemon.KotlinCompileDaemon
918396 sun.tools.jconsole.JConsole
109276
Jstack (Stack Trace for Java）命令用于生成虚拟机当前时刻的线程快照（-般称为 threaddump 或者 javacore 文件）。
线程快照就是当前虚拟机内每一条线程正在执行的方法堆栈的集合，生成线程快照的主要目的是定位线程出现长时间停顿的原因，如线程间死锁、死循环、请求外部资源导致的长时间等待等都是导致线程长时间停顿的常见原因。线程出现停顿的时候通过 jstack 来查看各个线程的调用堆栈，就可以知道没有响应的线程到底在后台做些什么事情，或者等待着什么资源。
1C:\Users\soulboy>jstack -l 14820
2Found one Java-level deadlock:
3=============================
4"Thread-1":
5 waiting to lock monitor 0x0000000026159938 (object 0x0000000715d6e230, a java.lang.Object),
6 which is held by "Thread-0"
7"Thread-0":
8 waiting to lock monitor 0x0000000026156f48 (object 0x0000000715d6e240, a java.lang.Object),
9 which is held by "Thread-1"
10
11Java stack information for the threads listed above:
12===================================================
13"Thread-1":
14 at com.xdclass.couponapp.test.deadlock.MustDeadLock.run(MustDeadLock.java:47)
15 - waiting to lock <0x0000000715d6e230> (a java.lang.Object)
16 - locked <0x0000000715d6e240> (a java.lang.Object)
17 at java.lang.Thread.run(Thread.java:748)
18"Thread-0":
19 at com.xdclass.couponapp.test.deadlock.MustDeadLock.run(MustDeadLock.java:35)
20 - waiting to lock <0x0000000715d6e240> (a java.lang.Object)
21 - locked <0x0000000715d6e230> (a java.lang.Object)
22 at java.lang.Thread.run(Thread.java:748)
23
24Found 1 deadlock.
ThreadMXBean 代码演示：用于让程序发生死锁之后的处理能力
1import java.lang.management.ManagementFactory;
2import java.lang.management.ThreadInfo;
3import java.lang.management.ThreadMXBean;
4
5/**
6 * 描述： 用ThreadMXBean检测死锁
7 */
8public class ThreadMXBeanDetection implements Runnable {
9
10 int flag = 1;
11
12 static Object o1 = new Object();
13 static Object o2 = new Object();
14
15 public static void main(String[] args) throws InterruptedException {
16 ThreadMXBeanDetection r1 = new ThreadMXBeanDetection();
17 ThreadMXBeanDetection r2 = new ThreadMXBeanDetection();
18 r1.flag = 1;
19 r2.flag = 0;
20 Thread t1 = new Thread(r1);
21 Thread t2 = new Thread(r2);
22 t1.start();
23 t2.start();
24 Thread.sleep(1000);
25 //解决死锁
26 ThreadMXBean threadMXBean = ManagementFactory.getThreadMXBean();
27 //数组中的元素为发生死锁的线程
28 long[] deadlockedThreads = threadMXBean.findDeadlockedThreads();
29 if (deadlockedThreads != null && deadlockedThreads.length > 0) {
30 for (int i = 0; i < deadlockedThreads.length; i++) {
31 ThreadInfo threadInfo = threadMXBean.getThreadInfo(deadlockedThreads[i]);
32 System.out.println("发现死锁" + threadInfo.getThreadName());
33 //报警
34 //日志记录
35 //重启程序
36 }
37 }
38 }
39
40 @Override
41 public void run() {
42 System.out.println("flag = " + flag);
43 if (flag == 1) {
44 synchronized (o1) {
45 try {
46 Thread.sleep(500);
47 } catch (InterruptedException e) {
48 e.printStackTrace();
49 }
50 synchronized (o2) {
51 System.out.println("线程1成功拿到两把锁");
52 }
53 }
54 }
55 if (flag == 0) {
56 synchronized (o2) {
57 try {
58 Thread.sleep(500);
59 } catch (InterruptedException e) {
60 e.printStackTrace();
61 }
62 synchronized (o1) {
63 System.out.println("线程2成功拿到两把锁");
64 }
65 }
66 }
67 }
68}
修复死锁的策略
线上发生死锁的情况
- 线上问题都要防患于未然，不造成损失地扑灭几乎已经是不可能了。
- 保存案发现场然后立刻重启服务器
- 暂时保证线上服务的安全，然后在利用刚才保存的信息，排查死锁，修改代码，重新发布。
常见修复策略
- 避免策略：哲学家就餐的换手方案、转账换序案。
1思路：避免相反的获取锁的顺序发生，实际开发中可以利用主键进行获取锁的排序，就不需要hashcode了。
- 检测与恢复策略：一段时间检测是否有死锁，如果有就剥夺某一个资源，来打开死锁。
- 鸵鸟策略：诺鸟这种动物在遇到危险的时候，通常就会把头埋在地上，这样一来它就看不到危险了。鸵鸟策略的意思就是说，如果发生死锁的概率极其低，那么可以直接忽略它，直到死锁发生的时候，再人工修复。几个月死锁一次的情况下才会考虑。
案例：避免相反的获取锁的顺序发生（避免策略）
1package com.xdclass.couponapp.test.deadlock;
2
3/**
4 * 描述： 转账时候遇到死锁，一旦打开注释，便会发生死锁
5 */
6public class TransferMoney implements Runnable {
7
8 int flag = 1;
9 static Account a = new Account(500);
10 static Account b = new Account(500);
11 static Object lock = new Object();
12
13 public static void main(String[] args) throws InterruptedException {
14 TransferMoney r1 = new TransferMoney();
15 TransferMoney r2 = new TransferMoney();
16 r1.flag = 1;
17 r2.flag = 0;
18 Thread t1 = new Thread(r1);
19 Thread t2 = new Thread(r2);
20 t1.start();
21 t2.start();
22 t1.join();
23 t2.join();
24 System.out.println("a的余额" + a.balance);
25 System.out.println("b的余额" + b.balance);
26 }
27
28 @Override
29 public void run() {
30 if (flag == 1) {
31 transferMoney(a, b, 200);
32 }
33 if (flag == 0) {
34 transferMoney(b, a, 200);
35 }
36 }
37
38 public static void transferMoney(Account from, Account to, int amount) {
39 //抽取转账的业务逻辑代码
40 class Helper {
41 public void transfer() {
42 if (from.balance - amount < 0) {
43 System.out.println("余额不足，转账失败。");
44 return;
45 }
46 from.balance -= amount;
47 to.balance = to.balance + amount;
48 System.out.println("成功转账" + amount + "元");
49 }
50 }
51 //利用哈希值：统一获取锁的顺序
52 int fromHash = System.identityHashCode(from);
53 int toHash = System.identityHashCode(to);
54 //根据对象的hashcode作为获取所的顺序条件
55 //保证两个相互获取锁的线程，获取锁的顺序始终一致。
56 if (fromHash < toHash) {
57 synchronized (from) {
58 synchronized (to) {
59 new Helper().transfer();
60 }
61 }
62 }
63 else if (fromHash > toHash) {
64 synchronized (to) {
65 synchronized (from) {
66 new Helper().transfer();
67 }
68 }
69 }else {
70 synchronized (lock) {// 发生hashcode碰撞，随便选择一种获取锁的顺序即可
71 synchronized (to) {
72 synchronized (from) {
73 new Helper().transfer();
74 }
75 }
76 }
77 }
78
79 }
80
81
82 static class Account {
83
84 public Account(int balance) {
85 this.balance = balance;
86 }
87
88 int balance;
89
90 }
91}
示例：哲学家就餐
1# 多种解决方案
2* 服务员检查（避免策略）
3* 改变一个哲学家拿叉子的顺序（避免策略）
4* 餐票（避免策略）
5* 领导调节（检测与恢复策略）
改变一个哲学家拿叉子的顺序（避免策略）
1/**
2 * 描述： 演示哲学家就餐问题导致的死锁
3 */
4public class DiningPhilosophers {
5
6 public static class Philosopher implements Runnable {
7
8 private Object leftChopstick;
9 private Object rightChopstick;
10
11 public Philosopher(Object leftChopstick, Object rightChopstick) {
12 this.leftChopstick = leftChopstick;
13 this.rightChopstick = rightChopstick;
14 }
15
16 @Override
17 public void run() {
18 try {
19 while (true) {
20 doAction("Thinking");
21 synchronized (leftChopstick) {
22 doAction("Picked up left chopstick");
23 synchronized (rightChopstick) {
24 doAction("Picked up right chopstick - eating");
25 doAction("Put down right chopstick");
26 }
27 doAction("Put down left chopstick");
28 }
29 }
30 } catch (InterruptedException e) {
31 e.printStackTrace();
32 }
33 }
34
35 private void doAction(String action) throws InterruptedException {
36 System.out.println(Thread.currentThread().getName() + " " + action);
37 Thread.sleep((long) (Math.random() * 10));
38 }
39 }
40
41 public static void main(String[] args) {
42 Philosopher[] philosophers = new Philosopher[5];
43 Object[] chopsticks = new Object[philosophers.length];
44 for (int i = 0; i < chopsticks.length; i++) {
45 chopsticks[i] = new Object();
46 }
47 for (int i = 0; i < philosophers.length; i++) {
48 Object leftChopstick = chopsticks[i];
49 Object rightChopstick = chopsticks[(i + 1) % chopsticks.length];
50 //最后一位哲学家改变拿筷子的顺序（避免策略）
51 if (i == philosophers.length - 1) {
52 philosophers[i] = new Philosopher(rightChopstick, leftChopstick);
53 } else {
54 philosophers[i] = new Philosopher(leftChopstick, rightChopstick);
55 }
56 new Thread(philosophers[i], "哲学家" + (i + 1) + "号").start();
57 }
58 }
59}
领导调节（检测与恢复策略）
1* 允许发生死锁
2* 每次调用锁都记录
3* 定期检查 “锁的调用链路图” 中是否存在环路
4* 一旦发生死锁，就用死锁恢复机制进行恢复
5 1.进程终止：逐个终止线程，知道死锁消除
6 2.终止顺序： 优先级（对于程序重要性的优先级）、已占用资源、还需要的资源作为终止进程的判断依据。或是已运行时间。
7 3.资源抢占：不把已经发放出去的锁给收回来。 缺点：造成饥饿
实际工程中如何避免死锁
- 获取锁的时候设置超时时间
1* Lock 的 tryLock(long timeout,TimeUnit unit)
2* synchronized 不具备尝试锁的能力
3* 造成超时的可能性多：发生了死锁、线程陷入死循环、线程执行很慢等……
4* 获取锁失败：打日志、发邮件、重启等
示例：用 tryLock 来避免死锁
1package com.xdclass.couponapp.test.deadlock;
2
3import java.util.Random;
4import java.util.concurrent.TimeUnit;
5import java.util.concurrent.locks.Lock;
6import java.util.concurrent.locks.ReentrantLock;
7
8/**
9 * 描述： 用tryLock来避免死锁
10 */
11public class TryLockDeadlock implements Runnable {
12
13 int flag = 1;
14 static Lock lock1 = new ReentrantLock();
15 static Lock lock2 = new ReentrantLock();
16
17 public static void main(String[] args) {
18 TryLockDeadlock r1 = new TryLockDeadlock();
19 TryLockDeadlock r2 = new TryLockDeadlock();
20 r1.flag = 1;
21 r2.flag = 0;
22 new Thread(r1).start();
23 new Thread(r2).start();
24 }
25
26 @Override
27 public void run() {
28 for (int i = 0; i < 100; i++) {
29 if (flag == 1) {
30 try {
31 if (lock1.tryLock(800, TimeUnit.MILLISECONDS)) {
32 System.out.println("线程1获取到了锁1");
33 Thread.sleep(new Random().nextInt(1000));
34 if (lock2.tryLock(800, TimeUnit.MILLISECONDS)) {
35 System.out.println("线程1获取到了锁2");
36 System.out.println("线程1成功获取到了两把锁");
37 lock2.unlock();
38 lock1.unlock();
39 break;
40 } else {
41 System.out.println("线程1尝试获取锁2失败，已重试");
42 lock1.unlock();
43 Thread.sleep(new Random().nextInt(1000));
44 }
45 } else {
46 System.out.println("线程1获取锁1失败，已重试");
47 }
48 } catch (InterruptedException e) {
49 e.printStackTrace();
50 }
51 }
52 if (flag == 0) {
53 try {
54 if (lock2.tryLock(3000, TimeUnit.MILLISECONDS)) {
55 System.out.println("线程2获取到了锁2");
56
57 Thread.sleep(new Random().nextInt(1000));
58 if (lock1.tryLock(3000, TimeUnit.MILLISECONDS)) {
59 System.out.println("线程2获取到了锁1");
60 System.out.println("线程2成功获取到了两把锁");
61 lock1.unlock();
62 lock2.unlock();
63 break;
64 } else {
65 System.out.println("线程2尝试获取锁1失败，已重试");
66 lock2.unlock();
67 Thread.sleep(new Random().nextInt(1000));
68 }
69 } else {
70 System.out.println("线程2获取锁2失败，已重试");
71 }
72 } catch (InterruptedException e) {
73 e.printStackTrace();
74 }
75 }
76 }
77 }
78}
- 多使用并发类而不是自己设计的锁。
1* ConcurrentHashMap、ConcurrentLinkedQueue、AtomicBoolean等…
2* 实际应用中 java.util.concurrent.atomic 十分有用，简单方便且效率比使用 Lock 更高。
3* 多使用并发集合少使用同步集合，并发集合比同步集合的可扩展性更好。
4* 并发场景需要用到map,首先想到用ConcurrentHashMap
- 尽量减低锁的使用粒度:用不同的锁而不是一个锁。
- 如果能使用同步代码块，就不使用同步方法：自己指定锁对象。
- 给你的线程起个有意义的名字：debug 和排查时事半功倍，框架和 JDK 都遵循这个最佳实践。
- 避免锁的嵌套：MustDeadLock 类
- 分配资源前先看能不能收回来：银行家算法。
- 尽量避免几个功能用同一把锁：专锁专用
其他活性故障
死锁是最常见的活跃性问题，除了死锁之外，还有一些类似的问题，会导致程序无法顺利执行，统称为活跃性问题。
- 活锁（LiveLock）
- 饥饿
活锁成因
虽然线程并没有阻塞，也始终在运行（所以叫做"活"锁，线程是"活"的），但是程序却得不到进展，因为线程始终重复做同样的事。
死锁会陷入阻塞（不消耗 CPU 时间片），而活锁会消耗 CPU 资源（不断的运行）。
1# 哲学家问题
2 同时拿起左边的筷子，同时等待一段时间，同时放下手中的筷子，再等 5 分钟，再同时拿起筷子……repeat。
3 如果这里死锁，那么就是这里两个人都始终一动不动，直到对方先抬头，他们之间不再说话了，只是等待。
活锁示例：吃饭
1成因：重试机制不变，消息队列始终重试，吃饭始终谦让。
2解决方案：以太网的指数退避算法。
3
4工程中活锁实例：消息队列
5 成因：由于依赖服务出了问题，处理该消息一直失败，一直重试（试图处理该消息）。消息如果处理失败，就放在队列开头重试
6 解决方案：放在队尾、重试限制（阈值触发，持久化到数据库中，从队列中踢出该消息）
1import java.util.Random;
2
3/**
4 * 描述： 演示活锁问题
5 */
6public class LiveLock {
7
8 static class Spoon {
9
10 private Diner owner;
11
12 public Spoon(Diner owner) {
13 this.owner = owner;
14 }
15
16 public Diner getOwner() {
17 return owner;
18 }
19
20 public void setOwner(Diner owner) {
21 this.owner = owner;
22 }
23
24 public synchronized void use() {
25 System.out.printf("%s吃完了!", owner.name);
26
27 }
28 }
29
30 static class Diner {
31
32 private String name;
33 private boolean isHungry;
34
35 public Diner(String name) {
36 this.name = name;
37 isHungry = true;
38 }
39
40 public void eatWith(Spoon spoon, Diner spouse) {
41 while (isHungry) {
42 if (spoon.owner != this) {
43 try {
44 Thread.sleep(1);
45 } catch (InterruptedException e) {
46 e.printStackTrace();
47 }
48 continue;
49 }
50 Random random = new Random();
51 // if (spouse.isHungry) //活锁
52 if (spouse.isHungry && random.nextInt(10) < 9) { //大部分情况都会小于9 (0~9)
53 System.out.println(name + ": 亲爱的" + spouse.name + "你先吃吧");
54 spoon.setOwner(spouse);
55 continue;
56 }
57
58 spoon.use();
59 isHungry = false;
60 System.out.println(name + ": 我吃完了");
61 spoon.setOwner(spouse);
62
63 }
64 }
65 }
66
67 public static void main(String[] args) {
68 Diner husband = new Diner("牛郎");
69 Diner wife = new Diner("织女");
70
71 Spoon spoon = new Spoon(husband);
72
73 new Thread(new Runnable() {
74 @Override
75 public void run() {
76 husband.eatWith(spoon, wife);
77 }
78 }).start();
79
80 new Thread(new Runnable() {
81 @Override
82 public void run() {
83 wife.eatWith(spoon, husband);
84 }
85 }).start();
86 }
87}
饥饿成因
当线程需要某些资源（CPU），但是却始终得不到。
线程的优先级设置得过于低，或者有某线程持有锁同时又无限循环从而不释放锁，或者某些程序始终占用某文件的写锁。
饥饿可能会导致响应性差：比如，我们的浏览器有一个线程负责处理前台响应（打开收藏夹等动作），另外的后台线程负责下载图片、文件、计算渲染等。在这种情况下，如果后台线程把 CPU 资源都占用了，那么前台线程将无法得到很好地执行，这会导致用户的体验很差。