diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2021-09-25 13:18:20 +0200 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2021-09-25 13:18:20 +0200 |
commit | 7d95dc97ab60e1e1fc95a55378a0e90fbc1b68d7 (patch) | |
tree | 373e1c8c6d8e32be4d666e1e3f661e5c01af4b86 /messagebus | |
parent | 0e54ad277430f556b490ec312fc9dc24bad9bce0 (diff) |
Simplify with computeIfAbsent
Diffstat (limited to 'messagebus')
-rwxr-xr-x | messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCServicePool.java | 8 |
1 files changed, 1 insertions, 7 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCServicePool.java b/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCServicePool.java index e4cfd0bc630..a666a03c401 100755 --- a/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCServicePool.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCServicePool.java @@ -38,13 +38,7 @@ public class RPCServicePool { */ public RPCServiceAddress resolve(String pattern) { - ServiceLRUCache cache = getPerThreadCache(); - RPCService service = cache.get(pattern); - if (service == null) { - service = RPCService.create(net.getMirror(), pattern); - cache.put(pattern, service); - } - return service.resolve(); + return getPerThreadCache().computeIfAbsent(pattern, (key) -> RPCService.create(net.getMirror(), key)).resolve(); } private ServiceLRUCache getPerThreadCache() { |