【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;
            }
        }
 
释放资源
    逻辑执行完成后,要进行资源的释放,以便让其他线程获得资源。release()负责资源的释放。有资源释放请求时,对count进行decrementAndGet()操作。
 
      同一个业务不同的资源依赖时,可以选择信号量隔离,降低线程调度带来的性能消耗。
 
到此,信号量资源的申请和释放讲完了。
http://blog.csdn.net/a_fengzi_code_110/article/details/53643499

猜你喜欢

转载自m635674608.iteye.com/blog/2384868