業務需求

電影院新片首映，觀影人數大量增加，為提高日營業額，線下售票窗口由原單窗口調整為3窗口，設計一段簡單的程序模擬該售票過程。

程序設計

多線程場景下需考慮線程安全的問題，避免多個線程爭搶同一個資源導致業務邏輯出現錯誤。實現線程安全的方式有很多，這里使用Java Lock 接口中的方法實現。

代碼示例

import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
/**
 * 測試類
 */
public class DemoTest {
    public static void main(String[] args) {
        //窗口01
        new Thread(() -> {
            while (true) {
                //售票并獲取售票后的當前票余量
                int currentTickets = TicketSource.saleTickets();
                //模擬售票員賣出一張票用時1秒
                waitProcess();
                //票已賣完
                if (currentTickets <= 0) break;
            }
        }, "01").start();
        //窗口02
        new Thread(() -> {
            while (true) {
                int currentTickets = TicketSource.saleTickets();
                waitProcess();
                if (currentTickets <= 0) break;
            }
        }, "02").start();
        //窗口03
        new Thread(() -> {
            while (true) {
                int currentTickets = TicketSource.saleTickets();
                waitProcess();
                if (currentTickets <= 0) break;
            }
        }, "03").start();
    }
    private static void waitProcess() {
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
/**
 * 電影票資源類
 */
class TicketSource {
    //當前電影票余量
    private static int currentTickets = 30;
    //加鎖確保多線程場景下的線程安全
    private static final Lock lock = new ReentrantLock();
    /**
     * 賣票
     *
     * @return 當前電影票余量
     */
    public static int saleTickets() {
        lock.lock();
        try {
            if (currentTickets > 0) {
                //模擬賣票
                currentTickets--;
                if (currentTickets == 0) {
                    //票余量為 0 停止售賣
                    System.out.println(
                            Thread.currentThread().getName() + "窗口出票成功！"
                                    + "當前票余量：" + currentTickets
                                    + " 今日票已賣完！");
                } else {
                    System.out.println(
                            Thread.currentThread().getName() + "窗口出票成功！"
                                    + "當前票余量：" + currentTickets);
                }
            } else {
                //票余量為 0 停止售賣
                System.out.println(Thread.currentThread().getName() + "窗口：今日票已賣完！");
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            lock.unlock();
        }
        return currentTickets;
    }
}

運行結果

D:\installPath\Java\jdk1.8.0_121\bin\java.exe "-javaagent:D:\installPath\IntelliJ IDEA 2019.1.4\lib\idea_rt.jar=64339:D:\installPath\IntelliJ IDEA 2019.1.4\bin"
01窗口出票成功！當前票余量：29
02窗口出票成功！當前票余量：28
03窗口出票成功！當前票余量：27
01窗口出票成功！當前票余量：26
03窗口出票成功！當前票余量：25
02窗口出票成功！當前票余量：24
03窗口出票成功！當前票余量：23
01窗口出票成功！當前票余量：22
02窗口出票成功！當前票余量：21
02窗口出票成功！當前票余量：20
03窗口出票成功！當前票余量：19
01窗口出票成功！當前票余量：18
01窗口出票成功！當前票余量：17
02窗口出票成功！當前票余量：16
03窗口出票成功！當前票余量：15
02窗口出票成功！當前票余量：14
01窗口出票成功！當前票余量：13
03窗口出票成功！當前票余量：12
01窗口出票成功！當前票余量：11
03窗口出票成功！當前票余量：10
02窗口出票成功！當前票余量：9
03窗口出票成功！當前票余量：8
02窗口出票成功！當前票余量：7
01窗口出票成功！當前票余量：6
03窗口出票成功！當前票余量：5
02窗口出票成功！當前票余量：4
01窗口出票成功！當前票余量：3
01窗口出票成功！當前票余量：2
03窗口出票成功！當前票余量：1
02窗口出票成功！當前票余量：0 今日票已賣完！
01窗口：今日票已賣完！
03窗口：今日票已賣完！
Process finished with exit code 0