¿Es posible leer desde un InputStream con un tiempo de espera?

Específicamente, el problema es escribir un método como este:

int maybeRead(InputStream in, long timeout)

donde el valor de retorno es el mismo que in.read() si los datos están disponibles dentro de los milisegundos de 'tiempo de espera' y -2 en caso contrario. Antes de que el método regrese, todos los subprocesos generados deben salir.

Para evitar discusiones, el tema aquí es java.io.InputStream, según lo documentado por Sun (cualquier versión de Java). Tenga en cuenta que esto no es tan simple como parece. A continuación se muestran algunos datos respaldados directamente por la documentación de Sun.

1. El método in.read() puede no ser interrumpible.

2. Envolver el InputStream en un Reader o InterruptibleChannel no ayuda, porque lo único que esas clases pueden hacer es llamar a los métodos del InputStream. Si fuera posible utilizar esas clases, sería posible escribir una solución que simplemente ejecute la misma lógica directamente en InputStream.

3. Siempre es aceptable que in.available() devuelva 0.

4. El método in.close() puede bloquear o no hacer nada.

5. No existe una forma general de eliminar otro hilo.

Apr 30 '09 07:04

Suponiendo que su transmisión no esté respaldada por un socket (por lo que no puede usar Socket.setSoTimeout()), creo que la forma estándar de resolver este tipo de problema es usar un Future.

Supongamos que tengo el siguiente ejecutor y transmisiones:

    ExecutorService executor = Executors.newFixedThreadPool(2);
    final PipedOutputStream outputStream = new PipedOutputStream();
    final PipedInputStream inputStream = new PipedInputStream(outputStream);

Tengo un escritor que escribe algunos datos y luego espera 5 segundos antes de escribir el último dato y cerrar la transmisión:

    Runnable writeTask = new Runnable() {
        @Override
        public void run() {
            try {
                outputStream.write(1);
                outputStream.write(2);
                Thread.sleep(5000);
                outputStream.write(3);
                outputStream.close();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    };
    executor.submit(writeTask);

La forma normal de leer esto es la siguiente. La lectura se bloqueará indefinidamente para los datos, por lo que se completa en 5 segundos:

    long start = currentTimeMillis();
    int readByte = 1;
    // Read data without timeout
    while (readByte >= 0) {
        readByte = inputStream.read();
        if (readByte >= 0)
            System.out.println("Read: " + readByte);
    }
    System.out.println("Complete in " + (currentTimeMillis() - start) + "ms");

que produce:

Read: 1
Read: 2
Read: 3
Complete in 5001ms

Si hubiera un problema más fundamental, como que el escritor no respondiera, el lector se bloquearía para siempre. Si finalizo la lectura en el futuro, puedo controlar el tiempo de espera de la siguiente manera:

    int readByte = 1;
    // Read data with timeout
    Callable<Integer> readTask = new Callable<Integer>() {
        @Override
        public Integer call() throws Exception {
            return inputStream.read();
        }
    };
    while (readByte >= 0) {
        Future<Integer> future = executor.submit(readTask);
        readByte = future.get(1000, TimeUnit.MILLISECONDS);
        if (readByte >= 0)
            System.out.println("Read: " + readByte);
    }

que produce:

Read: 1
Read: 2
Exception in thread "main" java.util.concurrent.TimeoutException
    at java.util.concurrent.FutureTask$Sync.innerGet(FutureTask.java:228)
    at java.util.concurrent.FutureTask.get(FutureTask.java:91)
    at test.InputStreamWithTimeoutTest.main(InputStreamWithTimeoutTest.java:74)

Puedo detectar TimeoutException y hacer la limpieza que quiera.

Mar 23 '2012 00:03 Ian Jones

Si su InputStream está respaldado por un Socket, puede establecer un tiempo de espera de Socket (en milisegundos) usando setSoTimeout . Si la llamada read() no se desbloquea dentro del tiempo de espera especificado, generará una excepción SocketTimeoutException.

Solo asegúrese de llamar a setSoTimeout en el Socket antes de realizar la llamada read().

Sep 06 '2011 05:09 Templar

Cuestionaría el planteamiento del problema en lugar de aceptarlo ciegamente. Sólo necesitas tiempos de espera desde la consola o a través de la red. Si tiene estos últimos Socket.setSoTimeout()y HttpURLConnection.setReadTimeout()ambos hacen exactamente lo que se requiere, siempre y cuando los configure correctamente cuando los construya/adquiera. Dejarlo en un punto arbitrario más adelante en la aplicación, cuando todo lo que tiene es InputStream, es un diseño deficiente que conduce a una implementación muy incómoda.

Oct 19 '2011 23:10 user207421

No he usado las clases del paquete Java NIO, pero parece que podrían ser de alguna ayuda aquí. Específicamente, java.nio.channels.Channels y java.nio.channels.InterruptibleChannel .

Apr 30 '2009 01:04 jt.