aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/test/java/com/google/devtools/build/lib/concurrent/KeyedLockerTest.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/test/java/com/google/devtools/build/lib/concurrent/KeyedLockerTest.java')
-rw-r--r--src/test/java/com/google/devtools/build/lib/concurrent/KeyedLockerTest.java21
1 files changed, 12 insertions, 9 deletions
diff --git a/src/test/java/com/google/devtools/build/lib/concurrent/KeyedLockerTest.java b/src/test/java/com/google/devtools/build/lib/concurrent/KeyedLockerTest.java
index c6b94615c1..9370aeafe5 100644
--- a/src/test/java/com/google/devtools/build/lib/concurrent/KeyedLockerTest.java
+++ b/src/test/java/com/google/devtools/build/lib/concurrent/KeyedLockerTest.java
@@ -24,20 +24,19 @@ import com.google.devtools.build.lib.concurrent.KeyedLocker.AutoUnlocker;
import com.google.devtools.build.lib.concurrent.KeyedLocker.AutoUnlocker.IllegalUnlockException;
import com.google.devtools.build.lib.testutil.TestUtils;
import com.google.devtools.build.lib.util.Preconditions;
-
-import org.junit.After;
-import org.junit.Before;
-import org.junit.Test;
-
import java.util.HashSet;
import java.util.Set;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
+import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicReference;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
/** Base class for tests for {@link KeyedLocker} implementations. */
public abstract class KeyedLockerTest {
@@ -163,7 +162,8 @@ public abstract class KeyedLockerTest {
}
};
for (int i = 0; i < NUM_EXECUTOR_THREADS; i++) {
- executorService.submit(wrapper.wrap(runnable));
+ @SuppressWarnings("unused")
+ Future<?> possiblyIgnoredError = executorService.submit(wrapper.wrap(runnable));
}
boolean interrupted = ExecutorUtil.interruptibleShutdown(executorService);
Throwables.propagateIfPossible(wrapper.getFirstThrownError());
@@ -208,8 +208,10 @@ public abstract class KeyedLockerTest {
}
}
};
- executorService.submit(wrapper.wrap(runnable1));
- executorService.submit(wrapper.wrap(runnable2));
+ @SuppressWarnings("unused")
+ Future<?> possiblyIgnoredError = executorService.submit(wrapper.wrap(runnable1));
+ @SuppressWarnings("unused")
+ Future<?> possiblyIgnoredError1 = executorService.submit(wrapper.wrap(runnable2));
boolean interrupted = ExecutorUtil.interruptibleShutdown(executorService);
Throwables.propagateIfPossible(wrapper.getFirstThrownError());
if (interrupted || runnableInterrupted.get()) {
@@ -262,7 +264,8 @@ public abstract class KeyedLockerTest {
}
};
for (int i = 0; i < NUM_EXECUTOR_THREADS; i++) {
- executorService.submit(wrapper.wrap(runnable));
+ @SuppressWarnings("unused")
+ Future<?> possiblyIgnoredError = executorService.submit(wrapper.wrap(runnable));
}
boolean interrupted = ExecutorUtil.interruptibleShutdown(executorService);
Throwables.propagateIfPossible(wrapper.getFirstThrownError());