diff options
author | Martin Polden <mpolden@mpolden.no> | 2021-10-28 10:45:08 +0200 |
---|---|---|
committer | Martin Polden <mpolden@mpolden.no> | 2021-10-28 10:45:08 +0200 |
commit | 5c6cb12e12c5dc797531b53c1c659519c9f21b04 (patch) | |
tree | 24e86e2e0fad0fb57280347cde1e32c696c0c367 /controller-server | |
parent | 062c783e30399fad743aabeb892a362e168e788a (diff) |
Remove unnecessary use of LinkedBlockingDeque
Diffstat (limited to 'controller-server')
-rw-r--r-- | controller-server/src/main/java/com/yahoo/vespa/hosted/controller/dns/NameServiceQueue.java | 16 |
1 files changed, 6 insertions, 10 deletions
diff --git a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/dns/NameServiceQueue.java b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/dns/NameServiceQueue.java index 8a48cbd281d..af3d346b9a2 100644 --- a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/dns/NameServiceQueue.java +++ b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/dns/NameServiceQueue.java @@ -4,12 +4,10 @@ package com.yahoo.vespa.hosted.controller.dns; import com.yahoo.vespa.hosted.controller.api.integration.dns.NameService; import com.yahoo.yolean.Exceptions; -import java.util.ArrayList; -import java.util.Collection; import java.util.Collections; +import java.util.LinkedList; import java.util.List; import java.util.Objects; -import java.util.concurrent.LinkedBlockingDeque; import java.util.function.UnaryOperator; import java.util.logging.Level; import java.util.logging.Logger; @@ -28,17 +26,16 @@ public class NameServiceQueue { private static final Logger log = Logger.getLogger(NameServiceQueue.class.getName()); - private final LinkedBlockingDeque<NameServiceRequest> requests; + private final LinkedList<NameServiceRequest> requests; /** DO NOT USE. Public for serialization purposes */ - public NameServiceQueue(Collection<NameServiceRequest> requests) { - this.requests = new LinkedBlockingDeque<>(); - this.requests.addAll(Objects.requireNonNull(requests, "requests must be non-null")); + public NameServiceQueue(List<NameServiceRequest> requests) { + this.requests = new LinkedList<>(Objects.requireNonNull(requests, "requests must be non-null")); } /** Returns a view of requests in this queue */ - public Collection<NameServiceRequest> requests() { - return Collections.unmodifiableCollection(requests); + public List<NameServiceRequest> requests() { + return Collections.unmodifiableList(requests); } /** Returns a copy of this containing the last n requests */ @@ -99,7 +96,6 @@ public class NameServiceQueue { private NameServiceQueue resize(int n, UnaryOperator<List<NameServiceRequest>> resizer) { requireNonNegative(n); if (requests.size() <= n) return this; - List<NameServiceRequest> requests = new ArrayList<>(this.requests); return new NameServiceQueue(resizer.apply(requests)); } |