diff options
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.java | 21 |
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()); |