Dlaczego nie ma zaplanowanej buforowanej puli wątków dostarczanej przez klasę Java Executors?

Question

Executors zapewnia newCachedThreadPool() i newScheduledThreadPool(), ale nie newCachedScheduledThreadPool(), co daje tutaj? Mam aplikację, która otrzymuje wiadomości masowe i musi zaplanować dość długi etap przetwarzania po ustalonym opóźnieniu dla każdego. Ograniczenia czasowe nie są super ścisłe, ale wolałbym, aby więcej wątków zostało utworzonych w locie, jeśli przekroczę rozmiar puli, a następnie będę je przycinał podczas okresów braku aktywności. Czy jest coś, co przegapiłem w równoległej bibliotece, czy muszę napisać własną?

Answer 1

java.util.concurrent.Executors to nic więcej niż zbiór statycznych metod wygody, które budują wspólne aranżacje wykonawców.

Jeśli potrzebujesz czegoś konkretnego, co nie jest oferowane przez Executors, możesz swobodnie zbudować własną instancję klas implementacji, korzystając z przykładów w Executors jako przewodnika.

Answer 2

Jak mówi skaffman, Executors to tylko zbiór metod fabrycznych. jeśli potrzebujesz konkretnej instancji, zawsze możesz sprawdzić wszystkie istniejące implementatory Executor. W twoim przypadku myślę, że dzwonienie do jednego z różnych konstruktorów ScheduledThreadPoolExecutor byłoby dobrym pomysłem.

Answer 3

Zgodnie z projektem element ScheduledThreadPoolExecutor ma ustalony rozmiar. Można użyć wersji z pojedynczym wątkiem, która przesyła do zwykłej usługi ExecutorService w celu wykonania zadania. Ten wątek zdarzenia + puli pracowników jest dość łatwy do koordynowania, a elastyczność nadrabia dedykowany wątek. Używałem tego w przeszłości, aby zastąpić TimerTasks i inne niekrytyczne zadania, aby wykorzystać typowy executor jako ogólnosystemową pulę.

Answer 4

Sugerowana tutaj Why does ScheduledThreadPoolExecutor only accept a fixed number of threads? Obejście:

scheduledExecutor = new ScheduledThreadPoolExecutor(128); //no more than 128 threads 
scheduledExecutor.setKeepAliveTime(10, TimeUnit.SECONDS); 
scheduledExecutor.allowCoreThreadTimeOut(true);