Naf*_*Kay 4 java executorservice threadpool
是否有任何java.util.ExecutorService实现只是在调用线程中运行所有已执行的任务?如果默认情况下这不包含在Java中,那么是否有一个包含这样的实现的库?
您可以使用Guava com.google.common.util.concurrent.MoreExecutors.sameThreadExecutor()完全按照您的要求执行操作:https://github.com/google/guava/blob/0434c5199c83c3f43b8b6a86c62e121d518fe7d0/guava/src/com/google/通用/ UTIL /并发/ MoreExecutors.java#L267
编辑:该方法已重命名为com.google.common.util.concurrent.MoreExecutors.newDirectExecutorService() https://github.com/google/guava/blob/f67ab864bde63fa6602b5688de0440957ffeaa2e/guava/src/com/google/common/util /concurrent/MoreExecutors.java#L369
我能找到的唯一现有实现是SynchronousExecutorService- 不幸的是埋在骆驼库的某个地方。
将源代码(不带注释)粘贴到此处以供将来参考:
package org.apache.camel.util.concurrent;
import java.util.List;
import java.util.concurrent.AbstractExecutorService;
import java.util.concurrent.TimeUnit;
public class SynchronousExecutorService extends AbstractExecutorService {
private volatile boolean shutdown;
public void shutdown() {
shutdown = true;
}
public List<Runnable> shutdownNow() {
return null;
}
public boolean isShutdown() {
return shutdown;
}
public boolean isTerminated() {
return shutdown;
}
public boolean awaitTermination(long time, TimeUnit unit) throws InterruptedException {
return true;
}
public void execute(Runnable runnable) {
runnable.run();
}
}
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
2142 次 |
| 最近记录: |