Próbuję użyć ThreadPoolExecutorklasy Javy do uruchamiania dużej liczby ciężkich zadań z ustaloną liczbą wątków. Każde z zadań ma wiele miejsc, w których może się nie powieść z powodu wyjątków. Podklasowałem ThreadPoolExecutori przesłoniłem afterExecutemetodę, która ma zapewnić nieprzechwycone...
newCachedThreadPool() przeciw newFixedThreadPool() Kiedy powinienem użyć jednego lub drugiego? Która strategia jest lepsza pod względem wykorzystania
Powiedzmy, że mam kolejkę pełną zadań, które muszę przesłać do usługi wykonawczej. Chcę, aby były przetwarzane pojedynczo. Najprościej przychodzi mi do głowy: Weź zadanie z kolejki Prześlij go do wykonawcy Wywołaj .get na zwróconym Future i blokuj, aż wynik będzie dostępny Weź kolejne zadanie z...
Wydaje się, że niemożliwe jest utworzenie buforowanej puli wątków z ograniczeniem liczby wątków, które może ona utworzyć. Oto jak static Executors.newCachedThreadPool jest zaimplementowane w standardowej bibliotece Java: public static ExecutorService newCachedThreadPool() { return new...
Jaka dokładnie jest różnica między wielkością puli podstawowej a maksymalnym rozmiarem puli, gdy mówimy o ThreadPoolExecutor? Czy można to wyjaśnić na przykładzie?
Chcę stworzyć ThreadPoolExecutortaki, który po osiągnięciu maksymalnego rozmiaru i zapełnieniu kolejki submit()metoda blokuje się przy próbie dodania nowych zadań. Czy muszę zaimplementować w RejectedExecutionHandlertym celu niestandardowy sposób , czy też istnieje istniejący sposób, aby to...
Od jakiegoś czasu byłem sfrustrowany domyślnym zachowaniem, ThreadPoolExecutorktóre wspiera ExecutorServicepule wątków, których używa tak wielu z nas. Cytat z Javadocs: Jeśli jest więcej uruchomionych wątków niż corePoolSize, ale mniej niż maximumPoolSize, nowy wątek zostanie utworzony tylko...