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.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