简单来说, Single Thread Execution就是采用排他式的操作保证在同一时刻只能有一个线程访问共享资源。

1.机场过安检

1.1非线程安全

先模拟一个非线程安全的安检口类,旅客(线程)分别手持登机牌和身份证接受工作人员的检查,示例代码如所示。

  1. public class FlightSecurity {
  2. private int count = 0;
  3. // 登机牌
  4. private String boardingPass = "null";
  5. // 身份证
  6. private String idCard = "null";
  7. public void pass(String boardingPass, String idCard) {
  8. this.boardingPass = boardingPass;
  9. this.idCard = idCard;
  10. this.count++;
  11. }
  12. private void check() {
  13. // 简单的测试,当登机牌和身份证首字母不相同时则表示检查不通过
  14. if ( boardingPass.charAt(0) != idCard.charAt(0))
  15. throw new RuntimeException("======Exception=====" + toString());
  16. }
  17. @Override
  18. public String toString() {
  19. return "FlightSecurity{" +
  20. "count=" + count +
  21. ", boardingPass='" + boardingPass + '\'' +
  22. ", idCard='" + idCard + '\'' +
  23. '}';
  24. }
  25. }

Flight Security比较简单, 提供了一个pass方法, 将旅客的登机牌和身份证传递给pass方法, 在pass方法中调用check方法对旅客进行检查, 检查的逻辑也足够的简单, 只需要检测登机牌和身份证首字母是否相等(当然这样在现实中非常不合理,但是为了使测试简单我们约定这么做),我们看代码所示的测试.

  1. public class FlightSecurityTest {
  2. // 旅客线程
  3. static class Passengers extends Thread {
  4. // 机场安检类
  5. private final FlightSecurity flightSecurity;
  6. // 旅客的身份证
  7. private final String idCard;
  8. // 旅客的登机牌
  9. private final String boardingPass;
  10. // 构造旅客是传入身份证,登机牌以及机场安检类
  11. public Passengers(FlightSecurity flightSecurity, String idCard, String boardingPass) {
  12. this.flightSecurity = flightSecurity;
  13. this.idCard = idCard;
  14. this.boardingPass = boardingPass;
  15. }
  16. @Override
  17. public void run() {
  18. while(true) {
  19. flightSecurity.pass(boardingPass, idCard);
  20. }
  21. }
  22. }
  23. public static void main(String[] args) {
  24. // 定义三个旅客,身份证和登机牌首字母均相同
  25. final FlightSecurity flightSecurity = new FlightSecurity();
  26. new Passengers(flightSecurity, "A1234","AF1234").start();
  27. new Passengers(flightSecurity, "B1234", "BF1234").start();
  28. new Passengers(flightSecurity,"C1234", "CF1234").start();
  29. }
  30. }

首字母相同检查不能通过和首字母不相同检查不能通过,为什么会出现这样的情况呢?首字母相同却不能通过?更加奇怪的是传入的参数明明全都是首字母相同的,为什么会出现首字母不相同的错误呢?

1.2 问题分析

(1)首字母相同却未通过检查
图所示的为首字母相同却无法通过安检的分析过程。
2image.png
(2)为何出现首字母不相同的情况
明明传入的身份证和登机牌首字母都相同,可为何在运行的过程中会出现首字母不相同的情况,下面我们也通过图示的方式进行分析,如图所示。
image.png

1.3 线程安全

1.1节中出现的问题说到底就是数据同步的问题, 虽然线程传递给pass方法的两个参数能够百分之百地保证首字母相同, 可是在为FlightSecurity中的属性赋值的时候会出现多个线程交错的情况,结合我们在第一部分第4章的所讲内容可知,需要对共享资源增加同步保护,改进代码如下:

  1. public synchronized void pass(String boardingPass, String idCard) {
  2. this.boardingPass = boardingPass;
  3. this.idCard = idCard;
  4. this.count++;
  5. }

何时适合使用single thread execution模式呢?答案如下。

  • 多线程访问资源的时候, 被synchronized同步的方法总是排他性的。
  • 多个线程对某个类的状态发生改变的时候, 比如Flight Security的登机牌以及身份证。

2.吃面问题

2.1吃面引起的死锁

虽然使用synchronized关键字可以保证single thread execution, 但是如果使用不得当则会导致死锁的情况发生,比如A手持刀等待B放下叉,而B手持叉等待A放下刀,示例代码如所示。

  1. public class EatNoodleThread extends Thread {
  2. private final String name;
  3. // 左手边的餐具
  4. private final Tableware leftTool;
  5. // 右手边的餐具
  6. private final Tableware rightTool;
  7. public EatNoodleThread(String name, Tableware leftTool, Tableware rightTool) {
  8. this.name = name;
  9. this.leftTool = leftTool;
  10. this.rightTool = rightTool;
  11. }
  12. @Override
  13. public void run() {
  14. while (true) {
  15. this.eat();
  16. }
  17. }
  18. // 吃面条的过程
  19. private void eat() {
  20. synchronized (leftTool) {
  21. System.out.println(name + " take up" + leftTool + "left");
  22. synchronized (rightTool) {
  23. System.out.println(name + "take up " + rightTool + "right");
  24. }
  25. System.out.println(name + " put down " + leftTool);
  26. }
  27. }
  28. public static void main(String[] args) {
  29. Tableware fork = new Tableware("fork");
  30. Tableware knife = new Tableware("knife");
  31. new EatNoodleThread("A", fork, knife).start();
  32. new EatNoodleThread("B", knife, fork).start();
  33. }
  34. }

2.2 解决吃面引起的死锁问题

为了解决交叉锁的情况,我们需要将刀叉进行封装,使刀叉同属于一个类中,改进代码如所示

  1. public class EatNoodleThread1 extends Thread{
  2. private final String name;
  3. private final TablewarePair tablewarePair;
  4. public EatNoodleThread1(String name, TablewarePair tablewarePair) {
  5. this.name = name;
  6. this.tablewarePair = tablewarePair;
  7. }
  8. @Override
  9. public void run() {
  10. while(true) {
  11. this.eat();
  12. }
  13. }
  14. private void eat() {
  15. synchronized (tablewarePair) {
  16. System.out.println("eatting");
  17. }
  18. }
  19. }

2.3哲学家吃面问题
哲学家吃面是解释操作系统中多个进程竞争资源的经典问题,每个哲学家的左右手都有吃面用的刀叉,但是不足以同时去使用,比如A哲学家想要吃面,必须拿起左手边的叉和右手边的刀,但是有可能叉和刀都被其他哲学家拿走使用,或者是手持刀等待别人放下叉等容易引起死锁的问题。