Consulta synchronized objeto

[ElAthlit]

Hola a todos,
estoy haciendo pruebas con el synchronized para que varios hilos no me machaquen una información determinada y he estado realizando la siguiente prueba, que no se si hago algo mal o es el concepto que se me escapa.

Hilo1

Código PHP:

  public void run(){
        try{
            FileWriter fr = new FileWriter(new File("C:\\TEST.txt"), true);
            synchronized (fr) {
                
                for (int i=0;i<10000;i++){
                    fr.write("A" + i + "\r\n");
                }
            
            fr.flush();
            fr.close();
            }
                
        }catch (Exception e){
            e.getMessage();
        } 
   

Hilo2

Código PHP:

  public void run(){
        try{
            
            FileWriter fr = new FileWriter(new File("C:\\TEST.txt"), true);
            
            synchronized (fr) {
                for (int i=0;i<10000;i++){
                    fr.write("B" + i + "\r\n");
                }
 
            fr.flush();
            fr.close();    
            }    
            
        }catch (Exception e){
            e.getMessage();
        }
        
    } 
   

Básicamente hacen lo mismo.

Entiendo que al poner el synchronized cuando entra uno de los dos hilos, el otro se tiene que esperar a que deje de usar el objeto para poder hacer uso de él.

El resultado del escenario actual, es que me encuentro todo mezclado, las lineas del Hilo1 con las del Hilo2.

¿Porque no se espera el segundo hilo a que acabe de escribir el primero?

Muchas gracias a todos por vuestro tiempo y ayuda.

Un saludo.

[Ronruby]

El problema esta en que ambos hilos definen su propio método. Con hacer eso, no previenes que se escriba en el archivo uno a la vez ya que ambos hilos tienen su propio bloque sincronizado.

Lo que debes hacer es AISLAR el método que crea el archivo y luego desde el hilo hacer la llamada a ese método.

[hualro]

El problema mas bien esta en que cada hilo define su propio objeto fr por lo que es una variable local, las variables locales son thread safe por lo que no estan compartidas con los demas hilos, esto es BUENO no hay que confundir, pero para efectos practicos de tu ejemplo no funciona.

1. Lo que debes hacer es, identificar tu objeto compartido que es, en este caso: FileWriter
2. Declararlo en una clase principal como objeto compartido, simplemente como variable de objeto (puedes usar static tambien)
3. Lanzar tus threads desde la clase principal.
4. Estas bien en sincronizar el bloque nada mas que en lugar de sincronizar la variable local, ahora estaras sincronizando la variable compartida.

Saludos!

[ElAthlit]

Hola hualro y Ronruby,
muchas gracias por vuestras aclaraciones, ahora entiendo bien cómo funciona y el error que estaba teniendo.

Voy a rectificar según me indicais.

Muchas gracias y un saludo.

Athlit

[ElAthlit]

Buenas, he logrado que me "funcionara" aunque el segundo bloque no empieza desde el número 0....

(Abajo del código he puesto la explicación para que se entendiera mejor)


Clase Sincronized1 (principal)

Código PHP:

  public class Sincronized1 {

    static FileWriter fr;
    
    public Sincronized1(){
        try{
        fr = new FileWriter(new File("C:\\Test.txt"));
        }catch (Exception e){
            e.printStackTrace();
        }
    }
    
    public void Metodo1(){
        try{

            Sincronized2 sin2 = new Sincronized2();
            Sincronized3 sin3 = new Sincronized3();
            sin2.start();
            sin3.start();
            sin2.join();
            sin3.join();
            fr.close();
            }catch (Exception e){
                e.printStackTrace();
            }
    }
    
    public static void main(String[] args) {
        Sincronized1 sin1 = new Sincronized1();
        sin1.Metodo1();
    } 
   

Clase Sincronized2 (HILO1)

Código PHP:

  public void run(){
        Sincronized1 sin1 = new Sincronized1();
        
        synchronized (sin1.fr) {
            
             
            try{
                for (int i=0;i<10000;i++){
                    
                    sin1.fr.write("A" + i + "\r\n");
                    
                }
                
            }catch (Exception e){
            System.out.println("Error en " + getClass().getName());
            System.out.println(e.getMessage());
            }
            
            
        } 
   

Clase Sincronized3 (HILO2)

Código PHP:

  public void run(){
        Sincronized1 sin1 = new Sincronized1();
        
        synchronized (sin1.fr) {
            
            
            try{
                for (int i=0;i<10000;i++){
                    
                    sin1.fr.write("B" + i + "\r\n");
                    
                }

            }catch (Exception e){
            System.out.println("Error en " + getClass().getName());
            System.out.println(e.getMessage());
            }
            
            
        } 
   

SALIDA:

......
A9995
A9996
A9997
A9998
A9999
B90
B91
B92
B93
B94
B95
........

Pienso lo siguiente, a ver que creeis.

Es posible que mientras el Objeto sin1.fr que uso en la Clase sincroniced3 aunqué esté bloqueado, el bucle sigue funcionando y cuando por fin ya está desbloqueado y puede escribir, el bucle ha funcionado 89 vueltas (sin poder escribirlas en fichero)?? Yo pensaba que bloquearía el bucle al estar entre llaves tambien (si es que fuera ese el "problema").

Muchas gracias y un saludo!

Athlit

[Ronruby]

Hice una pequena prueba para que verifiques como es que lo debes hacer:

Código Javascript:

public static void main(String[] args) throws Exception {
        final SyncTest test = new SyncTest();
 
        Thread hiloUno = new Thread(new Runnable() {
            public void run() {
                try {
                    test.writeToFile("A");
                } catch(Exception e) {
 
                }
            }
        });
 
        Thread hiloDos = new Thread(new Runnable() {
            public void run() {
                try {
                    test.writeToFile("B");
                } catch(Exception e) {
 
                }
            }
        });
 
        hiloUno.start();
        hiloDos.start();
    }
 

Código Javascript:

public void writeToFile(String firstChar) {
 
        synchronized (SyncTest.archivo) {
 
            for(int i = 1; i <= 10; i++) {
                 System.out.println(firstChar + i); //Debes reemplazar esto por la actual escritura
            }
 
        }
 
    }
 

Debes de aislar el metodo de escritura en tu clase tambien

La clase SyncTest tiene un metodo llamado writeToFile que cree para hacer una pruebita. Al hacerlo de esa manera, solo un hilo escribira a la vez en el archivo.

[ElAthlit]

Hola Ronruby,
en primer lugar muchas gracias por tu tiempo y no solo eso, me has ayudado muchísimo.

Con tu ejemplo me ha quedado bastante más claro, y comprendiéndolo he creado un código desde 0 (pero viene a ser lo mismo) y me ha funcionado a la perfección de modo que si quito el synchronized me sale todo mezclado y al ponerlo me lo imprime por pantalla perfecto.

El problema que tengo ahora es que al hacer lo mismo escribiendo en fichero tengo problemas con el cierre cuando ya tengo creado el Stream, pero lo importante era comprender la idea del synchronized. Para esto último ya me busco la vida a ver como me lo monto.

Muchas gracias por todo y un saludo!!!!

Por si sirve a alguien o si quieres echar un vistazo, adjunto código:

Clase principal

Código Javascript:

public void Escritura(String strIDHilo){
        try{
                        
            synchronized(System.out){
                
                for (int i=0;i<100;i++){
                    System.out.println(i + strIDHilo + "\r\n");
                }
            }
            
            System.out.println("OK!!");
            
            }catch (Exception e){
                e.printStackTrace();
            }
    }
    
    public static void main(String[] args) {
        Sincronized2 sin2 = new Sincronized2();
        Sincronized3 sin3 = new Sincronized3();
        sin2.start();
        sin3.start();
    }
 

Clase sincronized2 (HILO1)

Código Javascript:

public void run(){
    try{
        Sincronized1 sin1 = new Sincronized1();
        sin1.Escritura("HILO1");
        }catch (Exception e){
            e.printStackTrace();
        }
    
    }
 

Clase sincronized3 (HILO2)

Código Javascript:

public void run(){
        try{
        Sincronized1 sin1 = new Sincronized1();
        sin1.Escritura("HILO2");
        }catch (Exception e){
            e.printStackTrace();
        }
    
    }
 

Athlit

[ElAthlit]

Por si alguien tiene un problema parecido al mio, al final de los hilos, con un join() esperamos a que terminen y ya podemos hacer el close().

Un saludo!

Athlit