Read the Atomic reference variable in the loop to avoid cpu run off. (#…

…201)
Netflix · Feb 1, 2018 · 21fe6ed · 21fe6ed
1 parent 7ada67c
commit 21fe6ed
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/dyno-core/src/main/java/com/netflix/dyno/connectionpool/impl/RetryNTimes.java b/dyno-core/src/main/java/com/netflix/dyno/connectionpool/impl/RetryNTimes.java
@@ -46,17 +46,19 @@ public void begin() {
 	@Override
 	public void success() {
 		boolean success = false;
-		RetryState rs = state.get();
+		RetryState rs;
 		while (!success) {
+			rs = state.get();
 			success = state.compareAndSet(rs, new RetryState(rs.count + 1, true));
 		}
 	}
 
 	@Override
 	public void failure(Exception e) {
 		boolean success = false;
-		RetryState rs = state.get();
+		RetryState rs;
 		while (!success) {
+			rs = state.get();
 			success = state.compareAndSet(rs, new RetryState(rs.count + 1, false));
 		}
 	}