【Hystrix权威指南四】Hystrix隔离策略源码分析二
微服务设计，高并发高可用系统组件
·
信号隔离
TryableSemaphore
接口定义了信号隔离的行为，内部借助AtomicInteger类实现资源的分配。HystrixProperty<Integer> numberOfPermits 存储可分配的资源，AtomicInteger count存储已分配的资源。numberOfPermits 在类初始化时就需要赋值，所以定义成了final类型。
protected final HystrixProperty<Integer> numberOfPermits;
private final AtomicInteger count = new AtomicInteger(0);
申请资源
tryAcquire（）负责资源的分配。有资源申请请求时，对count执行incrementAndGet()操作，如果返回值大于numberOfPermits的值，则进行decrementAndGet进行回退刚才的加一操作，并返回false，表示申请资源失败；如果返回值不大于numberOfPermits的值，则表示申请资源成功，返回true。详见代码：
@Override
public boolean tryAcquire() {
int currentCount = count.incrementAndGet();
if (currentCount > numberOfPermits.get()) {
count.decrementAndGet();
return false;
} else {
return true;
}
public boolean tryAcquire() {
int currentCount = count.incrementAndGet();
if (currentCount > numberOfPermits.get()) {
count.decrementAndGet();
return false;
} else {
return true;
}
}
释放资源
逻辑执行完成后，要进行资源的释放，以便让其他线程获得资源。release()负责资源的释放。有资源释放请求时，对count进行decrementAndGet()操作。
同一个业务不同的资源依赖时，可以选择信号量隔离，降低线程调度带来的性能消耗。
到此，信号量资源的申请和释放讲完了。
权威｜前沿｜技术｜干货｜国内首个API全生命周期开发者社区
更多推荐
3
0- 0
已为社区贡献4条内容
所有评论(0)