Allow other ExecutorService implementations in AbstractQueueVisitor

Previously, only ThreadPoolExecutor implementations were allowed.

--
MOS_MIGRATED_REVID=105340237

1 files changed, 61 insertions, 0 deletions

diff --git a/src/main/java/com/google/devtools/build/lib/concurrent/ExecutorParams.java b/src/main/java/com/google/devtools/build/lib/concurrent/ExecutorParams.java
new file mode 100644
index 0000000000..c06144c8df
--- /dev/null
+++ b/src/main/java/com/google/devtools/build/lib/concurrent/ExecutorParams.java
@@ -0,0 +1,61 @@
+// Copyright 2014 The Bazel Authors. All rights reserved.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//    http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package com.google.devtools.build.lib.concurrent;
+
+import java.util.concurrent.BlockingQueue;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.TimeUnit;
+
+/** Configuration parameters for {@link ExecutorService} construction. */
+public class ExecutorParams {
+  private final int parallelism;
+  private final long keepAliveTime;
+  private final TimeUnit units;
+  private final String poolName;
+  private final BlockingQueue<Runnable> workQueue;
+
+  public ExecutorParams(
+      int parallelism,
+      long keepAliveTime,
+      TimeUnit units,
+      String poolName,
+      BlockingQueue<Runnable> workQueue) {
+    this.parallelism = parallelism;
+    this.keepAliveTime = keepAliveTime;
+    this.units = units;
+    this.poolName = poolName;
+    this.workQueue = workQueue;
+  }
+
+  public int getParallelism() {
+    return parallelism;
+  }
+
+  public long getKeepAliveTime() {
+    return keepAliveTime;
+  }
+
+  public TimeUnit getUnits() {
+    return units;
+  }
+
+  public String getPoolName() {
+    return poolName;
+  }
+
+  public BlockingQueue<Runnable> getWorkQueue() {
+    return workQueue;
+  }
+}