Spring/spring-boot-data-geode
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add synchronizaton block surrounding the TimeUnit.timedWait(..) invocation inside getResult(duration:long, :TimeUnit).

Browse Source
This commit is contained in:
John Blum
2018-05-23 20:00:52 -07:00
parent 126f386dfc
commit 1f8b98550d
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
geode-spring-boot-starter/src/main/java/org/springframework/data/gemfire/function/execution/AbstractResultCollector.java
View File

@@ -33,6 +33,8 @@ import org.apache.geode.cache.execute.ResultCollector;
@SuppressWarnings("unused")
public abstract class AbstractResultCollector<T, S> implements ResultCollector<T, S> {
private static final Object MUTEX = new Object();
protected static final String NOT_IMPLEMENTED = "Not Implemented";
protected static final TimeUnit DEFAULT_TIME_UNIT = TimeUnit.MILLISECONDS;
@@ -57,7 +59,9 @@ public abstract class AbstractResultCollector<T, S> implements ResultCollector<T
Math.min(durationInMilliseconds / 5, durationInMilliseconds));
while (getResult() == null && System.currentTimeMillis() < timeout) {
unit.timedWait(this, waitInMilliseconds);
synchronized (MUTEX) {
unit.timedWait(MUTEX, waitInMilliseconds);
}
}
return getResult();