[Java知识库]ReentrantLock实现买票功能

import lombok.SneakyThrows;

import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.ReentrantLock;

public class test implements Runnable  {

    //票的数量
    private static  int  tick = 2;

    //锁
    private static ReentrantLock lock = new ReentrantLock();

    @SneakyThrows  //和try catch  一样
    @Override
    public void run() {
        //获取锁 锁等待1秒就返回false
        if(lock.tryLock(1000, TimeUnit.MILLISECONDS)){
            try {
                //获取到锁调用减库存方法
                sell();
            } finally {
                lock.unlock();
            }
        }else{
            System.out.println("目前访问人数较多，请稍后再试");
        }
    }

    /**
     * 减库存方法
     */
    private void sell() {
        System.out.println("现在还有："+tick);
        //判断库存是否足够
        if (tick>0){
            tick = tick - 1;
            System.out.println(Thread.currentThread().getName()+"卖了一张，还剩余"+tick);
        }else{
            System.out.println("票已经卖完了");
        }
    }

    /**
     * 模拟客户端买票
     * @param args
     */
    public static void main(String[] args) {
        test test = new test();
        //模拟十个客户端抢两张票
        for (int i = 1; i < 10; i++) {
            Thread thread = new Thread(test);
            thread.setName("窗口"+i);
            thread.start();
        }
    }
}

现在还有：2
窗口9卖了一张，还剩余1
现在还有：1
窗口2卖了一张，还剩余0
现在还有：0
票已经卖完了
现在还有：0
票已经卖完了
现在还有：0
票已经卖完了
现在还有：0
票已经卖完了
现在还有：0
票已经卖完了
现在还有：0
票已经卖完了
现在还有：0
票已经卖完了

《新程序员》：云原生和全面数字化实践

50位技术专家共同创作，文字、视频、音频交互阅读