zervo/seb-server
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

made CircuitBreaker thread safe

Browse source
This commit is contained in:
anhefti 2021-05-12 08:11:41 +02:00
parent 5e4404c1b5
commit a46e2c0b27
2 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/main/java/ch/ethz/seb/sebserver/gbl/async/CircuitBreaker.java
View file

@ -121,7 +121,7 @@ public final class CircuitBreaker<T> {
return this.lastSuccessTime; return this.lastSuccessTime;
} }
public Result<T> protectedRun(final Supplier<T> supplier) { public synchronized Result<T> protectedRun(final Supplier<T> supplier) {
final long currentTime = System.currentTimeMillis(); final long currentTime = System.currentTimeMillis();
if (log.isDebugEnabled()) { if (log.isDebugEnabled()) {

2
src/main/java/ch/ethz/seb/sebserver/gbl/async/MemoizingCircuitBreaker.java
View file

@ -124,7 +124,7 @@ public final class MemoizingCircuitBreaker<T> implements Supplier<Result<T>> {
} }
@Override @Override
public Result<T> get() { public synchronized Result<T> get() {
final Result<T> result = this.delegate.protectedRun(this.supplier); final Result<T> result = this.delegate.protectedRun(this.supplier);
if (result.hasError()) { if (result.hasError()) {
if (this.memoizing && this.cached != null) { if (this.memoizing && this.cached != null) {