如何在不使用執行緒的情況下實現輸入流的定時讀取？

從輸入流中可能的定時讀取

挑戰在於設計一個名為MaybeRead 的方法，它返回與in.read( ) 相同的結果如果資料在指定的逾時時間內可用。具體來說，如果在給定的超時時間內沒有可用數據，maybeRead 將傳回 -2。

最初，將 InputStream 包裝在 Reader 或 InterruptibleChannel 中似乎可以提供解決方案，但兩者都只能透過 InputStream 方法。此外，在此過程中避免任何線程生成至關重要。

儘管相信 in.available() 始終返回 0，但文件顯示它提供了可用於讀取而不會阻塞的位元組的估計。雖然這個估計可能被低估，但它會趕上以下呼叫以考慮新到達的情況。

但是，InputStream 的子類別處理它們自己的 available() 實現，並且具體實作會覆寫它以提供有意義的值。因此，僅僅使用 is.available() 是不夠的。

對於非阻塞和無超時讀取，請考慮以下解決方案：

byte[] inputData = new byte[1024];
int result = is.read(inputData, 0, is.available());  // -1 for EOF with no data read.

或

BufferedReader br = new BufferedReader(new InputStreamReader(System.in, Charset.forName("ISO-8859-1")),1024);
// ...
         // inside some iteration / processing logic:
         if (br.ready()) {
             int readCount = br.read(inputData, bufferOffset, inputData.length-bufferOffset);
         }

對於在超時內最大化緩衝區的更複雜的解決方案，請使用以下方法方法：

public static int readInputStreamWithTimeout(InputStream is, byte[] b, int timeoutMillis)
     throws IOException  {
     int bufferOffset = 0;
     long maxTimeMillis = System.currentTimeMillis() + timeoutMillis;
     while (System.currentTimeMillis() < maxTimeMillis &amp;&amp; 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;
 }

並按如下方式使用：

byte[] inputData = new byte[1024];
int readCount = readInputStreamWithTimeout(System.in, inputData, 6000);  // 6 second timeout
// readCount indicates bytes read; -1 for EOF with no data read.

以上是如何在不使用執行緒的情況下實現輸入流的定時讀取？的詳細內容。更多資訊請關注PHP中文網其他相關文章！