Bagaimana untuk Melaksanakan Bacaan Bermasa daripada InputStream Tanpa Threading?

Kemungkinan Pembacaan Bermasa daripada InputStream

Cabarannya terletak pada mereka bentuk kaedah yang dipanggil maybeRead yang mengembalikan hasil yang sama seperti in.read() jika data tersedia dalam masa tamat yang ditentukan. Khususnya, maybeRead mengembalikan -2 jika tiada data tersedia dalam tempoh tamat masa yang diberikan.

Pada mulanya, nampaknya pembalut InputStream dalam Pembaca atau InterruptibleChannel boleh menawarkan penyelesaian, tetapi kedua-duanya hanya melalui kaedah InputStream. Selain itu, adalah penting untuk mengelakkan sebarang benang yang timbul semasa proses ini.

Walaupun percaya bahawa in.available() sentiasa mengembalikan 0, dokumentasi mendedahkan ia memberikan anggaran bait yang tersedia untuk dibaca tanpa menyekat. Walaupun anggaran ini mungkin dipandang rendah, anggaran ini mengikuti panggilan berikut untuk mengambil kira ketibaan baharu.

Walau bagaimanapun, subkelas InputStream mengendalikan pelaksanaan available() mereka sendiri dan pelaksanaan konkrit mengatasinya untuk memberikan nilai yang bermakna. Oleh itu, hanya menggunakan is.available() tidak mencukupi.

Untuk bacaan tanpa sekatan dan kurang masa, pertimbangkan penyelesaian berikut:

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

Atau

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);
         }

Untuk penyelesaian yang lebih rumit yang memaksimumkan penimbal dalam masa tamat, gunakan perkara di bawah kaedah:

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;
 }

Dan gunakannya seperti berikut:

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.

Atas ialah kandungan terperinci Bagaimana untuk Melaksanakan Bacaan Bermasa daripada InputStream Tanpa Threading?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!