Jak rozmiar basenu faktycznie działa z zaplanowanymi zadaniami Spring?

Question

mam zadanie zaplanowane jako takie:

<task:scheduler id="notification.scheduler" pool-size="15" /> 

<task:scheduled-tasks scheduler="notification.scheduler"> 
    <task:scheduled ref="notificationProcessor" method="sendNextQueueEvent" fixed-rate="500" /> 
    <task:scheduled ref="notificationProcessor" method="deleteNextCompletedEvent" fixed-rate="60000" /> 
</task:scheduled-tasks> 

Chyba mam nieporozumienie, w jaki sposób zaplanowane zadania pracy z wielkości basenu. Pomimo tego, że rozmiar basenu wynosi 15, wydaje się, że używany jest tylko jeden wątek. Na przykład, jeśli mam piętnaście zdarzeń w kolejce, myślę, że będzie piętnaście wątków sprawdzających co minutę, aby usunąć zdarzenie z kolejki. Oczywiście, to jest złe.

Jak mogę to zrobić, aby piętnaście wątków wywoływał tę metodę dla przedziału czasu z wykorzystaniem abstrakcji programu Spring Spring?

Edycja: Chcę osiągnąć to: co pół sekundy, chcę sprawdzić, czy istnieją oczekujące w kolejce zdarzenia do wysłania. Kiedy to nastąpi, chcę wysłać maksymalnie 15 (jeśli 15 istnieje). W jaki sposób osiągnąć to przy użyciu abstrakcji wiosny dla rzeczy wątku java?

Answer 1

sprężyny task:scheduler jest domyślnie właściwości fasoli wrapper dla java.util.concurrent.ThreadPoolExecutor:

corePoolSize - liczba wątków, aby utrzymać się w basenie, nawet jeśli są bezczynne.

to nie gwarantuje, że nieruchomość pools-size jest równoważne posiadające taką liczbę aktywnych wątkach. Z drugiej strony, należy zauważyć, że pod dowolnym punktem w czasiemoże znajdować się tylko maksymalna liczba wątków równa liczbie rdzeni przetwarzających na komputerze, którego używasz; tj. wszystkie inne wątki będą czekać na przejście do trybu RUNNING i kontynuują wykonywanie.

Również w dokumentacji Spring wspomina, że ​​jeśli nie jest to to, czego potrzebujesz, możesz również skorzystać z ConcurrentTaskExecutor.

Answer 2

Przede wszystkim <task:scheduler/> to opakowanie o numerze ScheduledThreadPoolExecutor przedłużające ThreadPoolExecutor. JavaDoc dla tej ostatniej mówi:

nawet główne wątki są początkowo stworzony i uruchomiony tylko gdy nowe zadania przybyć

drugie musisz zrozumieć, że zaplanowane zadania (jest to cecha Java, nie sprężyny) nie uruchamiać jednocześnie, nawet jeśli zabierają więcej czasu niż interwał powtarzania. Po prostu czekają. Tak więc nie masz 15 zdarzeń czekających w kolejce, masz 15 wykonań, które są opóźnione i czekasz na ten pojedynczy wątek. Nie trzeba tworzyć kolejnego, ponieważ następna operacja musi poczekać na zakończenie poprzedniej. Ponownie, tak działa framework harmonogramu Java.

Oczywiście, jeśli zaplanowano kilka różnych zadań, zostanie utworzonych więcej wątków.