private ProducerBatchHolder getOrCreateProducerBatchHolder()

in src/main/java/com/aliyun/openservices/aliyun/log/producer/internals/LogAccumulator.java [263:275]


  private ProducerBatchHolder getOrCreateProducerBatchHolder(GroupKey groupKey) {
    ProducerBatchHolder holder = batches.get(groupKey);
    if (holder != null) {
      return holder;
    }
    holder = new ProducerBatchHolder();
    ProducerBatchHolder previous = batches.putIfAbsent(groupKey, holder);
    if (previous == null) {
      return holder;
    } else {
      return previous;
    }
  }