Очередь задач с отложенной обработкой

Высокопроизводительная очередь задач для отложенной обработки. Поддерживает эффективную обработку до 100 тысяч отложенных сообщений в секунду на одном компьютере (можно развернуть несколько экземпляров для ещё более высокой параллельной обработки). Например, если оплата не поступает в течение 30 минут после оформления заказа, заказ автоматически отменяется. Как эффективно отменить большое количество неоплаченных заказов?

Подробности см. в wiki: https://gitee.com/itman666/wheel-timer-queue/wikis/Home

Использование:

// Запуск очереди QueueBootstrap queueBootstrap = new QueueBootstrap(); WheelQueue wheelQueue = queueBootstrap.start();

// Добавление задачи в очередь wheelQueue.add(new AbstractTask("9527") {

@Override
public void run() {
    LOG.info("add task. id=" + this.getId());