Java for Beginner

Основные методы DelayQueue и примеры использования

add(E e):

Добавляет элемент в очередь. Если очередь полна, генерируется исключение.

DelayQueue<DelayedElement> delayQueue = new DelayQueue<>();
delayQueue.add(new DelayedElement(1000));

put(E e):

Добавляет элемент в очередь. Если очередь полна, операция блокируется до освобождения места.

delayQueue.put(new DelayedElement(2000));

offer(E e):

Добавляет элемент в очередь, если это возможно. Возвращает true, если элемент был добавлен, и false в противном случае.

boolean added = delayQueue.offer(new DelayedElement(3000));

take():

Извлекает и удаляет элемент из головы очереди, ожидая при необходимости до истечения задержки.

DelayedElement element = delayQueue.take();

poll(long timeout, TimeUnit unit):

Извлекает и удаляет элемент из головы очереди, ожидая до указанного времени, если необходимо.

DelayedElement element = delayQueue.poll(2, TimeUnit.SECONDS);

clear():

Удаляет все элементы из очереди.

delayQueue.clear();

remove(Object o):

Удаляет указанный элемент из очереди, если он присутствует.

delayQueue.remove(someElement);

Примеры использования

Запланированные задачи:
DelayQueue можно использовать для планирования выполнения задач через определенные промежутки времени.

import java.util.concurrent.DelayQueue;

public class ScheduledTaskExample {
    public static void main(String[] args) throws InterruptedException {
        DelayQueue<DelayedElement> delayQueue = new DelayQueue<>();

        // Добавление задач
        delayQueue.put(new DelayedElement(3000)); // 3 секунды задержки
        delayQueue.put(new DelayedElement(5000)); // 5 секунд задержки

        // Обработка задач
        while (!delayQueue.isEmpty()) {
            DelayedElement element = delayQueue.take();
            System.out.println("Task executed: " + element);
        }
    }
}

Кэширование с истечением срока действия:
DelayQueue можно использовать для реализации кэша, элементы которого удаляются по истечении определенного времени.

import java.util.concurrent.DelayQueue;

public class CacheExample {
    private static class CacheItem implements Delayed {
        private final String value;
        private final long expiryTime;

        public CacheItem(String value, long delay) {
            this.value = value;
            this.expiryTime = System.currentTimeMillis() + delay;
        }

        @Override
        public long getDelay(TimeUnit unit) {
            long delay = expiryTime - System.currentTimeMillis();
            return unit.convert(delay, TimeUnit.MILLISECONDS);
        }

        @Override
        public int compareTo(Delayed o) {
            if (this.expiryTime < ((CacheItem) o).expiryTime) {
                return -1;
            }
            if (this.expiryTime > ((CacheItem) o).expiryTime) {
                return 1;
            }
            return 0;
        }

        @Override
        public String toString() {
            return value;
        }
    }

    public static void main(String[] args) throws InterruptedException {
        DelayQueue<CacheItem> cache = new DelayQueue<>();

        // Добавление элементов в кэш
        cache.put(new CacheItem("Item1", 2000)); // 2 секунды жизни
        cache.put(new CacheItem("Item2", 4000)); // 4 секунды жизни

        // Извлечение элементов по истечении срока жизни
        while (!cache.isEmpty()) {
            CacheItem item = cache.take();
            System.out.println("Expired item: " + item);
        }
    }
}

#Java #Training #Medium #DelayQueue

745 viewsДен, 14:15