summaryrefslogtreecommitdiffstats
path: root/libjava/classpath/external/jsr166/java/util/concurrent/FutureTask.java
diff options
context:
space:
mode:
Diffstat (limited to 'libjava/classpath/external/jsr166/java/util/concurrent/FutureTask.java')
-rw-r--r--libjava/classpath/external/jsr166/java/util/concurrent/FutureTask.java54
1 files changed, 27 insertions, 27 deletions
diff --git a/libjava/classpath/external/jsr166/java/util/concurrent/FutureTask.java b/libjava/classpath/external/jsr166/java/util/concurrent/FutureTask.java
index bbe49d7aed0..94742405dec 100644
--- a/libjava/classpath/external/jsr166/java/util/concurrent/FutureTask.java
+++ b/libjava/classpath/external/jsr166/java/util/concurrent/FutureTask.java
@@ -233,59 +233,59 @@ public class FutureTask<V> implements RunnableFuture<V> {
}
void innerSet(V v) {
- for (;;) {
- int s = getState();
- if (s == RAN)
- return;
+ for (;;) {
+ int s = getState();
+ if (s == RAN)
+ return;
if (s == CANCELLED) {
- // aggressively release to set runner to null,
- // in case we are racing with a cancel request
- // that will try to interrupt runner
+ // aggressively release to set runner to null,
+ // in case we are racing with a cancel request
+ // that will try to interrupt runner
releaseShared(0);
return;
}
- if (compareAndSetState(s, RAN)) {
+ if (compareAndSetState(s, RAN)) {
result = v;
releaseShared(0);
done();
- return;
+ return;
}
}
}
void innerSetException(Throwable t) {
- for (;;) {
- int s = getState();
- if (s == RAN)
- return;
+ for (;;) {
+ int s = getState();
+ if (s == RAN)
+ return;
if (s == CANCELLED) {
- // aggressively release to set runner to null,
- // in case we are racing with a cancel request
- // that will try to interrupt runner
+ // aggressively release to set runner to null,
+ // in case we are racing with a cancel request
+ // that will try to interrupt runner
releaseShared(0);
return;
}
- if (compareAndSetState(s, RAN)) {
+ if (compareAndSetState(s, RAN)) {
exception = t;
result = null;
releaseShared(0);
done();
- return;
+ return;
}
- }
+ }
}
boolean innerCancel(boolean mayInterruptIfRunning) {
- for (;;) {
- int s = getState();
- if (ranOrCancelled(s))
- return false;
- if (compareAndSetState(s, CANCELLED))
- break;
- }
+ for (;;) {
+ int s = getState();
+ if (ranOrCancelled(s))
+ return false;
+ if (compareAndSetState(s, CANCELLED))
+ break;
+ }
if (mayInterruptIfRunning) {
Thread r = runner;
- if (r != null)
+ if (r != null)
r.interrupt();
}
releaseShared(0);
OpenPOWER on IntegriCloud