Callable任务由线程池异步执行，其call()方法内同步调用Redisson的tryLock()可实现阻塞等待锁，配合看门狗自动续期，无需手动异步处理；锁必须在finally中安全释放。
在 Java 中，Callable 本身是同步执行的接口，但配合线程池（如 ExecutorService.submit()）可实现异步提交任务。若想在 Callable 逻辑中安全地获取 Redisson 分布式锁，并支持“等待锁释放”的语义（即阻塞式重试），关键不是让 Callable “异步等待”，而是：在 Callable 的 call() 方法内，**同步调用 Redisson 的可重入锁（如 RLock.lock()）**——该方法默认会阻塞等待，直到获取锁或超时，而整个 Callable 任务仍由线程池异步执行。
✅ 正确理解：异步的是任务提交，等待锁是同步阻塞
很多人误以为要“异步等待锁”，其实 Redisson 的 RLock.lock() 已内置重试与看门狗机制，它会在后台自动续期、阻塞等待，无需手动轮询或异步回调。你只需在 call() 里按需加锁即可：
-
lock()：阻塞获取，支持最大等待时间（如lock(10, TimeUnit.SECONDS)） -
tryLock()：非阻塞尝试，返回 boolean；也可带等待时间和持有时间（tryLock(waitTime, leaseTime, unit)） - 锁必须在
finally块中unlock()，防止死锁
? 示例：Callable + Redisson 分布式锁（带超时等待）
以下是一个完整、线程安全的示例：
// 1. 初始化 RedissonClient（单例）
Config config = new Config();
config.useSingleServer().setAddress("redis://127.0.0.1:6379");
RedissonClient redisson = Redisson.create(config);
// 2. 定义带分布式锁的 Callable
Callable<String> task = () -> {
RLock lock = redisson.getLock("my:lock:key");
try {
// 等待最多 5 秒，成功后自动续期（看门狗默认 30s）
if (lock.tryLock(5, 10, TimeUnit.SECONDS)) {
// ✅ 持有锁，执行业务逻辑（例如扣减库存、生成订单号等）
String result = "processed-by-" + Thread.currentThread().getName();
Thread.sleep(2000); // 模拟耗时操作
return result;
} else {
throw new RuntimeException("Failed to acquire lock within 5 seconds");
}
} finally {
// 必须确保释放锁（即使发生异常）
if (lock.isHeldByCurrentThread()) {
lock.unlock();
}
}
};
// 3. 异步提交任务
ExecutorService executor = Executors.newFixedThreadPool(4);
Future<String> future = executor.submit(task);
// 4. 主线程可选择同步获取结果（或继续做其他事）
System.out.println("Result: " + future.get()); // 阻塞直到 callable 执行完
⚠️ 关键注意事项
-
leaseTime 要合理：第二个参数（如
10秒）是锁自动释放时间，应略大于业务最大执行时间，避免误释放；Redisson 看门狗会自动续期，前提是客户端保持连接且未崩溃 - 不要在 lock() 后再 sleep 或长时间阻塞：这会延长锁持有时间，影响并发度；复杂流程建议拆解或用状态机控制
-
避免锁粒度太粗：例如用固定 key
"global:lock"会导致所有任务串行；应按业务维度设计 key，如"order:lock:" + orderId - 异常时务必检查 isHeldByCurrentThread()：防止 unlock() 被未持锁线程调用抛出 IllegalMonitorStateException
? 进阶：需要真正“异步不阻塞等待锁”？用 Redisson 的 RSemaphore 或 RCountDownLatch
如果业务场景确实要求“不阻塞当前线程，而是注册回调等锁可用”，Redisson 本身不直接提供 lockAsync() 的回调式加锁（v3.24+ 有 lockAsync(long, long, TimeUnit) 返回 RFuture<Void>），可结合 CompletableFuture 实现：
立即学习“Java免费学习笔记（深入）”；
RFuture<Void> lockFuture = lock.lockAsync(5, 10, TimeUnit.SECONDS);
CompletableFuture<String> asyncTask = lockFuture.thenCompose(v -> {
try {
// 锁已获取，执行业务
return CompletableFuture.completedFuture("success");
} finally {
lock.unlockAsync(); // 异步释放
}
});
但注意：这种方式绕过了看门狗自动续期（因 unlockAsync 不绑定续期上下文），更适合短时、确定性操作；生产环境仍推荐使用带看门狗的同步 tryLock。
