11

在我的应用程序中，我使用 ScheduledExecutorService，但只生成了一个线程来处理计划任务。这是因为 ScheduledExecutorService 没有产生线程来处理挂起的任务吗？

这是一个代码片段，它将仅输出“run() 1”而不是预期的“run() 1”，然后是“run() 2”...“run() 10”。

public class App {

    public static void main(String[] args) {
        int N = 10;
        Runnable runner = new Runnable() {

            public void run() {
                foo();
            }
        };
        for (int i = 0; i < N; i++) {
            executor.schedule(runner, i, TimeUnit.MILLISECONDS);
        }
    }

    private static void foo() {
        System.out.println("run() " + (++n));
        synchronized (executor) {
            try {
                executor.wait();
            } catch (InterruptedException ex) {
                Logger.getLogger(App.class.getName()).log(Level.SEVERE, null, ex);
            }
        }
        System.out.println("finished()");
    }
    private static Logger logger = Logger.getLogger(App.class.getName());
    private static int n = 0;
    private static ScheduledExecutorService executor = Executors.newScheduledThreadPool(1);
}
4

2 回答 2

15

只有一个线程，因为您使用创建线程池Executors.newScheduledThreadPool(1)，这意味着线程池仅包含 1 个线程。如果您想要 10 个线程，请将 10 作为参数传递。请注意，该方法返回的ScheduledThreadPoolExecutor的文档明确指出线程池具有固定大小。

于 2012-07-26T21:22:30.073 回答
6

从 javadoc 为ScheduledThreadPoolExecutor：

虽然这个类继承自 ThreadPoolExecutor，但一些继承的调优方法对它没有用。特别是，因为它充当使用 corePoolSize 线程和无界队列的固定大小的池，所以对 maximumPoolSize 的调整没有有用的效果。此外，将 corePoolSize 设置为零或使用 allowCoreThreadTimeOut 几乎不是一个好主意，因为这可能会使池没有线程来处理任务，一旦它们有资格运行。

换句话说，maximumPoolSize == corePoolSize. 您设置corePoolSize为1，这就是它会产生的全部内容。

于 2012-07-26T21:20:32.640 回答