java - 如何根据元素属性从 PriorityQueue 中删除元素？

Question

我尝试在我的 PQueue 中设置 Maximum Waiting Time。如果有任何链接等待超过Maximum Waiting Time，这个Maximum Waiting Time会自动检查我的PQueue去掉它。我对我的代码进行了此更改，它正在运行，但它在删除链接后正好停止。我想根据等待时间条件从我的 PQueue 中删除所有元素。你能告诉我这里缺少什么吗？

这是我的课:

public class MyClass {

    public static PriorityQueue <LinkNodeLight> PQueue = new PriorityQueue <> (); 


    private static Set<String> DuplicationLinksHub = new LinkedHashSet <> ();         

    private static Integer IntraLinkCount = new Integer (0);                 
    private static Integer InterLinkCount = new Integer (0);                 
    private static Integer DuplicationLinksCount = new Integer (0);     
    private static Integer MaxWaitTime = new Integer (60000); // 1 M= 60000 MS


    @SuppressWarnings("null")
    LinkNode deque(){

        LinkNode link = null;
        synchronized (PQueue) {

            link = (LinkNode) PQueue.poll();
            if (link != null) {
                link.setDequeTime(new DateTime());
                if (link.isInterLinks())
                    synchronized (InterLinkCount) {
                        InterLinkCount--;
                        }
                else
                    synchronized (IntraLinkCount) {
                        IntraLinkCount--;
                        }
            }

            synchronized (PQueue) {
                if (link.waitingInQueue()>MaxWaitTime) {

                    link = (LinkNode) PQueue.remove();
                                    System.out.println("*********************************");
                                    System.out.println("This Link is Deopped: " + link);
                                    System.out.println("%%% MaX Waiting Time:" + (MaxWaitTime/60000)+"Min");

                                    System.out.println("*********************************");
                  }
            }
            return link;


        }

Answer 1

你的问题有点不透明，但如果我理解正确的话，你想检查你的 PriorityQueue 看看是否有等待时间超过特定时间的项目。

如前所述，您对 IntraLinkCount 和 InterLinkCount 的 synchronized 使用有点奇怪。有一个相当未知的替代方案，原子整数类 AtomicInteger(在包 java.util.concurrent.atomic 中:

private static AtomicInteger IntraLinkCount = Integer.valueOf(0);

这将如您所愿。

第二个问题是您使用了poll() 方法。这将从队列中删除 顶部项目。也许您想改用 peek()，然后仅在返回的链接对象满足 link.waitingInQueue() > MaxWaitTime 时才使用 remove() >?

顺便说一句，您的队列将根据它们的“自然顺序”返回项目。这意味着使用了 compareTo 方法，“最小的”将首先从队列中返回。我认为您可能想要实现一个自定义的 compareTo，将 最长等待 链接放在第一位？

你也可以 create your PriorityQueue with a custom Comparator对象代替。

像这样:

public class MyClass {
    public static PriorityQueue<LinkNodeLight> PQueue = new PriorityQueue<>();

    private static AtomicInteger IntraLinkCount = new AtomicInteger(0);
    private static AtomicInteger InterLinkCount = new AtomicInteger(0);

    private static Integer MaxWaitTime = Integer.valueOf(60_000); // 1 M= 60000 MS

    LinkNode deque() {
        LinkNode link = null;

        synchronized (PQueue) {
            link = PQueue.peek();

            if (link != null) {
                link.setDequeTime(LocalDateTime.now());

                if (link.isInterLinks())
                    InterLinkCount.decrementAndGet();
                else
                    IntraLinkCount.decrementAndGet();

                if (link.waitingInQueue() > MaxWaitTime) {
                    link = PQueue.remove();

                    System.out.println("*********************************");
                    System.out.println("This Link is Deopped: " + link);
                    System.out.println("%%% MaX Waiting Time:" + MaxWaitTime / 60000 + "Min");
                    System.out.println("*********************************");

                    return link;
                } else
                    return null;
            }
        }

        return link; // Not sure what you want to return here
    }
}

如果你有幸使用 Java 8，像这样的魔法可能会有用:

synchronized (PQueue) {
    link = PQueue.stream().filter(node -> node.waitingInQueue() > MaxWaitTime).findFirst().orElse(null);

    if (link != null)
        PQueue.remove(link);
}