Как установить размер буфера в BufferedWriter вместо FileWriter

Есть ли проблема с моим кодом?

Немного. В основном: потенциальные ошибки ввода-вывода и параллелизма. Размер буфера файла может быть меньшей проблемой (и с этим вы не можете эффективно справиться).

• #P3# <блочная цитата> #P4#

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

  В качестве решения (если ваши потоки должны совместно использовать один и тот же вывод) вы можете использовать общий объект с синхронизированным доступом, чтобы позаботиться о фактической записи. Я реализовал SafeAppender в своем примере, но, вероятно, есть лучшие альтернативы.

• Никакие очистка и закрытие буферов не будут означать, что ваши данные будут потеряны (как слезы под дождем). Блок finally обычно хорош, чтобы позаботиться об этом.

• Кроме того, как утверждают другие пользователи, BufferedWriter размер буфера не влияет на размер буфера в FileOutputStream (и, следовательно, FileWriter). И похоже, что java.io и java.nio API не предлагают никакого способа возиться с этим. Если вы посмотрите на исходные коды библиотеки Java, вы можете заметить, что размер буфера BufferedWriter просто означает количество символов, которые вы сохраняете до фактической записи в вывод делегата. Размер по умолчанию (8192) оптимален для большинства случаев, и его увеличение может привести к большим проблемам (возможно, потере большего количества данных), чем к преимуществам.

Это мой код, если он вам служит:

// http://stackoverflow.com/questions/32451526/how-to-set-the-buffer-size-on-a-bufferedwriter-over-a-filewriter
public class TestWriter {

public static class SafeAppender {
    private BufferedWriter bw;
    private int users = 0;
    public SafeAppender(File f) throws IOException {
        bw = new BufferedWriter(new FileWriter(f));
    }

    public synchronized void append(String s) throws IOException {
        bw.write(s);
    }
    public synchronized void incrUsers() { 
        users ++; 
    }
    public synchronized void decrUsers() {
        if (--users <= 0) {
            try {
                bw.flush();
                System.err.println("INFO-appender-flush()");
            } catch (Throwable whatever) { /* log-if-you-care*/}
        }
    }
    // Might be called by GC, or not
    @Override protected void finalize() throws Throwable {
        try {
            bw.close();
            System.err.println("INFO-appender-close()");
        } catch (Throwable whatever) { /* log-if-you-care */}
        super.finalize();
    }
}

private static class MyRunnable implements Runnable {
    final static String S = "{addffffffkkkljlkj2015dd}";
    SafeAppender appender;
    String threadId;
    public MyRunnable (SafeAppender a, String tid) {
        appender = a; threadId = tid;
    }

    public void run() {
        appender.incrUsers();
        try {
            for(int i =0 ; i<1000; i++){
                // NOTE: Not a good idea to printStackTrace if each line fails. Let thread fail
                String line = String.format("%s-%03d-%s\n", threadId, i, S);
                appender.append(line);
            }
        } catch (IOException e) {
            System.err.printf("ERROR-%s-%s\n", threadId, e.toString());
        } finally {
            appender.decrUsers();
        }
    }
}

public static void main(String[] args) {
    try {
        File f = File.createTempFile("TestWriter", ".txt");
        System.err.printf("INFO-main-Writing into %s\n", f.getCanonicalPath());
        SafeAppender appender = new SafeAppender (f);
        for(int i =0;i<10;i++){
            MyRunnable r = new MyRunnable(appender, ""+i);
            Thread t = new Thread(r);
            t.start();
        }
    } catch (Throwable e) {
        e.printStackTrace(System.err);
    }
}

}

FileWriter фактически использует свой собственный буфер фиксированного размера 1024 байта. С другой стороны, BufferedWriter показывает, что он использует размер буфера 8192 байта (по умолчанию), который может быть настроен пользователем на любой другой желаемый размер.

И чтобы еще больше замутить воду, реализация Java 6 OutputStreamWriter фактически делегирует StreamEncoder, который использует свой собственный буфер с размером по умолчанию 8192 байта. И буфер StreamEncoder настраивается пользователем, хотя нет возможности получить к нему прямой доступ через охватывающий OutputStreamWriter.

Я решаю проблему, используя OutputStream, а не писатель, вот код:

bw = new BufferedOutputStream(
                new FileOutputStream(new File("/Users/liaoliuqing/Downloads/1.txt"),true),165537);

Вы видите не размер буфера BufferedWriter, а размер буфера, используемого внутри FileWriter. Цитата из документации по Java (http://docs.oracle.com/javase/7/docs/api/java/io/FileWriter.html)

Конструкторы этого класса предполагают, что кодировка символов по умолчанию и размер байтового буфера по умолчанию являются приемлемыми. Чтобы указать эти значения самостоятельно, создайте OutputStreamWriter в FileOutputStream.

Поэтому, если вы хотите иметь точный контроль над тем, когда данные фактически записываются на диск, вы должны создать экземпляр BufferedWriter как

bw = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(new File('my_file.txt),true)));