summaryrefslogtreecommitdiffstats
path: root/messagebus
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2021-09-25 13:18:20 +0200
committerHenning Baldersheim <balder@yahoo-inc.com>2021-09-25 13:18:20 +0200
commit7d95dc97ab60e1e1fc95a55378a0e90fbc1b68d7 (patch)
tree373e1c8c6d8e32be4d666e1e3f661e5c01af4b86 /messagebus
parent0e54ad277430f556b490ec312fc9dc24bad9bce0 (diff)
Simplify with computeIfAbsent
Diffstat (limited to 'messagebus')
-rwxr-xr-xmessagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCServicePool.java8
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() {