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

Question

我尝试在我的PQueue 中设置Maximum Waiting Time。这个Maximum Waiting Time 将自动检查我的PQueue，如果有任何links 等待超过Maximum Waiting Time 来删除它。我对正在运行的代码进行了此更改，但在删除链接后它完全停止了。我想根据等待时间条件从我的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);
}