|
|
@ -71,11 +71,6 @@ public enum BlockingQueueTypeEnum {
|
|
|
|
return new LinkedBlockingDeque<>(capacity);
|
|
|
|
return new LinkedBlockingDeque<>(capacity);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
|
|
|
<T> BlockingQueue<T> of(Integer capacity) {
|
|
|
|
|
|
|
|
return new LinkedBlockingDeque<>(capacity);
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
|
<T> BlockingQueue<T> of() {
|
|
|
|
<T> BlockingQueue<T> of() {
|
|
|
|
return new LinkedBlockingDeque<>();
|
|
|
|
return new LinkedBlockingDeque<>();
|
|
|
@ -92,11 +87,6 @@ public enum BlockingQueueTypeEnum {
|
|
|
|
return new SynchronousQueue<>();
|
|
|
|
return new SynchronousQueue<>();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
|
|
|
<T> BlockingQueue<T> of(Integer capacity) {
|
|
|
|
|
|
|
|
return new SynchronousQueue<>();
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
|
<T> BlockingQueue<T> of() {
|
|
|
|
<T> BlockingQueue<T> of() {
|
|
|
|
return new SynchronousQueue<>();
|
|
|
|
return new SynchronousQueue<>();
|
|
|
@ -113,11 +103,6 @@ public enum BlockingQueueTypeEnum {
|
|
|
|
return new LinkedTransferQueue<>();
|
|
|
|
return new LinkedTransferQueue<>();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
|
|
|
<T> BlockingQueue<T> of(Integer capacity) {
|
|
|
|
|
|
|
|
return new LinkedTransferQueue<>();
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
|
<T> BlockingQueue<T> of() {
|
|
|
|
<T> BlockingQueue<T> of() {
|
|
|
|
return new LinkedTransferQueue<>();
|
|
|
|
return new LinkedTransferQueue<>();
|
|
|
|