Öğe Özelliğine Göre PriorityQueue öğelerini nasıl kaldırılır?

Question

PQueue benim Maximum Waiting Time ayarlamaya çalışıyorum. Bu Maximum Waiting Time, linksMaximum Waiting Time'dan daha fazlasını bekliyorsa otomatik olarak PQueue'u kontrol edecektir. Bu değişiklikleri kodumda çalıştım ama bağlantıyı kaldırdıktan hemen sonra duruyor. Tüm öğeleri PQueue'dan bekleme süresi durumuna göre kaldırmak istiyorum. Bana neyi kaçırdığımı söyler misin?

Bu benim sınıftır:

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

Sorunuz biraz opak, ama doğru anlamak, belirli bir süre daha uzun bekledim öğeleri olup olmadığını görmek için PriorityQueue kontrol etmek istiyorum. synchronized kullanımınız IntraLinkCount ve InterLinkCount'da belirtildiği gibi, biraz garip. paketin java.util.concurrent.atomic yılında oldukça bilinmeyen bir alternatif, atomik tamsayı sınıfı AtomicInteger (vardır:.. istediğiniz kadar

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

Bu çalışacaktır

ikinci sorun poll() yöntemini kullanmasıdır Bu olacak Belki yerine peek() kullanmak istiyorum. kuyruktan üst öğeyi kaldırmak ve sonra tek yol, y tarafından döndürülen bağlantı nesnesi tatmin olmadığını remove()link.waitingInQueue() > MaxWaitTime?

kullanmak kuyruğumuz öğeleri "doğal sipariş" e göre iade edecektir. Bu, compareTo yönteminin kullanıldığı anlamına gelir ve "en küçük", önce sıradan döndürülür. Bunun yerine ilk olarak en uzun bekleyen bağlantısını koyan bir özel compareTo uygulamasını uygulamak isteyebilirsiniz.

Bunun yerine create your PriorityQueue with a custom Comparator nesnesini de uygulayabilirsiniz. Böyle

şey: Eğer Java 8 olacak kadar şanslı iseniz

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 
    } 
} 

, bu gibi bazı sihirli yerine yararlı olabilir: