Warum passiert beim Sperren einer Datei eine OverlappingFileLockException?

Question

ich versuche, eine Datei zu sperren und unten, um es mit dem Code schreiben:

public class TrainSetBuildTask implements Runnable { 
    private String pathname; 
    public TrainSetBuildTask(String pathname){ 
     this.pathname = pathname; 
    } 

    @Override 
    public void run() { 
      try { 
       String content = "content\n"; 
      //write to a file 
      FileOutputStream os = new FileOutputStream(new File(pathname), true); 
      FileChannel channel = os.getChannel(); 
      FileLock lock = channel.tryLock(); 
      if (lock != null) { 
       ByteBuffer bytes = ByteBuffer.wrap(content.getBytes()); 
       channel.write(bytes); 
       lock.release(); 
      } 
      channel.close(); 
      os.close(); 
      } catch (IOException e) { 
       e.printStackTrace(); 
      } 
    } 
} 

Und neue zwei Gewinde mit Instanzen der Klasse:

String pathname = "/home/sjtu123/test.arff"; 
    TrainSetBuildTask task1 = new TrainSetBuildTask(pathname); 
    Thread t1 = new Thread(task1); 
    TrainSetBuildTask task2 = new TrainSetBuildTask(pathname); 
    Thread t2 = new Thread(task2); 
    t1.start(); 
    t2.start(); 

Dann erhalte ich die Fehler OverlappingFileLockException. Ich frage mich, warum das passiert, da ich die Datei nur einmal in jedem Thread sperre? Wie kann ich meinen Code reparieren?

Answer 1

Sie können nicht die gleiche Datei mehr sperren als einmal gleichzeitig. Entweder müssen Sie Java Lock-Objekte verwenden, um sicherzustellen, dass nur ein Thread versucht, die Datei zu einem Zeitpunkt zu sperren, oder die Threads auf andere Weise koordinieren, um zu warten, bis kein anderer Thread mehr blockiert.

Vom manual:

Dateisperren werden im Namen der gesamten virtuellen Java-Maschine gehalten. Sie sind nicht geeignet, um den Zugriff auf eine Datei durch mehrere Threads innerhalb derselben virtuellen Maschine zu steuern.

Answer 2

Dateien werden global gesperrt, nicht nur pro Thread oder pro Prozess.

Sie benötigen zwei Faden nacheinander wie folgt auszuführen:

String pathname = "/home/sjtu123/test.arff"; 
TrainSetBuildTask task1 = new TrainSetBuildTask(pathname); 
Thread t1 = new Thread(task1); 
TrainSetBuildTask task2 = new TrainSetBuildTask(pathname); 
Thread t2 = new Thread(task2); 
t1.start(); 
t1.join(); // Wait for t1 to die. 
t2.start(); 

Neue Version nach Kommentare:

FileWriter pathname = new FileWriter("/home/sjtu123/test.arff"); 
TrainSetBuildTask task1 = new TrainSetBuildTask(pathname); 
Thread t1 = new Thread(task1); 
TrainSetBuildTask task2 = new TrainSetBuildTask(pathname); 
Thread t2 = new Thread(task2); 
t1.start(); 
t2.start(); 
t1.join(); 
j2.join(); 
synchronized (pathname){ 
    pathname.close(); 
} 

und

public class TrainSetBuildTask implements Runnable { 
    private FileWriter pathname; 
    public TrainSetBuildTask(FileWriter pathname){ 
     this.pathname = pathname; 
    } 

    @Override 
    public void run() { 
      try { 
      // Do work 
      synchronized (pathname){ 
      // Write to file 
      } 
      } catch (IOException e) { 
       e.printStackTrace(); 
      } 
    } 
}