Java 中的 DelayQueue 迭代器()方法,带示例

原文:https://www . geeksforgeeks . org/delay queue-iterator-method-in-Java-with-examples/

DelayQueue迭代器()方法用于返回 DelayQueue 中所有元素的迭代器。这些元素可以过期或未过期。 语法:

public Iterator iterator ()

参数:此方法不接受任何参数。 返回:这个方法返回这个延迟队列中元素的迭代器。 下面程序来说明 Java 中的 DelayQueue 迭代器(): 示例:

Java 语言(一种计算机语言,尤用于创建网站)

// Java Program Demonstrate DelayQueue iterator() method

import java.util.concurrent.*;
import java.util.*;

// The DelayObject for DelayQueue
// It must implement Delayed and
// its getDelay() and compareTo() method
class DelayObject implements Delayed {

    private String name;
    private long time;

    // Constructor of DelayObject
    public DelayObject(String name, long delayTime)
    {
        this.name = name;
        this.time = System.currentTimeMillis()
                    + delayTime;
    }

    // Implementing getDelay() method of Delayed
    @Override
    public long getDelay(TimeUnit unit)
    {
        long diff = time - System.currentTimeMillis();
        return unit.convert(diff, TimeUnit.MILLISECONDS);
    }

    // Implementing compareTo() method of Delayed
    @Override
    public int compareTo(Delayed obj)
    {
        if (this.time < ((DelayObject)obj).time) {
            return -1;
        }
        if (this.time > ((DelayObject)obj).time) {
            return 1;
        }
        return 0;
    }

    // Implementing toString() method of Delayed
    @Override
    public String toString()
    {
        return "\n{"
            + " " + name + ", time=" + time + "}";
    }
}

// Driver Class
public class GFG {
    public static void main(String[] args) throws InterruptedException
    {

        // create object of DelayQueue
        // using DelayQueue() constructor
        BlockingQueue<DelayObject> DQ
            = new DelayQueue<DelayObject>();

        // Add numbers to end of DelayQueue
        // using add() method
        DQ.add(new DelayObject("A", 1));
        DQ.add(new DelayObject("B", 2));
        DQ.add(new DelayObject("C", 3));
        DQ.add(new DelayObject("D", 4));

        // Creating an iterator
        Iterator val = DQ.iterator();

        // print the value after iterating DelayQueue
        System.out.println("The iterator values are: ");
        while (val.hasNext()) {
            System.out.println(val.next());
        }
    }
}

Output: 

The iterator values are: 

{ A, time=1545818784540}

{ B, time=1545818784541}

{ C, time=1545818784542}

{ D, time=1545818784543}