Filetage de la piscine avec tâches uniques

Si vous êtes autorisé à gérer la base de données, je vous suggère d'utiliser la base de données elle-même pour éviter les efforts en double:

• Ajoutez une colonne LOCKID à votre table
• Ajoutez une colonne d'état à votre table (peut-être 'nouveau' et 'fait')
• Assurez-vous que votre niveau d'isolement de DB est au moins read_commité

  puis essayez quelque chose comme ça, dans votre fil principal: xxx

  Les lignes qui retirent de la sélection sont ce que vous ajoutez à la file d'attente.

  Ensuite, vous avez une classe qui implémente en ligne qui traite ces lignes, en les récupérant de la file d'attente. Une fois que cela traite une ligne, vous faites une autre mise à jour SQL (à l'intérieur de l'exécutable) pour régler le retour sur zéro et définir le statut sur "Terminé".

  Cela a l'avantage de travailler même si vous avez plusieurs machines chacune avec leur propre file d'attente.

Une solution similaire à la solution acceptée mais basée sur le ressort (par opposition à GUAVA):

Créer une interface RunnableWithID strong>: p>

import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import org.springframework.util.concurrent.ListenableFuture;
import org.springframework.util.concurrent.ListenableFutureCallback;

import java.util.Set;

/**
 * In addition to all the abilities of ThreadPoolTaskExecutor adds the ability
 * to execute a task only if it is not already running/queued using the
 * executeIfNotQueuedOrRunningAlready method.
 *
 * @see ThreadPoolTaskExecutor
 */
public class UniquTaskExecutor extends ThreadPoolTaskExecutor implements TaskWithIdExecutor {

    private Set<String> queuedTasks;

    public UniquTaskExecutor() {
        queuedTasks = Sets.newConcurrentHashSet();
    }

    @Override
    public void execute(Runnable task) {
        super.execute(task);
    }

    /**
     * @param task The task to execute
     */
    @Override
    public void executeIfNotQueuedOrRunningAlready(RunnableWithId task) {
        if (queuedTasks.add(task.getTaskId())) {
            ListenableFuture<?> res = submitListenable(task);
            res.addCallback(new ListenableFutureCallback<Object>() {
                @Override
                public void onFailure(Throwable throwable) {
                    queuedTasks.remove(task.getTaskId());
                }

                @Override
                public void onSuccess(Object o) {
                    queuedTasks.remove(task.getTaskId());
                }
            });
        }
    }
}