LimitedQueue auf Datum prüfen

[Fohnbit]

Hallo,

ich habe eine LimitedQueue, die mir bei 10000 Einträge keine neue mehr reinlegt.

private LimitedQueue<RecEvent> recordedEvents = new LimitedQueue<RecEvent>(10000);

public class LimitedQueue<E> extends LinkedList<E> {

    /**
     *
     */
    private static final long serialVersionUID = -4649076009250033576L;
    private int limit = 10000;

    public LimitedQueue(int limit) {
        this.limit = limit;
    }

    @Override
    public boolean add(E o) {
        boolean added = super.add(o);
       
        // check queue size
        while (added && size() > limit) {
            super.remove();
        }
        return added;
    }
}

class RecEvent {
        public RecEvent(String objId, String key, long ts, RecValue value,
                String nodeId) {
            this.objId = objId;
            this.ts = ts;
            this.value = value;
            this.key = key;
            this.nodeId = nodeId;
        }

        public RecEvent() {
        }
....

Nun möchte ich aber, da die Variable "ts" ein Timestamp ist, Einträge in der Queue, die älter als 7 Tage sind, löschen.

Logisch kann ich vor dem hinzufügen in die LimitedQueue einen Loop über alle Elemente machen und alte Einträge löschen.
Oder kann ich das sogar in der Überschriebenen Klasse?

Die Einträge sind immer Aufsteigend vom Timestamp ... wenn der erste gefunden wird, welcher nicht älter als 7 Tage ist, kann abgebrochen werden. Aber ich möchte nicht die Queue von hinten her beginnen zu iterieren.

Vielen dank!

 

[Fohnbit]

das scheint mal zu funktionieren:

    @Override
    public boolean add(E o) {
        boolean added = super.add(o);

        // check timestamp with a loop
        boolean b = true;

        while (b) {
            if (super.size() > 0) {
                RecEvent recEvent = (RecEvent) super.get(0);

                if (recEvent.getTs() < System.currentTimeMillis() - duration) {
                    super.remove(0);
                } else {
                    b = false;
                }
            } else {
                b = false;
            }

        }

        // check queue size
        while (added && size() > limit) {
            // super.remove();
            super.remove(0);
        }
        return added;
    }

 

[JStein52]

Logisch kann ich vor dem hinzufügen in die LimitedQueue einen Loop über alle Elemente machen

Deine LimitedQueue ist doch generisch und weiss nichts von einem Timestamp. Ich denke mal RecEvent sind die Objekte die du in deiner Anwendung in diese LimitedQueue aufnimmst. Und dann musst du diese Timestamp-Überprüfungen doch auch in deiner Anwendung machen. Wenn du in deiner generischen Klasse davon ausgehst dass die Queue immer RecEvents enthält hebelst du ja deinen Generic-Ansatz aus.

 

[mrBrown]

Du solltest bei sowas eher Komposition statt Vererbung nutzen, spätestens bei addAll oder add mit Index wirst du sonst negativ überrascht werden...

 

[Fohnbit]

Hallo,

ja, muss aber nicht generisch sein. Habs mal so abgeändert.

public class LimitedQueue<RecEvents> extends LinkedList<RecEvents> {

    /**
     *
     */
    private static final long serialVersionUID = -4649076009250033576L;
    private int limit = 10000;
    private long duration = 86400000;

    public LimitedQueue(int limit, long duration) {
        this.limit = limit;
        this.duration = duration;
    }

    @Override
    public boolean add(RecEvents recEvents) {
        boolean added = super.add(recEvents);

        // check timestamp with a loop
        boolean b = true;

        while (b) {
            if (super.size() > 0) {
                RecEvent recEvent = (RecEvent) super.get(0);

                if (recEvent.getTs() < System.currentTimeMillis() - duration) {
                    super.remove(0);
                } else {
                    b = false;
                }
            } else {
                b = false;
            }

        }

        // check queue size
        while (added && size() > limit) {
            // super.remove();
            super.remove(0);
        }
        return added;
    }
}

 

[mrBrown]

Zum Löschen und generisch bleiben: du könntest bei der Initialisierung ein Predicate übergeben, welches angibt, welche Elemente gelöscht werden, und damit dann

 

[mrBrown]

Hallo,

ja, muss aber nicht generisch sein. Habs mal so abgeändert.

Das ist jetzt genauso generisch wie vorher, da sollten auch sowohl IDE als auch Compiler über den unchecked cast meckern.