honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

sync with latest guava version of abstract future

This commit is contained in:
Shay Banon 2012-09-07 11:13:43 +02:00
parent dd970752e7
commit fbd352b448
1 changed files with 13 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/main/java/org/elasticsearch/common/util/concurrent/BaseFuture.java
View File

@ -335,22 +335,28 @@ public abstract class BaseFuture<V> implements Future<V> {
* Implementation of completing a task. Either {@code v} or {@code t} will * Implementation of completing a task. Either {@code v} or {@code t} will
* be set but not both. The {@code finalState} is the state to change to * be set but not both. The {@code finalState} is the state to change to
* from {@link #RUNNING}. If the state is not in the RUNNING state we * from {@link #RUNNING}. If the state is not in the RUNNING state we
* return {@code false}. * return {@code false} after waiting for the state to be set to a valid
* final state ({@link #COMPLETED} or {@link #CANCELLED}).
* *
* @param v the value to set as the result of the computation. * @param v the value to set as the result of the computation.
* @param t the exception to set as the result of the computation. * @param t the exception to set as the result of the computation.
* @param finalState the state to transition to. * @param finalState the state to transition to.
*/ */
private boolean complete(@Nullable V v, Throwable t, int finalState) { private boolean complete(@Nullable V v, @Nullable Throwable t,
if (compareAndSetState(RUNNING, COMPLETING)) { int finalState) {
boolean doCompletion = compareAndSetState(RUNNING, COMPLETING);
if (doCompletion) {
// If this thread successfully transitioned to COMPLETING, set the value
// and exception and then release to the final state.
this.value = v; this.value = v;
this.exception = t; this.exception = t;
releaseShared(finalState); releaseShared(finalState);
return true; } else if (getState() == COMPLETING) {
// If some other thread is currently completing the future, block until
// they are done so we can guarantee completion.
acquireShared(-1);
} }
return doCompletion;
// The state was not RUNNING, so there are no valid transitions.
return false;
} }
} }
} }