Introduce QuiescingExecutor

This interface (mostly) encapsulates what the ValueVisitor expects
from the AbstractQueueVisitor class it currently inherits from. This
makes it easier for a future CL to change ValueVisitor's strategy of
code reuse from inheritance to composition.

RELNOTES:

--
MOS_MIGRATED_REVID=106728863

1 files changed, 21 insertions, 19 deletions

diff --git a/src/test/java/com/google/devtools/build/lib/actions/MapBasedActionGraphTest.java b/src/test/java/com/google/devtools/build/lib/actions/MapBasedActionGraphTest.java
index 6d5a23e665..2dd07ed868 100644
--- a/src/test/java/com/google/devtools/build/lib/actions/MapBasedActionGraphTest.java
+++ b/src/test/java/com/google/devtools/build/lib/actions/MapBasedActionGraphTest.java
@@ -91,27 +91,29 @@ public class MapBasedActionGraphTest {
     }
 
     private void registerAction(final Action action) {
-      enqueue(new Runnable() {
-        @Override
-        public void run() {
-          try {
-            graph.registerAction(action);
-          } catch (ActionConflictException e) {
-            throw new UncheckedActionConflictException(e);
-          }
-          doRandom();
-        }
-      });
+      execute(
+          new Runnable() {
+            @Override
+            public void run() {
+              try {
+                graph.registerAction(action);
+              } catch (ActionConflictException e) {
+                throw new UncheckedActionConflictException(e);
+              }
+              doRandom();
+            }
+          });
     }
 
     private void unregisterAction(final Action action) {
-      enqueue(new Runnable() {
-        @Override
-        public void run() {
-          graph.unregisterAction(action);
-          doRandom();
-        }
-      });
+      execute(
+          new Runnable() {
+            @Override
+            public void run() {
+              graph.unregisterAction(action);
+              doRandom();
+            }
+          });
     }
 
     private void doRandom() {
@@ -134,7 +136,7 @@ public class MapBasedActionGraphTest {
     }
 
     private void work() throws InterruptedException {
-      work(/*failFastOnInterrupt=*/true);
+      awaitQuiescence(/*interruptWorkers=*/ true);
     }
   }