[Arvodan]

Hallo Forum!

Folgendes Problem: Ist es möglich (und wenn ja wie) den Status eines Puffers des PipedOutputStreams zu überprüfen? Sprich: wie voll ist der Puffer.

Hintergrund:
In meiner Anwendung bekommt ein Algorithmus Daten von insgesamt 3 verschiedenen Anwendungen. Diese werden von einer Zwischenschicht sortiert und gruppiert und als Collection über einen Stream übertragen. Das Problem ist, das durch das puffern der Algorithmus den Datenliefernden stellen quasi immer mehr hinterher hinkt (wenn er die daten nicht so schnell verarbeiten kann, wie sie geliefert werden). Er bekommt, sagen wir alle 200ms Daten, 400 ms braucht er zum Auswerten. Dann wird pro auswertung 1 Datensatz in den Puffer geschrieben, was bedeutet, das nach 5 durchläufen, 5 Datensätze im Puffer liegen, und dadurch die Ergebnise des Algorithmuses 1000ms hinter den wirklichen Daten zurückliegen.


Die einzige Lösung dir mir einfällt, ist ein weiteres Streampaar zu erzeugen, über das der Algorithmus der zwischenschicht mitteilt, das er einen Datensatz jetzt verarbeitet...wenn die Zwischenschicht mehr als 2 Datensätze in den Stream schreibt, bevor der Algorithmus fertig ist, ergreift sie entsprechende massnahmen. Aber diese Lösung will mir nicht recht gefallen... und eine einfache "sizeOfBuffer"-methode für den Stream gibt es nicht...

Irgendwelche Ideen?

edit:/ Hab jetzt vorläufig mal vor, vor jedem schreiben den Stream zuleeren. Das ist zwar keine wirkliche Lösung des Problems (da u.U. Datensätze verloren gehen).Dies ist aber für die Anwendung eher vertretbar als das die Algorithmen immer weiter "zurückfallen".



Grüße
Arvodan