排队的时间

Question

我想在队列中存储时间标记的元素，数据结构没有关系，只是我已经插入内的元素从说当前时间最后5分钟。任何旧的东西都应该被删除 - 这样，每当我得到队列的大小时，它就会计算最近5分钟内插入的对象的数量。

基本上所有我知道的是我的应用程序有多少次让下一个电话之前做了一个HTTP调用到最后5分钟服务器。

如果有人可能在本实施，请分享一些现有的库都知道。

Answer 1

在什么语言？队列是持久还是内存？

如果您在Java中需要此行为，您可以使用DelayedQueue，并有一个单独的线程连续调用queue.take()以避免过期的项目。 queue.size()将会为您提供队列中剩余未过期项目的大小。这就要求你把DelayedQueue项目实施Delayed接口，5分钟返回值到.getDelay()方法。

Answer 2

您可以使用一个优先级队列带有时间戳作为你的钥匙。因此，当您调用Peek（）时，您始终会将最旧的时间戳保留在队列中。然后，每次查询窗口大小内的项目数量时：清除窗口外的项目并返回优先级队列中的项目数。

例如：

public class CountInWindow { 

    /** 
    * Adding a main just for testing 
    * @param args 
    * @throws InterruptedException 
    */ 
    public static void main(String[] args) throws InterruptedException { 
     System.out.println("test started"); 
     CountInWindow test = new CountInWindow(5000); //5 seconds for testing 
     test.debug = true; 
     test.insertTimeStamp(System.currentTimeMillis()); 
     Thread.sleep(100);//sleep 
     test.insertTimeStamp(System.currentTimeMillis()); 
     Thread.sleep(100);//sleep 
     test.insertTimeStamp(System.currentTimeMillis()); 
     Thread.sleep(100);//sleep 
     test.insertTimeStamp(System.currentTimeMillis()); 
     Thread.sleep(5040);//sleep 5 secs 
     test.insertTimeStamp(System.currentTimeMillis()); 
     Thread.sleep(100);//sleep 
     test.insertTimeStamp(System.currentTimeMillis()); 
     System.out.println(test.getWindowCount()); //Should be 2 not 6. 
     System.out.println("test done"); 
    } 

    java.util.PriorityQueue<Long> window; 
    public static final long FIVE_MINS_IN_MS = 300000l; 
    public final long WINDOW_SIZE; 
    public boolean debug = false; 

    //Constructor which defaults to 5mins 
    public CountInWindow(){ 
     WINDOW_SIZE = FIVE_MINS_IN_MS; 
     window = new java.util.PriorityQueue<Long>(); 
    } 
    //Constructor for any size window 
    public CountInWindow(long windowSize){ 
     WINDOW_SIZE = windowSize; 
     window = new java.util.PriorityQueue<Long>(); 
    } 
    /** 
    * Add a new timestamp to the window's queue 
    * @param ts 
    */ 
    public void insertTimeStamp(long ts){ 
     window.add(ts); 
    } 
    /** 
    * Clean up items outside the window size and then return the count of times still in the window. 
    * @return A count of timestamps still inside the 5 mins window. 
    */ 
    public int getWindowCount(){ 
     long currTime = System.currentTimeMillis(); 
     //Clean out old Timestamps 
     while((currTime - window.peek().longValue()) > WINDOW_SIZE){ 
      long drop = window.remove().longValue(); 
      if(debug)System.out.println("dropping item:" + drop); 
     } 
     return window.size(); 
    } 
}