docs: public static <T extends ArbitrateLifeCycle> T getInstance(Long pipelineId, Class<T> instanceClass) {
          // Map<Class, Object> resources = cache.get(pipelineId);
          // if (resources == null) {
          // synchronized (cache) {// 锁住一下
          // if (!cache.containsKey(pipelineId)) {// double check
          // resources = new ConcurrentHashMap<Class, Object>();
          // cache.put(pipelineId, resources);
          // } else {
          // resources = cache.get(pipelineId);
          // }
          // }
          // }
          // Object obj = resources.get(instanceClass);
          // if (obj == null) {
          // synchronized (instanceClass) {// 锁住class对象
          // if (!resources.containsKey(instanceClass)) { // double check
          // obj = newInstance(instanceClass, pipelineId);// 通过反射调用构造函数进行初始化
          // autowire(obj);
          // resources.put(instanceClass, obj);
          // } else {
          // obj = resources.get(instanceClass);
          // }
          // }
          // }
          // return (T) obj;
  
          return (T) cache.get(pipelineId).get(instanceClass);
      }