diff options
author | kush <kush@google.com> | 2018-05-04 08:55:27 -0700 |
---|---|---|
committer | Copybara-Service <copybara-piper@google.com> | 2018-05-04 08:56:39 -0700 |
commit | ba6a7d45755a2552ebcb4bf5915b4c44a4405275 (patch) | |
tree | e63172b392b96d20804a76e4e1367bbc337e2568 /src/main/java/com/google/devtools/build/lib/exec | |
parent | 30eb98352a00095b0e41e2272563a967f3117fc2 (diff) |
Kill Legacy Fileset implementation.
RELNOTES: None
PiperOrigin-RevId: 195422399
Diffstat (limited to 'src/main/java/com/google/devtools/build/lib/exec')
-rw-r--r-- | src/main/java/com/google/devtools/build/lib/exec/FilesetActionContextImpl.java | 36 |
1 files changed, 3 insertions, 33 deletions
diff --git a/src/main/java/com/google/devtools/build/lib/exec/FilesetActionContextImpl.java b/src/main/java/com/google/devtools/build/lib/exec/FilesetActionContextImpl.java index d21b27069e..6371352788 100644 --- a/src/main/java/com/google/devtools/build/lib/exec/FilesetActionContextImpl.java +++ b/src/main/java/com/google/devtools/build/lib/exec/FilesetActionContextImpl.java @@ -14,14 +14,9 @@ package com.google.devtools.build.lib.exec; import com.google.common.collect.ImmutableList; -import com.google.common.util.concurrent.ThreadFactoryBuilder; import com.google.devtools.build.lib.actions.ActionContext; import com.google.devtools.build.lib.actions.ExecutionStrategy; -import com.google.devtools.build.lib.events.Reporter; import com.google.devtools.build.lib.rules.fileset.FilesetActionContext; -import java.util.concurrent.LinkedBlockingQueue; -import java.util.concurrent.ThreadPoolExecutor; -import java.util.concurrent.TimeUnit; /** * Context for Fileset manifest actions. It currently only provides a ThreadPoolExecutor. @@ -38,49 +33,24 @@ public final class FilesetActionContextImpl implements FilesetActionContext { */ public static class Provider extends ActionContextProvider { private FilesetActionContextImpl impl; - private final Reporter reporter; - private final ThreadPoolExecutor filesetPool; - public Provider(Reporter reporter, String workspaceName) { - this.reporter = reporter; - this.filesetPool = newFilesetPool(100); - this.impl = new FilesetActionContextImpl(filesetPool, workspaceName); - } - - private static ThreadPoolExecutor newFilesetPool(int threads) { - ThreadPoolExecutor pool = new ThreadPoolExecutor(threads, threads, 3L, TimeUnit.SECONDS, - new LinkedBlockingQueue<Runnable>()); - // Do not consume threads when not in use. - pool.allowCoreThreadTimeOut(true); - pool.setThreadFactory(new ThreadFactoryBuilder().setNameFormat("Fileset worker %d").build()); - return pool; + public Provider(String workspaceName) { + this.impl = new FilesetActionContextImpl(workspaceName); } @Override public Iterable<? extends ActionContext> getActionContexts() { return ImmutableList.of(impl); } - - @Override - public void executionPhaseEnding() { - BlazeExecutor.shutdownHelperPool(reporter, filesetPool, "Fileset"); - } } - private final ThreadPoolExecutor filesetPool; private final String workspaceName; - private FilesetActionContextImpl(ThreadPoolExecutor filesetPool, String workspaceName) { - this.filesetPool = filesetPool; + private FilesetActionContextImpl(String workspaceName) { this.workspaceName = workspaceName; } @Override - public ThreadPoolExecutor getFilesetPool() { - return filesetPool; - } - - @Override public String getWorkspaceName() { return workspaceName; } |