Cómo bloquear un método java para proteger múltiples invocaciones

Question

Tengo una aplicación que cada 15 minutos más o menos realiza una replicación desde una base de datos remota. Simplemente mantiene los dos repositorios sincronizados. Una vez que se lleva a cabo esta replicación, no es posible volver a hacerlo. He configurado la siguiente estructura, pero no estoy seguro de si es el enfoque correcto.

public class ReplicatorRunner { 

     private static Lock lock = new ReentrantLock(); 

     public replicate() { 

      if (lock.tryLock()) { 
       try { 
        // long running process 
       } catch (Exception e) {     
       } finally { 
        lock.unlock(); 
       }    
      } else { 
       throw new IllegalStateException("already replicating"); 
      } 

     } 

} 

public class ReplicatorRunnerInvocator { 

    public void someMethod() { 

     try { 
      ReplicatorRunner replicator = new ReplicatorRunner(); 
      replicator.replicate(); 
     } catch (IllegalStateException e) { 
      e.printStackTrace(); 
     } 

    } 

} 

El ReplicatorRunner es la clase propietaria del método replicate que sólo se puede ejecutar uno a la vez.

Editar. Necesito que la siguiente llamada falle (no bloque) si el método ya se está ejecutando en cualquier instancia.

Answer 1

Esto se ve bien. ReentrantLock.tryLock() solo dará el bloqueo a un hilo, por lo que synchronized no es necesario. También evita el bloqueo inherente a la sincronización que usted dice que es un requisito. ReentrantLock es Serializable, por lo que debería funcionar en su clúster.

Hazlo.

Answer 2

echar un vistazo a la clase de semáforo here o de la marca como el método sincronizado el hilo de la ejecución del método en un momento dado es propietaria de un bloqueo en ella evitando otros hilos para llamar al método hasta que termine su ejecución.
Editar: si desea que los otros hilos fallen, puede usar un Lock, y probar si el bloqueo está disponible con el método tryLock.

Answer 3

Cambio public replicate() a public synchronized replicate()

De esa manera réplica referida solamente permitir el acceso a un hilo a la vez. También podrá eliminar ReentrantLock y todo el código asociado.

Answer 4

Sin tener en cuenta los detalles de ReentrantLock, se me ocurre que esta prevención de múltiples rutinas de replicación simultáneas estará limitada a una única instancia de JVM.

Si se inicia otra instancia de la clase en una JVM por separado, entonces es posible que tenga problemas.

¿Por qué no poner un mecanismo de bloqueo en la base de datos? es decir, una fila en una tabla de control que se establece en un valor que representa si la replicación está ocupada o no, y restablece el valor cuando finaliza la replicación.

Answer 5

Terminé usando los siguientes:

public class ReplicatorRunner { 

     private static Semaphore lock = new Semaphore(1); 

     public replicate() { 

      if (lock.tryAcquire()) { 
       try {        
        // basic setup     
        Thread t = new Thread(new Runnable() { 
         public void run() { 
          try { 
           // long running process        
          } catch Exception (e) { 
           // handle the exceptions 
          } finally { 
           lock.release(); 
          } 
         } 
        }) 
        t.start(); 

       } catch (Exception e) { 
        // in case something goes wrong 
        // before the thread starts 
        lock.release(); 
       }    
      } else { 
       throw new IllegalStateException("already replicating"); 
      } 

     } 

} 

public class ReplicatorRunnerInvocator { 

    public void someMethod() { 

     try { 
      ReplicatorRunner replicator = new ReplicatorRunner(); 
      replicator.replicate(); 
     } catch (IllegalStateException e) { 
      e.printStackTrace(); 
     } 

    } 

}