Java并发编程：Lock锁实现线程安全的卖票案例

在多线程编程中，保证线程安全是一个非常重要的问题。当多个线程同时访问共享资源时，就可能会出现数据竞争的问题，导致程序运行结果不正确。为了解决这个问题，Java提供了一系列的同步机制，其中Lock锁就是一种常用的解决方案。

本文将以一个经典的卖票案例为例，讲解如何使用Java Lock锁实现线程安全的卖票系统。

1. 问题描述

假设有一个售票系统，共有100张票，现在开启三个窗口同时售票。要求每个窗口都能售卖成功，并且最终售出的总票数不能超过100张。

2. 使用Lock锁解决思路

为了保证线程安全，我们需要在代码中添加同步机制，确保同一时刻只有一个线程能够执行卖票操作。这里我们可以使用Java中的Lock接口和ReentrantLock类来实现锁的功能。

具体步骤如下：

创建一个ReentrantLock对象，用于控制对共享资源的访问。
在执行卖票操作之前，先获取锁。
如果获取锁成功，则执行卖票操作，并将剩余票数减1。
卖票操作执行完毕后，释放锁。

3. 代码实现

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

public class TicketSeller implements Runnable {
    private int tickets = 100; // 票总数
    private Lock lock = new ReentrantLock(); // 创建一个ReentrantLock对象

    @Override
    public void run() {
        while (true) {
            sellTicket(); // 调用卖票方法
            if (tickets <= 0) {
                break;
            }
        }
    }

    // 卖票方法
    private void sellTicket() {
        lock.lock(); // 获取锁
        try {
            if (tickets > 0) {
                System.out.println(Thread.currentThread().getName() + '卖出了第' + tickets + '张票');
                tickets--;
            }
        } finally {
            lock.unlock(); // 释放锁
        }
    }

    public static void main(String[] args) {
        TicketSeller ticketSeller = new TicketSeller();
        Thread thread1 = new Thread(ticketSeller, '窗口1');
        Thread thread2 = new Thread(ticketSeller, '窗口2');
        Thread thread3 = new Thread(ticketSeller, '窗口3');
        thread1.start();
        thread2.start();
        thread3.start();
    }
}

代码解读:

我们将卖票操作封装到sellTicket()方法中，并在该方法内部使用lock.lock()获取锁，使用lock.unlock()释放锁。
try...finally语句块保证了锁的释放，即使在卖票过程中出现异常也能正常释放锁，避免死锁。

4. 总结

通过使用Lock锁，我们成功地实现了线程安全的卖票系统，确保了数据的正确性。在实际开发中，我们应该根据具体情况选择合适的同步机制，以保证程序的正确性和效率。