У меня есть несколько потоков (некоторые из них порождаются Process X, другие - Process Y, et cetera), и каждый поток должен записывать в файл MyFile. Однако, если Thread T1 начинает сначала записывать в MyFile, а затем, когда Thread T2 начинает писать, ему нужно дождаться T1, чтобы освободить файл, чтобы он мог прочитать содержимое, написанное в Thread T1, Другими словами, каждый поток будет иметь метод finalizeThread, например:
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
}
}
Мой вопрос: как я могу выполнить locked_section в приведенном выше коде? Я изучал класс FileLock, но в Javadoc говорится, что "Блокировки файлов хранятся от имени всей виртуальной машины Java. Они не подходят для управления доступом к файлу несколькими потоками на той же виртуальной машине.".
Если файл доступен только из вашей программы, синхронизированный объект блокировки в порядке. Но если вы хотите защитить файл от изменений другими программами во время работы над ним, вы можете использовать функции блокировки файлов Java в java.nio.channels.FileLock (пример). Как говорится в тексте, помните, что в некоторых операционных системах программы все равно могут изменять файлы, если они не проверяют наличие существующей блокировки файлов.
Вместо совместного использования блокировки, возможно, у вас может быть отдельный процесс, который отвечал за сохранение блокировки файла. Чтобы начать шаг чтения/изменения/записи, Thread должен был бы спросить этот центральный процесс для блокировки через HTTP или обмен сообщениями или что угодно. Если запрос отклонен, поток перейдет в спящий режим, проснется и повторите попытку. В противном случае Thread будет читать/изменять/записывать, а затем сообщать процессу блокировки, что он освобождает блокировку.
Вы хотите синхронизировать некоторые объекты. Например:
synchronized(fileLockObject) {
readContentsFromFile(f);
modifyContentsFromFile(f);
writeFile(f);
}