Bolehkah InputStream Java Dibaca dengan Tamat Masa, dan Bagaimana?

Bolehkah Data Dibaca daripada InputStream dengan Tamat Masa?

Soalan berpusat di sekitar membangunkan kaedah yang boleh membaca daripada InputStream dalam satu tempoh tamat masa yang ditetapkan. Kaedah sedemikian, maybeRead, bertujuan untuk mengembalikan hasil yang sama seperti kaedah read() dalam InputStream apabila data tersedia dalam masa yang diperuntukkan, atau -2 jika tiada data tersedia. Cabarannya terletak pada memastikan bahawa mana-mana utas yang dihasilkan ditamatkan semasa pelaksanaan.

Had Aliran Input Java

Sebelum meneroka penyelesaian yang berpotensi, adalah penting untuk mengakui batasan khusus Java InputStream:

1. baca() mungkin tidak boleh diganggu, menghalang gangguan semasa pengambilan data.
2. Membungkus InputStream dalam Pembaca atau InterruptibleChannel tidak menawarkan penyelesaian kerana ia bergantung sepenuhnya pada kaedah InputStream.
3. available() boleh mengembalikan 0 secara sah, malah apabila data ada.
4. close() mungkin menyekat atau tidak kesan.
5. Tiada mekanisme yang wujud untuk menamatkan rangkaian lain.

Melawan Pengehadan

Menggunakan InputStream.available()

Walaupun dokumentasi menyatakan bahawa available() boleh pulangan 0, bukti mencadangkan ia memberikan anggaran tepat data yang tersedia. Subkelas InputStream Konkrit secara strategik mengatasi tersedia() untuk memberikan maklumat yang bermakna.

Kaveat Khusus Platform

Windows/Cygwin: Input hanya diberikan apabila menekan "Kembali." Jika tidak, InputStream.available() mengembalikan 0 seperti yang dijangkakan.

Penyelesaian Mudah (Tiada Penyekatan)

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

Penyelesaian Komprehensif (Data Maksimum Pemerolehan)

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

Penggunaan:

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

Atas ialah kandungan terperinci Bolehkah InputStream Java Dibaca dengan Tamat Masa, dan Bagaimana?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!