스레딩 없이 입력 스트림에서 시간 초과 읽기를 구현하는 방법은 무엇입니까?

InputStream에서 가능한 시간 제한 읽기

문제는 in.read()와 동일한 결과를 반환하는 MaybeRead라는 메서드를 설계하는 데 있습니다. 지정된 제한 시간 내에 데이터를 사용할 수 있는 경우 구체적으로, 지정된 제한 시간 내에 사용 가능한 데이터가 없으면 MaybeRead는 -2를 반환합니다.

처음에는 Reader 또는 InterruptibleChannel에서 InputStream을 래핑하는 것이 솔루션을 제공할 수 있는 것처럼 보이지만 둘 다 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 중국어 웹사이트의 기타 관련 기사를 참조하세요!