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;
}
}