Есть 2 потока. Один читае файл, а другой пишет. Как синхронизировать доступ к файлу ?

Простейший способ, хотя и не самый оптимальный:

Код

Object LOCK = new Object(); .... synchronized(LOCK) { //делаем здесь ВСЕ манипуляции с файлом }

Есть еще варианты, но надо смотреть по задаче, надо ли уведомлять читающий процесс о новых данных, надо ли на это время останавливать запись в файл и т.д.

Это сообщение отредактировал(а) LSD - 13.2.2005, 00:12

Смысл такой - читающий поток проверяет дату последнего изменения файла. Если она изменилась, то он читает его. Пишуший поток просто пишет через определенные период времени.

Тогда можно сделать как LSD предлагает, только учти что lock должен быть один и тот же для обеих тредов

Код

public static final Object LOCK = new Object(); ... // тред 1 synchronized(LOCK) {   проверяем дату } ... // тред 2 synchronized(LOCK) {     пишем в файл }

Наверное так не получится - эти потоки находятся в разных приложениях.

Тоесть они могут запускаться независимо друг от друга.

Может это можно сделать средствами самого файла ?

Цитата(zss @ 13.2.2005, 10:41)

Может это можно сделать средствами самого файла ?

Для чтения использовать RandomAccessFile и открывать файл на запись, если в этот момент в файл пишет другая программа, то будет ошибка.

public void syncronized read() throws .... {
// insert code here
}
public void syncronized write() throws ....{
// insert code here
}

Цитата

public void syncronized read() throws .... { // insert code here } public void syncronized write() throws ....{ // insert code here }

Все это не должно принадлежать этим двум тредам.

Пожалуйстa пользуйся тегами [codе=javа] [/code].

Цитата

Есть 2 потока. Один читае файл, а другой пишет. Как синхронизировать доступ к файлу ?

Цитата

Наверное так не получится - эти потоки находятся в разных приложениях. Тоесть они могут запускаться независимо друг от друга.

Пока не оказалось, что это вообще разные файлы на разных машинах, предложу следующее (это просто кусок из моего кода, не адаптированный под текущий вопрос):

Код

... FileInputStream fis = new FileInputStream( ...); FileChannel chan = fis.getChannel(); FileLock lock = chan.tryLock(0, Long.MAX_VALUE, true); if (lock == null) {    System.out.println( "Другой процесс использует файл"); } else {    ...    lock.release(); } fis.close(); ...

Это сообщение отредактировал(а) Zandr - 28.2.2005, 14:30

Цитата(Zandr @ 26.2.2005, 10:20)

Пока не оказалось, что это вообще разные файлы на разных машинах

Это один файл на одной машине (PC1), но читатель и писатель на разных (PC2 и PC3)

Тоесть участвуют 2 разные машины для манипуляцией файлом, а сам он лежит на третьей (например на сервере)

извиняюсь - не зашел

Значит юзай блокировки на уровне файловой системы, как в примере выше (я его попровил немного). Там осуществляется попытка блокировки на запись. Остальное в API.

Что-то не очень-то получается

если блокировать и читающий процесс и пишущий, то вроде все должно работать, но все равно слетает

Не, процессы блокировать не нужно. Блокировать нужно файлы Если твой процесс читает файл - есть смысл заблокировать файл на изменение, если твой процесс пишет в файл, то есть смысл заблокировать файл вообще. Естественно что нужно аккуратно все это делать. Заблокировать можно не весь файл, а только его часть. Блокировка (которая выше) работает не на уровне Java-машины, а на уровне операционки. Поэтому если блокируешь файл на доступ, то другие программы не могут его прочитать не зависимо от того на каком языке они написаны. Есть криво написанные программы, которые не блокируют файлы, обрабатывающиеся продолжительное время.

Цитата

все равно слетает

В какую сторону?

Пробовал тестовый вариант, в котором при чтении файл блокируется для изменения, а при записи монопольно - вроде все работает. Непонятно, почему при чтении тоже нельзя монопольно заблокировать ?

Код

java.nio.channels.NonWritableChannelException     at sun.nio.ch.FileChannelImpl.tryLock(FileChannelImpl.java:784)     at java.nio.channels.FileChannel.tryLock(FileChannel.java:967)

Тестовый вариант

Код

public class Lock {     private static String filePath = "C:\\test.txt";     private static File file = new File (filePath);     public Lock() {         readFile();                 writeFile();                     }     public void readFile (){         try {                         FileInputStream stream = new FileInputStream ( file );             FileChannel chan = stream.getChannel ();             FileLock lock = chan.tryLock (0, Long.MAX_VALUE, true);             if ( lock == null ) {                 System.out.println ( "Файл заблокирован на запись" );                 return;             }             else { //                lock.release (); //                chan.close(); //                stream.close ();             }         }         catch ( Throwable t ) {             t.printStackTrace ();         }     }     public void writeFile(){         try {             StreamResult outStream = new StreamResult ( file );                                       FileOutputStream stream = new FileOutputStream ( file );             FileChannel chan = stream.getChannel ();             FileLock lock = chan.tryLock ();             if ( lock == null ) {                 System.out.println ( "Файл заблокирован на чтение" );                 return;             }             else { //                stream.write(-1); //                lock.release (); //                chan.close(); //                stream.close ();             }         }         catch ( Throwable ex ) {             ex.printStackTrace ();         }     }     public static void main(String[] args) {         Lock lock = new Lock ();     } }

И самое главное. Это все работает при FileInputStream & FileOutputStream. Но мне надо при записи использовать StreamResult - а с ним к сожалению не получится получить FileChannel. Как быть ?

Думал прокатит так

Код

FileOutputStream stream = new FileOutputStream (file);             StreamResult out = new StreamResult ( stream );                         FileChannel chan = stream.getChannel ();             FileLock lock = chan.tryLock ();             if ( lock == null ) {                 System.out.println ( "Файл заблокирован на чтение" );                 return;             }             else {     transformer.transform ( source, out );                 lock.release ();                 chan.close();                 stream.close ();             }

Но не дает писать - говорит файл заблокирован

P.S. Блин - задолбался с этой синхронизацией, что нельзя было просто сделать что-нибудь вроде Mutex

Это сообщение отредактировал(а) zss - 12.3.2005, 15:45