Java 多线程的应用场景

业务需求
电影院新片首映，观影人数大量增加，为提高日营业额，线下售票窗口由原单窗口调整为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.getCurrentTickets();
                if (currentTickets > 0) {
                    TicketSource.saleTickets();
                    waitProcess();
                } else {
                    stopSale();
                    break;
                }
            }
        }, "01").start();

        //窗口02
        new Thread(() -> {
            while (true) {
                int currentTickets = TicketSource.getCurrentTickets();
                if (currentTickets > 0) {
                    TicketSource.saleTickets();
                    waitProcess();
                } else {
                    stopSale();
                    break;
                }
            }
        }, "02").start();

        //窗口03
        new Thread(() -> {
            while (true) {
                int currentTickets = TicketSource.getCurrentTickets();
                if (currentTickets > 0) {
                    TicketSource.saleTickets();
                    waitProcess();
                } else {
                    stopSale();
                    break;
                }
            }
        }, "03").start();


    }

    //模拟售票员卖出一张票用时且假设每个售票员业务能力相同
    private static void waitProcess() {
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    //停止售卖
    private static void stopSale() {
        System.out.println(Thread.currentThread().getName() + "窗口：今日票已卖完！");
    }
}

/**
 * 电影票资源类
 */
class TicketSource {

    //当前电影票余量
    private static int currentTickets = 30;

    //加锁确保多线程场景下的线程安全
    private static Lock lock = new ReentrantLock();

    /**
     * 卖票
     *
     * @return 当前电影票余量
     */
    public synchronized static void saleTickets() {
        lock.lock();
        try {
            if (currentTickets > 0) {
                //模拟卖票
                currentTickets--;

                System.out.println(
                        Thread.currentThread().getName() + "窗口出票成功！"
                                + "当前票余量：" + currentTickets);
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            lock.unlock();
        }
    }

    public static int getCurrentTickets() {
        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"
03窗口出票成功！当前票余量：29
02窗口出票成功！当前票余量：28
01窗口出票成功！当前票余量：27
03窗口出票成功！当前票余量：26
01窗口出票成功！当前票余量：25
02窗口出票成功！当前票余量：24
03窗口出票成功！当前票余量：23
02窗口出票成功！当前票余量：22
01窗口出票成功！当前票余量：21
01窗口出票成功！当前票余量：20
02窗口出票成功！当前票余量：19
03窗口出票成功！当前票余量：18
03窗口出票成功！当前票余量：17
01窗口出票成功！当前票余量：16
02窗口出票成功！当前票余量：15
03窗口出票成功！当前票余量：14
02窗口出票成功！当前票余量：13
01窗口出票成功！当前票余量：12
03窗口出票成功！当前票余量：11
02窗口出票成功！当前票余量：10
01窗口出票成功！当前票余量：9
01窗口出票成功！当前票余量：8
02窗口出票成功！当前票余量：7
03窗口出票成功！当前票余量：6
03窗口出票成功！当前票余量：5
02窗口出票成功！当前票余量：4
01窗口出票成功！当前票余量：3
02窗口出票成功！当前票余量：2
01窗口出票成功！当前票余量：1
03窗口出票成功！当前票余量：0
03窗口：今日票已卖完！
01窗口：今日票已卖完！
02窗口：今日票已卖完！

Process finished with exit code 0