11

私のアプリケーションではScheduledExecutorServiceを使用していますが、スケジュールされたタスクを処理するために1つのスレッドのみが生成されます。これは、ScheduledExecutorServiceが保留中のタスクを処理するためのスレッドを生成しないためですか？

これは、予想される「run（）1」の後に「run（）2」...「run（）10」が続くのではなく、「run（）1」のみを出力するコードスニペットです。

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

でスレッドプールを作成するため、スレッドは1つだけです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 に答える