使用ConcurrentSkipListMap实现的优先级队列，不确定如何让消费者阻止它

Question

我用ConcurrentSkipListMap实现了一个优先级队列，使用16种不同的优先级。

class ConcurrentPriorityQueue {

    ConcurrentSkipListMap<Long, Message> queue = new ConcurrentSkipListMap<>();

    AtomicLong counter16 = new AtomicLong(Long.MAX_VALUE);
    AtomicLong counter15 = new AtomicLong(Long.MAX_VALUE / 8 * 7);
    AtomicLong counter14 = new AtomicLong(Long.MAX_VALUE / 4 * 3);
    // etc
    AtomicLong counter1 = new AtomicLong(Long.MIN_VALUE / 8 * 7);

    void addPriority16(Message message) {
        queue.put(counter16.getAndDecrement(), message);
    }

    void addPriority15(Message message) {
        queue.put(counter15.getAndDecrement(), message);
    }

    // and so on
}

这并不完全是类的组织方式（例如，我把原子放在一个数组中），但我认为这段代码会更清晰。还有一个DelayQueue，用于删除旧消息或提高旧消息的优先级（取决于消息类型）。

我的问题是，我有几个消费者正在使用pollLastEntry（），以便从队列中删除优先级最高的消息，然后在队列为空时Hibernate，但问题是队列活动会突然爆发——它会持续一个小时而不包含超过几条消息，然后在接下来的一个小时里，它将永远不会空。因此，我希望使用阻塞方法从队列中删除消息，这样我就不会在重复睡眠的线程上浪费资源（我会使用指数退避，在活动较少时使它们睡眠时间更长，但这会使它们在队列再次启动时无响应），但我不清楚实现这一点的最佳方式——我有大量使用阻塞队列的经验，但没有实现它们的经验。我的第一个想法是在睡眠中的消费者中实现指数退避，然后在队列活动再次启动时中断他们，但我首先想看看是否有更好的方法来做到这一点。

Answer 1

我会实现一个包装器

class Wrapper implements Comparable<Wrapper> {
    long priority;
    Message message;

    Wrapper(long priority, Message message) {
        this.priority = priority;
        this.message = message;
    }

    @Override
    public int compareTo(Wrapper w) {
        return Long.compare(priority, w.priority);
    }
}

并使用PriorityBlockingQueue而不是ConcurrentSkipListMap