Bloqueo de archivos Java

Question

Tengo varios hilos (algunos creados por Process X, otros por Process Y, y otros), y cada hilo debe escribirse en un archivo MyFile. Sin embargo, si Thread T1 empieza a escribir a MyFile primero, y luego, cuando Thread T2 empieza a escribir, tiene que esperar a que T1 a versión del archivo, para que se pueda leer el contenido que fueron escritos en Thread T1. En otras palabras, cada hilo tendría un método finalizeThread, así:

private void finalizeThread() { 
    File f = new File("MyFile.dat"); 
    f.createNewFile(); // atomically creates the file, if it doesn't exist 
    locked_section { 
     readContentsFromFile(f); // read contents if some other thread already modified the file 
     modifyContentsFromFile(f); // modify 
     writeFile(f); // write, so that new threads can see the content modified by this thread 
    } 
} 

Mi pregunta es: ¿Cómo puedo lograr que la locked_section en el código anterior? Estaba buscando en la clase FileLock, pero dice en el Javadoc que "Los bloqueos de archivos se llevan a cabo en nombre de toda la máquina virtual Java. No son adecuados para controlar el acceso a un archivo por varios subprocesos dentro de la misma máquina virtual"..

Answer 1

Si solo se accede al archivo desde su programa, el objeto de bloqueo sincronizado está bien. Pero si desea proteger el archivo para que no sea modificado por otros programas mientras está trabajando en él, puede usar las funciones de bloqueo de archivos de Java en java.nio.channels.FileLock (example). Como dice el texto, tenga en cuenta que, en algunos sistemas operativos, los programas aún pueden cambiar archivos si no comprueban si hay un bloqueo de archivos existente.

Answer 2

Te querrás sincronizar en algún objeto. Por ejemplo:

synchronized(fileLockObject) { 
    readContentsFromFile(f); 
    modifyContentsFromFile(f); 
    writeFile(f); 
} 

Answer 3

En lugar de compartir un bloqueo, tal vez podría tener un proceso separado que era responsable de mantener un bloqueo en el archivo. Para comenzar su paso de lectura/modificación/escritura, un Tema debería solicitar este proceso central para el bloqueo a través de HTTP, o mensajes, o lo que quiera. Si se deniega la solicitud, el subproceso se irá a dormir, se despertará e intentará de nuevo. De lo contrario, el hilo leería/modificaría/escribiría y luego le diría al proceso de bloqueo que está liberando el bloqueo.