Kann Javas InputStream mit einem Timeout gelesen werden und wie?

Können Daten aus einem InputStream mit einem Timeout gelesen werden?

Die Frage dreht sich um die Entwicklung einer Methode, die innerhalb eines Zeitraums aus einem InputStream lesen kann angegebenen Timeout-Zeitraum. Eine solche Methode, MaybeRead, zielt darauf ab, das gleiche Ergebnis wie die Methode read() in InputStream zurückzugeben, wenn Daten innerhalb der vorgegebenen Zeit verfügbar sind, oder -2, wenn keine Daten verfügbar sind. Die Herausforderung besteht darin, sicherzustellen, dass alle erzeugten Threads während der Ausführung beendet werden.

Einschränkungen von Java InputStream

Bevor mögliche Lösungen untersucht werden, ist es wichtig, bestimmte Einschränkungen von Java InputStream zu berücksichtigen:

1. read() kann unterbrechungsfrei sein, wodurch Unterbrechungen während der Datenübertragung verhindert werden Abruf.
2. Das Einschließen von InputStream in Reader oder InterruptibleChannel bietet keine Lösung, da diese ausschließlich auf InputStream-Methoden basieren.
3. available() kann legal 0 zurückgeben, selbst wenn Daten vorhanden sind.
4. close() kann blockieren oder keine Wirkung haben.
5. Es gibt keinen inhärenten Mechanismus, um andere zu beenden Threads.

Bekämpfung der Einschränkungen

Verwendung von InputStream.available()

Obwohl in der Dokumentation angegeben ist, dass verfügbar () kann 0 zurückgeben, es gibt Hinweise darauf, dass es genaue Schätzungen der verfügbaren Daten liefert. Konkrete InputStream-Unterklassen überschreiben available() strategisch, um aussagekräftige Informationen bereitzustellen.

Plattformspezifische Einschränkungen

Windows/Cygwin: Eingaben werden nur bereitgestellt indem Sie „Return“ drücken. Andernfalls gibt InputStream.available() wie erwartet 0 zurück.

Einfache Lösung (keine Blockierung)

byte[] inputData = new byte[1024];
int result = is.read(inputData, 0, is.available());  // Reads as much data as immediately available

Umfassende Lösung (Maximale Daten). Erwerb)

public static int readInputStreamWithTimeout(InputStream is, byte[] b, int timeoutMillis)
     throws IOException  {
     int bufferOffset = 0;
     long maxTimeMillis = System.currentTimeMillis() + timeoutMillis;
     while (System.currentTimeMillis() < maxTimeMillis && bufferOffset < b.length) {
         int readLength = java.lang.Math.min(is.available(),b.length-bufferOffset);
         int readResult = is.read(b, bufferOffset, readLength);
         if (readResult == -1) break;
         bufferOffset += readResult;
     }
     return bufferOffset;
 }

Nutzung:

byte[] inputData = new byte[1024];
int readCount = readInputStreamWithTimeout(System.in, inputData, 6000);  // 6 second timeout

Das obige ist der detaillierte Inhalt vonKann Javas InputStream mit einem Timeout gelesen werden und wie?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!