¿Es seguro un subproceso PrintWriter de socket Java?

Question

Entonces, tengo dos hilos.

El hilo uno gestiona las conexiones del cliente. (Solo hay un cliente y un servidor)
Lo llamo mi hilo de servidor.

El subproceso dos gestiona el envío de mensajes al cliente. Lo llamo mi hilo de procesador de mensajes.

El hilo uno es responsable, entre otras cosas, de enviar un latido del corazón al cliente periódicamente.

Cuando programé, asumí que los sockets no eran seguros para subprocesos, pero los búferes sí, y siempre que utilizara búferes separados para el servidor y los hilos del procesador, estaría bien.

También he hecho la suposición de que la "PrintWriter" era análoga a la memoria intermedia de socket en Java.

Bajo estos supuestos escribí esta función para enviar un latido del corazón:

public void sendHeartBeat(){ 
     logger.info("Sending a hearbeat!"); 
     PrintWriter printWriter=null; 
     try { 
      printWriter = new PrintWriter(clientSocket.getOutputStream()); 
     } catch (IOException e) { 
      logger.info(e.toString()); 
     } 
     if(printWriter!=null){ 
      printWriter.print("HEARTBEAT#"); 
      printWriter.flush(); 
     } 
    } 

El otro hilo, el "procesador" hace algo similar, ya que hace:

printWriter=new PrintWriter(theServer.getClientSocket().getOutputStream()); 

De esta manera, Crearía un nuevo "buffer" cada vez que deseara enviar un latido, y mis mensajes nunca serían sobrescritos.

Desafortunadamente, este no parece ser el caso. Y me sale un mensaje que viene a través de la tubería de la siguiente manera: dsgdsbHEARTBEAT # SDG

Esto provoca un volcado de memoria más tarde.

Aquí están mis preguntas:

1) Los enchufes son, obviamente, no seguro para subprocesos, pero son los PrintWriters que recibo de ellos hilo de seguridad? ¿O solo está devolviendo el mismo PrintWriter?

2) ¿Qué es análogo al buffer de socket en Java? ¿Cómo debería pensar sobre este problema?

3) ¿Cómo puedo hacer para que estos hilos no escriban en el mismo buffer en el socket?

Answer 1

Es un diseño pobre para tener estos múltiples PrintWriter s en la misma corriente. Realmente desea al menos el objeto que las llama para sincronizarse (o enrutar confinado).

Sin embargo, suponiendo que por alguna razón te quiero múltiples PrintWriter s:

Primer problema: Writer s no utilizan this como la cerradura. PrintWriter y BufferedWriter de forma predeterminada ambos usan el Writer con el que están construidos como cerradura. Esto está obviamente completamente roto. Deben usar el candado Writer, no el Writer.Un error fácil dado que al bloquear una función de Object se elimina la seguridad del tipo estático. Por lo tanto, deberá construir un PrintWriter con el socket OutputStream (u otro objeto común) como el candado.

En segundo lugar, tenemos tampón dentro PrintWriter. Así que ven al final de un buffer, medio escrito y medio esperando la próxima escritura. Para evitar eso, bloquee externamente para combinar un print y flush, o use la función de limpieza automática y agregue un nuevo carácter de línea.

Por lo tanto, no es significativamente hilo seguro, pero puede hackearlo. O puedes usar un mejor diseño.

Answer 2

Necesita una forma de utilizar el mismo PrintWriter entre los hilos (t1.writer == t2.writer, no solo PrintWriter s creados a partir del mismo OutputStream). Con el mismo PrintWriter, todas las operaciones de escritura están sincronizadas.