Comment la taille du pool de travailler avec le Printemps des tâches planifiées?

J'ai une tâche planifiée en tant que tel:

<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>

Je pense que j'ai une mauvaise compréhension de la façon dont les tâches planifiées de travail avec la taille du pool. En dépit de la taille du pool de 15, il semble qu'un seul thread est utilisé. Par exemple, si j'ai une quinzaine d'événements dans la file d'attente, je pense qu'il y aurait quinze fils de vérifier toutes les minutes pour supprimer un événement de la file d'attente. Évidemment, c'est faux.

Comment puis-je faire en sorte qu'il n'y a quinze fils de l'appel de cette méthode pour l'intervalle de temps à l'aide de Printemps du planificateur de l'abstraction?

Edit: Ce que je veux accomplir, c'est ceci: Toutes les demi-secondes, je veux vérifier pour voir si il y a en file d'attente des événements à envoyer. Lorsque cela est fait, je veux envoyer un maximum de 15 (si 15 exister). Comment pourrais-je accomplir cela en utilisant le printemps des abstractions pour le fil de java trucs?

OriginalL'auteur AHungerArtist | 2012-04-20

  1. 5

    Tout d'abord <task:scheduler/> est un wrapper autour de ScheduledThreadPoolExecutor l'extension de ThreadPoolExecutor. JavaDoc pour le dernier dit:

    même le coeur de threads sont créés au départ et a commencé seulement lors de l'arrivée de nouvelles tâches

    Deuxièmement, vous devez comprendre que les tâches planifiées (c'est une fonctionnalité, pas du Printemps) ne pas s'exécuter simultanément, même si elles prennent plus de temps que l'intervalle de répétition. Ils ont tout simplement attendre. Si vous n'avez pas 15 événements dans la file d'attente, vous disposez de 15 exécutions qui sont en retard et attendre que le thread unique. Pas besoin d'en créer un autre en raison de la prochaine exécution doit attendre que la précédente à la fin. Encore une fois, c'est la façon dont Java cadre de la planification des travaux.

    Bien sûr, si vous avez plusieurs tâches planifiées, plus de threads sera créé.

    Je vous remercie. Je pense que j'ai surtout comprendre la relation entre les choses maintenant. Donc (et probablement pas la solution la plus élégante), si je voulais 15 les différents threads de traitement de la file d'attente des événements, je dois répéter '<tâche:prévue ref="notificationProcessor" method="sendNextQueueEvent" à taux fixe="500" /> " 15 fois?
    Donc, je pense, qu'est-ce que la valeur de la taille du pool? Est-ce que si il y a cinq tâches, mais la taille du pool est de deux, les autres tâches devront attendre jusqu'à ce que les deux premiers sont-ils faits?
    non, en fait une meilleure approche serait d'avoir un Printemps réussi piscine avec pool-size="15" simplement l'ajout d'un nouvel emploi ordinaire ExecutorService avec 15 fils. Ensuite, il permettra de traiter les événements à l'aide de tous les threads aussi vite que possible. Veuillez expliquer votre requiremenets mieux, vous voulez exécuter du code des toutes les 500ms dans 15 threads simultanément? Ajoutez à cette question ou à en ouvrir un autre, donc nous pouvons penser à une solution élégante. N'oubliez pas de post de suivi de lien le cas échéant.
    Je vais modifier cette question afin de mieux expliquer mes résultats souhaités. Je vous remercie pour l'aide.
    Mise à jour pour expliquer ce que je cherche.

    OriginalL'auteur Tomasz Nurkiewicz

  2. 3

    Du printemps tâche:planificateur est par défaut des propriétés du bean wrapper pour java.util.de façon concomitante.ThreadPoolExecutor:

    corePoolSize - le nombre de threads à garder dans la piscine, même si elles
    sont en veille.

    Cela ne garantit pas que le pools-size propriété est équivalent au fait que nombre de active threads. D'autre part, il faut noter qu'au un moment donné dans le temps il peut y avoir qu'un nombre maximal de threads de l'égalité de traitement des cœurs sur la machine que vous utilisez; c'est à dire tous les autres threads en attente de passer à RUNNING mode et de continuer l'exécution.

    Aussi, au Printemps, de la documentation, il mentionne que si ce n'est pas ce dont vous avez besoin, vous pouvez également profiter de ConcurrentTaskExecutor.

    Si j'ai quatre cœurs, ne devrait-il pas être au moins quatre fils? Je ne vois qu'une seule. Si j'ai une centaine d'événements dans ma file d'attente, lorsque ce planificateur commence, ne devrais-je pas voir immédiatement quatre appels de sendNextQueueEvent, un de chaque thread?
    Quatre est le nombre maximum de actives simultanées threads, vous pouvez avoir; ce n'est pas la première configuration par défaut. Voir l'appel est également dépendante sur différentes choses comme la simultanéité modèle de la file d'attente que vous utilisez pour les événements et le taux/période dont la tâche est exécutée. J'espère que cette aide.

    OriginalL'auteur nobeh