@Service
public class StockService {
    // 模擬數(shù)據(jù)庫中的庫存（實際開發(fā)中用數(shù)據(jù)庫或緩存）
    private int stock = 10;

    // 下單扣減庫存（synchronized保證同一時刻只有1個線程執(zhí)行）
    public synchronized boolean deductStock(int productId, int count) {
        // 檢查庫存是否足夠
        if (stock < count) {
            return false; // 庫存不足
        }
        // 模擬業(yè)務(wù)耗時（如查詢數(shù)據(jù)庫、記錄日志）
        try {
            Thread.sleep(100);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
        // 扣減庫存
        stock -= count;
        System.out.println("扣減成功，剩余庫存：" + stock);
        return true;
    }
}

@Service
public class StockService {
    private int stock = 10;
    // 顯式鎖（可重入鎖，支持公平/非公平）
    private final ReentrantLock lock = new ReentrantLock();

    public boolean deductStock(int productId, int count) {
        // 嘗試加鎖（最多等待2秒，避免死鎖）
        try {
            if (lock.tryLock(2, TimeUnit.SECONDS)) {
                if (stock >= count) {
                    Thread.sleep(100); // 模擬業(yè)務(wù)耗時
                    stock -= count;
                    System.out.println("扣減成功，剩余庫存：" + stock);
                    return true;
                } else {
                    System.out.println("庫存不足");
                    return false;
                }
            } else {
                System.out.println("獲取鎖超時");
                return false;
            }
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            return false;
        } finally {
            // 必須在finally中釋放鎖（避免異常導致鎖未釋放）
            lock.unlock();
        }
    }
}

@Service
public class StockService {
    @Autowired
    private RedissonClient redissonClient;

    // 模擬數(shù)據(jù)庫庫存（實際用數(shù)據(jù)庫或緩存，如Redis存儲庫存）
    private int stock = 10;

    public boolean deductStock(int productId, int count) {
        // 定義鎖的名稱（按商品ID隔離，不同商品用不同鎖）
        String lockKey = "lock:product:" + productId;
        RLock lock = redissonClient.getLock(lockKey);

        try {
            // 加鎖（自動續(xù)期，防止業(yè)務(wù)耗時過長鎖過期）
            // waitTime: 等待鎖的最大時間（5秒）
            // leaseTime: 鎖自動釋放時間（30秒，防止死鎖）
            boolean locked = lock.tryLock(5, 30, TimeUnit.SECONDS);
            if (!locked) {
                System.out.println("獲取鎖失敗，稍后再試");
                return false;
            }

            // 檢查并扣減庫存
            if (stock >= count) {
                Thread.sleep(100); // 模擬業(yè)務(wù)耗時
                stock -= count;
                System.out.println("扣減成功，剩余庫存：" + stock);
                return true;
            } else {
                System.out.println("庫存不足");
                return false;
            }
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            return false;
        } finally {
            // 釋放鎖（只有自己加的鎖才能釋放）
            if (lock.isHeldByCurrentThread()) {
                lock.unlock();
            }
        }
    }
}