refactor BlockingQueueTypeEnum

pull/1117/head
LiXuemin 3 years ago
parent f0ec4ec72f
commit 6095018d12

@ -234,11 +234,11 @@ public enum BlockingQueueTypeEnum {
.map(each -> each.generateBlockingQueue()) .map(each -> each.generateBlockingQueue())
.findFirst() .findFirst()
.orElseGet(() -> { .orElseGet(() -> {
Integer temCapacity = capacity; Integer tempCapacity = capacity;
if (capacity == null || capacity <= 0) { if (capacity == null || capacity <= 0) {
temCapacity = DEFAULT_CAPACITY; tempCapacity = DEFAULT_CAPACITY;
} }
return new LinkedBlockingQueue<T>(temCapacity); return new LinkedBlockingQueue<T>(tempCapacity);
}); });
} }

Loading…
Cancel
Save