Запись в текстовый файл из нескольких потоков?

Question

У меня 20 потоков, которые пишут с помощью функции println() в файле с именем results.txt. Как я могу синхронизировать их все?

Я отмечаю каждый раз, когда запускается моя программа, у меня есть разное количество строк текста в файле результатов. Txt.

спасибо.

Answer 1

Доступ к файлу через класс, содержащий synchronized method для записи в файл. Только один поток за раз сможет выполнить этот метод.

Я думаю, что Singleton шаблон будет соответствовать вашей проблемы:

package com.test.singleton; 

public class Singleton { 
    private static final Singleton inst= new Singleton(); 

    private Singleton() { 
     super(); 
    } 

    public synchronized void writeToFile(String str) { 
     // Do whatever 
    } 

    public Singleton getInstance() { 
     return inst; 
    } 

} 

Каждый раз, когда вам нужно записать на свой файл, только бы назвать:

Singleton.getInstance().writeToFile("Hello!!"); 

Answer 2

Использование среды журналирования таких как logback, который имеет все, что уже отсортировано.

Answer 3

Вы намерены записать данные в один файл. Поэтому, если вы попытаетесь заблокировать весь файл, для выполнения этой задачи лучше использовать один поток. Хотя вы создаете 20 потоков, но только один из них запускается каждый раз, когда вы вызываете метод, остальные просто ждут блокировки.

Я рекомендую вам использовать RandomAccessFile для записи данных в файл. Затем каждый поток может записывать в файл некоторые уникальные данные без блокировки всего файла.

Некоторые демо-код следующим образом

try { 
    final RandomAccessFile file = new RandomAccessFile("/path/to/your/result.txt", "rw"); 
    final int numberOfThread = 20; 
    final int bufferSize = 512; 
    ExecutorService pool = Executors.newFixedThreadPool(numberOfThread); 
    final AtomicInteger byteCounter = new AtomicInteger(0); 
    final byte[] yourText = "Your data".getBytes(); 
    for (int i = 0; i < yourText.length; i++) { 
     pool.submit(new Runnable() { 
      @Override 
      public void run() { 
       int start = byteCounter.getAndAdd(bufferSize); 
       int chunkSize = bufferSize; 
       if (start + bufferSize > yourText.length) { 
        chunkSize = yourText.length - start; 
       } 
       byte[] chunkData = new byte[chunkSize]; 
       System.arraycopy(yourText, start, chunkData, 0, chunkSize); 
       try { 
        file.write(chunkData); 
       } catch (IOException e) { 
        //exception handle 
       } 
      } 
     }); 
    } 
    file.close(); 
} catch (Exception e) { 
    //clean up 
} 

Answer 4

Дублировать вопрос ... продублировать ответ. As I said here:

Если вы можете держать свой файл как FileOutputStream вы можете заблокировать его, как это:

FileOutputStream file = ... 
.... 
// Thread safe version. 
void write(byte[] bytes) { 
    try { 
    boolean written = false; 
    do { 
     try { 
     // Lock it! 
     FileLock lock = file.getChannel().lock(); 
     try { 
      // Write the bytes. 
      file.write(bytes); 
      written = true; 
     } finally { 
      // Release the lock. 
      lock.release(); 
     } 
     } catch (OverlappingFileLockException ofle) { 
     try { 
      // Wait a bit 
      Thread.sleep(0); 
     } catch (InterruptedException ex) { 
      throw new InterruptedIOException ("Interrupted waiting for a file lock."); 
     } 
     } 
    } while (!written); 
    } catch (IOException ex) { 
    log.warn("Failed to lock " + fileName, ex); 
    } 
}