核心目标是避免在资源不可用、状态失效或上下文销毁时尝试获取信号量;需守卫持有者对象生命周期、共享资源可用性及调用上下文时效性,并将多重守卫封装为原子性 acquire 入口。

在调用 Semaphore.acquire() 前做多重条件守卫,核心目标不是“防止引用提前断开”(Java 中引用断开由 GC 控制,不可主动“守卫”),而是**避免在资源已不可用、状态已失效或上下文已销毁时,仍尝试获取信号量并执行后续逻辑**——这会导致空指针、竞态、业务语义错误或资源泄漏。
守卫「持有者对象」的生命周期有效性
如果闭包(如 Runnable、Consumer 或 lambda)捕获了外部对象(如 Activity、Fragment、Service、Callback 等),需确保该对象在 acquire 成功后依然存活且可安全使用:
- 对 Android 组件:检查
isFinishing()+isDestroyed()(API 28+)或getLifecycle().getCurrentState().isAtLeast(Lifecycle.State.STARTED) - 对自定义回调/监听器:引入弱引用包装(
WeakReference<callback></callback>),并在闭包开头立即解包并判空:
Callback cb = callbackRef.get(); if (cb == null) return; - 对非 UI 对象(如 Repository、Worker):若其内部维护了可关闭状态(如 Channel、Connection),应暴露
isClosed()或isValid()方法并参与守卫
守卫「共享资源」的可用前提
Semaphore 表达的是并发许可,但不表达资源本身的健康状态。需在 acquire 前确认底层依赖就绪:
- 检查连接状态:如数据库连接池是否 active、网络客户端是否 connected、文件句柄是否 open
- 检查配置/元数据就绪:如必要配置项是否加载完成、schema 是否已 migrate、密钥是否已初始化
- 用原子布尔标记兜底:
if (!resourceReady.get()) { log.warn("Skip acquire: resource not ready"); return; }
守卫「调用上下文」的时效性与一致性
避免 acquire 成功后,因上下文过期导致操作失去意义:
- 绑定超时时间戳:传入一个
deadlineNs,在 acquire 前比较System.nanoTime() > deadlineNs,超时则跳过 - 校验版本/序列号:如请求携带 versionId,闭包执行前比对当前活跃 version 是否匹配,不匹配则放弃
- 检查取消信号:若使用
CancellationException或AtomicBoolean cancelled,在 acquire 前轮询一次
把守卫逻辑封装进受控的 acquire 流程
不要把守卫散落在调用点,而是封装为原子性更强的入口方法:
public <t> void guardedAcquire(Consumer<t> action, T context, Supplier<boolean> precheck) {
if (!precheck.get()) return;
try {
if (semaphore.tryAcquire(1, 100, TimeUnit.MILLISECONDS)) {
try {
action.accept(context);
} finally {
semaphore.release();
}
}
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
}</boolean></t></t>
其中 precheck 可组合多个守卫:生命周期 + 资源状态 + 上下文有效性,全部通过才进入 acquire 竞争。











