Платные хостинги     Раскрутка сайта     Книги по программированию

Синхронизация доступа, к файлу

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

- Простейший способ, хотя и не самый оптимальный:Код Object LOCK = new Object();....synchronized(LOCK){//делаем здесь ВСЕ манипуляции с файлом}highlightSyntax('javac0OTM=','java');Есть еще варианты, но надо смотреть по задаче, надо ли уведомлять читающий процесс о новых данных, надо ли на это время останавливать запись в файл и т.д. Это сообщение отредактировал LSD - 13.2.2005, 00:12

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

- Тогда можно сделать как LSD предлагает, только учти что lock должен быть один и тот же для обеих тредовКод public static final Object LOCK = new Object();... // тред 1synchronized(LOCK){   проверяем дату} ...// тред 2synchronized(LOCK){     пишем в файл} highlightSyntax('javaOTE4YW','java');

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

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

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

- Все это не должно принадлежать этим двум тредам.Пожалуйстa пользуйся тегами [codе=javа] [/code].

- Цитата Наверное так не получится - эти потоки находятся в разных приложениях.Тоесть они могут запускаться независимо друг от друга.Пока не оказалось, что это вообще разные файлы на разных машинах, предложу следующее (это просто кусок из моего кода, не адаптированный под текущий вопрос):Код ...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();...highlightSyntax('javaDU5ODQ','java'); Это сообщение отредактировал Zandr - 28.2.2005, 14:30

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

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

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

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

- Пробовал тестовый вариант, в котором при чтении файл блокируется для изменения, а при записи монопольно - вроде все работает. Непонятно, почему при чтении тоже нельзя монопольно заблокировать ?Код java.nio.channels.NonWritableChannelException    at sun.nio.ch.FileChannelImpl.tryLock(FileChannelImpl.java:784)    at java.nio.channels.FileChannel.tryLock(FileChannel.java:967)highlightSyntax('javaDY3Mzc','java');Тестовый вариантКод 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 ();    }}highlightSyntax('javaZjUyNj','java');И самое главное. Это все работает при 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 ();            }highlightSyntax('javazNjI0N','java');Но не дает писать - говорит файл заблокированP.S. Блин - задолбался с этой синхронизацией, что нельзя было просто сделать что-нибудь вроде Mutex Это сообщение отредактировал zss - 12.3.2005, 15:45

Интернет казино     Онлайн игры     Увеличение члена     Купить DVD