Warum OverlappingFileLockException passieren, wenn beim sperren eine Datei?

Ich versuche, eine Datei sperren und schreiben Sie es mit den folgenden code:

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 neuen zwei thread 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 bekomme ich die Fehlermeldung OverlappingFileLockException. Ich Frage mich, warum dies geschieht, da ich nur die Datei sperren, wenn in jedem thread? Wie kann fix meinen code?

InformationsquelleAutor jerry_sjtu | 2012-03-28
  1. 3

    Sie nicht sperren kann die gleiche Datei mehr als einmal gleichzeitig. Entweder Sie verwenden müssen, um java-Objekte gesperrt werden, um sicherzustellen, dass nur ein thread versucht, die Datei sperren, zu einer Zeit, oder sonst zu koordinieren, die threads warten, bis kein anderer thread sperren.

    Aus der Handbuch:

    Datei sperren gehalten werden, im Namen des gesamten Java virtual machine. Sie sind nicht geeignet für die Steuerung des Zugriffs auf eine Datei durch mehrere threads innerhalb des gleichen virtuellen Maschine.

    • Dann, was ist die Verwendung von FileLock da kann es nicht verwendet werden, um die Koordinierung der threads was schreiben möchte-Datei? @Attila
    • Es ist zu verhindern, dass andere Personen (z.B. andere Programme) auf die Datei zugreifen, zur gleichen Zeit wie der, hält die Sperre. Die Ausnahme weist darauf hin, dass jemand anderes (der eine eigene threads in diesem Fall) bereits einen lock auf die Datei. Wenn Sie nicht wollen, aufgeben (aus Ihrer Sicht des Programms), können Sie später versuchen, zum Beispiel, in der Hoffnung, dass zu diesem Zeitpunkt die Sperre aufgehoben wird.
    • Ich habe das Handbuch gelesen, bevor ich das schreiben von code vor und verstehe nicht den Sinn davon. Jetzt verstehe ich es, danke. @Attila
    InformationsquelleAutor Attila
  2. 2

    Dateien gesperrt sind weltweit nicht nur pro thread oder pro Prozess.

    Müssen Sie zum ausführen von zwei Threads nacheinander, wie diese:

    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();
          }
     }
 }
    • Ich hoffe, t2 tun können, einige Arbeitsplätze, außer für das schreiben in eine Datei. Aber dein code bedeutet, dass thread t2 kann zu arbeiten beginnt erst nach diesem thread t1 hat seine Arbeit abgeschlossen,egal, egal ob t2 schreiben will, die Datei, die gesperrt ist, indem Sie t1. @Johannes
    • Das war nicht ganz offensichtlich von der Frage, aber nehmen Sie einen Blick auf die neue version statt dann. Es ist vielleicht nicht 100% korrekt, aber Sie sollten Sie bekommen die Allgemeine Idee.
    InformationsquelleAutor Johannes
Schreibe einen Kommentar