¿Mejor alternativa para PipedReader/PipedWriter?

Question

Necesito tener una secuencia de char con buffer, en la que escribo en un hilo y desde la que leo en otro hilo. Right now estoy usando PipedReader y PipedWriter para ello, pero esas clases causar un problema de rendimiento: PipedReader hace un wait(1000) cuando su memoria intermedia interna está vacía, lo que hace que mi solicitud a la zaga de forma visible.

¿Habría alguna biblioteca que haga lo mismo que PipedReader/PipedWriter, pero con un mejor rendimiento? ¿O tendré que implementar mis propias ruedas?

Answer 1

El problema fue que cuando algo se escribe en el PipedWriter, no notifica automáticamente el PipedReader que hay algunos datos a leer. Cuando uno intenta leer PipedReader y el búfer está vacío, el PipedReader hará un bucle y esperará usando una llamada wait(1000) hasta que el búfer tenga algunos datos.

La solución es llamar al PipedWriter.flush() siempre después de escribir algo en la tubería. Todo lo que hace la descarga es llamar al notifyAll() en el lector. La solución al código en la pregunta looks like this.

(Para mí, la implementación PipedReader/PipedWriter se parece mucho a un caso de optimización prematura, ¿por qué no notificar todo en cada escritura? También los lectores esperan en un bucle activo, despertando cada segundo, en lugar de despertarse solo cuando es algo para leer. El código también contiene algunos comentarios pendientes, que la detección de hilos del lector/escritor que no es lo suficientemente sofisticada)

Este mismo problema parece estar también en PipedOutputStream. En mi proyecto actual, llamar al flush() manualmente no es posible (no puedo modificar Commons IO's IOUtils.copy()), así que lo solucioné creando low-latency wrappers para las clases de tuberías. Funcionan mucho mejor que las clases originales. :-)

Answer 2

Debería ser bastante fácil envolver una API de secuencia char alrededor de BlockingQueue.

Debo decir, sin embargo, parece bastante perverso que PipedReader usaría sondeo para esperar los datos. ¿Está documentado esto en alguna parte, o lo descubriste por ti mismo de alguna manera?

Answer 3

he implementado algo un poco similar y asked a question si alguien más había nada mejor pensado y código de prueba.

Answer 4

@Esko Luontola, he estado leyendo su código en el paquete sbt para tratar de entender lo que está haciendo. Parece que desea iniciar un Process y pasarle una entrada, y hacer que el resultado de la acción llegue a diferentes lugares. ¿Es esto correcto?

Me gustaría probar la modificación del bucle principal en ReaderToWriterCopier de manera que en vez de hacer un read() - una operación de bloqueo que, al parecer cuando un PipedReader participa causa de votación - esperas explícitamente la Writer-flush. La documentación es clara que flush hace que cualquier Reader s sea notificado.

No estoy seguro de cómo ejecutar su código, así que no puedo profundizar en él. Espero que esto ayude.