Java 多线程的应用场景_才哈哈的博客-CSDN博客_java多线程的使用场景

安宇雨 - 随手采集
2022-07-07 15:58:40
随手采集
0000-未整理-等待研究

业务需求
电影院新片首映，观影人数大量增加，为提高日营业额，线下售票窗口由原单窗口调整为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 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

原网址: 访问
创建于: 2022-07-07 15:58:40
目录: default
标签: 无

未标明原创文章均为采集，版权归作者所有，转载无需和我联系，请注明原出处，南摩阿彌陀佛，知识，不只知道，要得到