|
|
@ -227,11 +227,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);
|
|
|
|
});
|
|
|
|
});
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|