模拟线程安全的售票案例(java)

Posted 2020-10-19 即使如此

package try51.thread.safe;

import java.util.ArrayList;
import java.util.Random;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class LockDemo {
    public static void main(String[] args) {
        // 所有票源
        ArrayList<Thread> lst = new ArrayList<>();
        lst.add(new Thread(new Tickets2("网上       售票")));
        lst.add(new Thread(new Tickets2("手机APP 售票")));
        lst.add(new Thread(new Tickets2("实地窗口售票")));

        // 随机产生一个客户端类型
        Random rdom = new Random();
        // 设置一个线程池
        ExecutorService es = Executors.newFixedThreadPool(100);
        // 模拟有 15个客户端 来购票
        for (int i = 0; i < 15; i++) {
            int index = rdom.nextInt(3);
            Thread thread = lst.get(index);
            // 购票线程进入线程池
            es.submit(thread);
        }
        // 关闭线程池
        es.shutdown();
    }
}

/**
 * 
 * @author lztkdr
 *
 */
class Tickets2 implements Runnable {

    // 安全锁对象
    public static Lock locker = new ReentrantLock();

    // 静态的票总数(固定)
    public static int TicketCount = 10;

    public String name;

    /**
     * 
     * @param name
     *            客户端 票源
     */
    public Tickets2(String name) {
        this.name = name;
    }

    @Override
    public void run() {
        // 线程锁 队列式 售票
        locker.lock();
        try {
            // 模拟购票需要200毫秒
            Thread.sleep(200);
            if (TicketCount > 0) {
                System.out.println(this.name + "\\t出售1一张，剩余\\t " + (--TicketCount));
            } else {
                System.out.println(this.name + "\\t沒有抢到票！！！");
            }

        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            locker.unlock();
        }
    }
}