// Упрощенная структура из OpenJDK
public class BufferedReader extends Reader {
    // Буфер символов в heap JVM
    private char[] cb;
    
    // Количество символов в буфере
    private int nChars;
    
    // Текущая позиция чтения
    private int nextChar;
    
    // Маркер для mark/reset
    private int markedChar = UNMARKED;
    private int readAheadLimit = 0;
    
    // Признак пропуска \n после \r
    private boolean skipLF = false;
    
    // Конструкторы
    public BufferedReader(Reader in) {
        this(in, defaultCharBufferSize); // 8192 по умолчанию
    }
    
    public BufferedReader(Reader in, int sz) {
        super(in);
        if (sz <= 0)
            throw new IllegalArgumentException("Buffer size <= 0");
        cb = new char[sz]; // Выделение в heap
    }
}

// Упрощенная логика readLine()
public String readLine() throws IOException {
    StringBuilder sb = new StringBuilder(defaultExpectedLineLength);
    
    while (true) {
        if (nextChar >= nChars) {
            fill(); // Заполнение буфера из underlying Reader
            if (nextChar >= nChars) {
                // Конец потока
                return sb.length() > 0 ? sb.toString() : null;
            }
        }
        
        char c = cb[nextChar++];
        
        if (c == '\n') {
            if (skipLF) {
                skipLF = false;
                continue; // Пропуск \n после \r
            }
            return sb.toString(); // Строка завершена
        }
        
        if (c == '\r') {
            skipLF = true;
            return sb.toString(); // Строка завершена, \n будет пропущен
        }
        
        sb.append(c); // Накопление символов
    }
}

[Диск: файл в байтах UTF-8]
  -> [Page Cache ОС]
    -> [FileInputStream: системный вызов read()]
      -> [InputStreamReader: декодирование байт -> char]
        -> [BufferedReader.fill(): копирование char[] в cb[8192]]
          -> [BufferedReader.readLine(): поиск \n в cb]
            -> [StringBuilder: накопление символов строки]
              -> [StringBuilder.toString(): создание String в heap]
                -> [Возврат String]

// Длинная строка превышает начальную емкость StringBuilder
StringBuilder sb = new StringBuilder(80); // Начальный массив char[80]
// Строка длиной 200 символов
// sb расширяется: char[80] -> char[160] -> char[320] -> ...
// Старые массивы становятся мусором

public long countLines(String path) throws IOException {
    long lineCount = 0;
    
    try (BufferedReader reader = new BufferedReader(
            new InputStreamReader(
                new FileInputStream(path), StandardCharsets.UTF_8))) {
        
        String line;
        while ((line = reader.readLine()) != null) {
            lineCount++;
            // line — новая String в heap
            // StringBuilder и его внутренний char[] — мусор
        }
        
    } // reader закрыт, cb освобожден
    
    return lineCount;
}

// Антипаттерн: удержание всех строк в памяти
public List<String> readAllLines(String path) throws IOException {
    List<String> lines = new ArrayList<>();
    
    try (BufferedReader reader = new BufferedReader(
            new InputStreamReader(new FileInputStream(path), StandardCharsets.UTF_8))) {
        
        String line;
        while ((line = reader.readLine()) != null) {
            lines.add(line); // Все String удерживаются списком
        }
    }
    
    return lines; // Возврат: все строки в heap
}

// Правильно: потоковая обработка без хранения всех строк
public void processLines(String path, Consumer<String> processor) throws IOException {
    try (BufferedReader reader = new BufferedReader(
            new InputStreamReader(new FileInputStream(path), StandardCharsets.UTF_8))) {
        
        String line;
        while ((line = reader.readLine()) != null) {
            processor.accept(line);
            // line становится недостижимой после итерации, если processor не сохраняет
        }
    }
}

// Антипаттерн: удержание всех строк в памяти
public List<String> readAllLines(String path) throws IOException {
    List<String> lines = new ArrayList<>();
    
    try (BufferedReader reader = new BufferedReader(
            new InputStreamReader(new FileInputStream(path), StandardCharsets.UTF_8))) {
        
        String line;
        while ((line = reader.readLine()) != null) {
            lines.add(line); // Все String удерживаются списком
        }
    }
    
    return lines; // Возврат: все строки в heap
}

// Правильно: потоковая обработка без хранения всех строк
public void processLines(String path, Consumer<String> processor) throws IOException {
    try (BufferedReader reader = new BufferedReader(
            new InputStreamReader(new FileInputStream(path), StandardCharsets.UTF_8))) {
        
        String line;
        while ((line = reader.readLine()) != null) {
            processor.accept(line);
            // line становится недостижимой после итерации, если processor не сохраняет
        }
    }
}

import java.io.*;
import java.nio.charset.StandardCharsets;

public class LineCounter {
    
    public LineStats analyzeFile(String path) throws IOException {
        long lineCount = 0;
        long totalChars = 0;
        long maxLineLength = 0;
        String longestLine = null;
        
        // BufferedReader с underlying InputStreamReader и FileInputStream
        // cb[8192] создается в heap при конструировании
        try (BufferedReader reader = new BufferedReader(
                new InputStreamReader(
                    new FileInputStream(path), StandardCharsets.UTF_8))) {
            
            String line;
            while ((line = reader.readLine()) != null) {
                lineCount++;
                long lineLength = line.length();
                totalChars += lineLength;
                
                if (lineLength > maxLineLength) {
                    maxLineLength = lineLength;
                    longestLine = line; // Сохранение ссылки — String остается в heap!
                }
            }
            
        } // close() освобождает cb, но longestLine удерживается
        
        return new LineStats(lineCount, totalChars, maxLineLength, longestLine);
    }
    
    public record LineStats(long lineCount, long totalChars, 
                           long maxLineLength, String longestLine) {}
}

// Если нужна только длина, не хранить строку
public LineStats analyzeFileOptimized(String path) throws IOException {
    long lineCount = 0;
    long totalChars = 0;
    long maxLineLength = 0;
    
    try (BufferedReader reader = new BufferedReader(
            new InputStreamReader(new FileInputStream(path), StandardCharsets.UTF_8))) {
        
        String line;
        while ((line = reader.readLine()) != null) {
            lineCount++;
            long lineLength = line.length();
            totalChars += lineLength;
            maxLineLength = Math.max(maxLineLength, lineLength);
            // line не сохраняется — собирается GC
        }
    }
    
    return new LineStats(lineCount, totalChars, maxLineLength, null);
}

// Строка длиной 100 000 символов без \n
// readLine() выполняет ~13 вызовов fill(), накапливая в StringBuilder

StringBuilder sb = new StringBuilder(80); // Начальный массив char[80]
// При достижении 80: расширение до 160, копирование
// При достижении 160: расширение до 320, копирование
// ...
// Итоговый массив char[131072] для 100000 символов

// Если известна ожидаемая длина строки
StringBuilder sb = new StringBuilder(expectedLineLength);

// Потоковое чтение без явного BufferedReader
public long countLinesStream(String path) throws IOException {
    try (Stream<String> lines = Files.lines(Path.of(path), StandardCharsets.UTF_8)) {
        return lines.count();
    }
}

import java.io.*;

public class Task230626 {
    public static void main(String[] args) throws IOException {
        BufferedReader br = new BufferedReader(new StringReader("Hello"));
        br.reset();
        System.out.println("Done");
    }
}

import java.util.*;
import java.util.stream.*;

public class ToMapDuplicate {
    
    public static void main(String[] args) {
        List<String> items = Arrays.asList("apple", "banana", "apple", "cherry");
        
        //Антипаттерн: выбросит IllegalStateException
        try {
            Map<String, Integer> bad = items.stream()
                .collect(Collectors.toMap(s -> s, String::length));
        } catch (IllegalStateException e) {
            System.err.println("Duplicate key: " + e.getMessage());
        }
        
        //Решение 1: оставить первое значение
        Map<String, Integer> first = items.stream()
            .collect(Collectors.toMap(
                s -> s,
                String::length,
                (oldVal, newVal) -> oldVal
            ));
        System.out.println("First: " + first); // {banana=6, apple=5, cherry=6}
        
        //Решение 2: взять последнее значение (часто для перезаписи)
        Map<String, Integer> last = items.stream()
            .collect(Collectors.toMap(
                s -> s,
                String::length,
                (old, newVal) -> newVal
            ));
        System.out.println("Last: " + last);
        
        //Решение 3: объединить значения (например, список длин)
        Map<String, List<Integer>> grouped = items.stream()
            .collect(Collectors.toMap(
                s -> s,
                s -> new ArrayList<>(List.of(s.length())),
                (list1, list2) -> { list1.addAll(list2); return list1; }
            ));
        System.out.println("Grouped: " + grouped);
        
        //Альтернатива: groupingBy для агрегации
        Map<String, Long> countByKey = items.stream()
            .collect(Collectors.groupingBy(
                s -> s,
                Collectors.counting()
            ));
        System.out.println("Counts: " + countByKey);
    }
}

import java.util.*;
import java.util.stream.*;

public class Task240626 {
    static class Person240626 {
        int id;
        String name;
        Person240626(int id, String name) {
            this.id = id;
            this.name = name;
        }
    }

    public static void main(String[] args) {
        List<Person240626> people = Arrays.asList(
            new Person240626(1, "Alice"),
            new Person240626(2, "Bob"),
            new Person240626(1, "Charlie")
        );

        try {
            Map<Integer, String> map = people.stream()
                    .collect(
                            Collectors.toMap(p -> p.id, p -> p.name)
                    );
            
            System.out.println("Success");
            
        } catch (Exception e) {
            System.out.println(e.getClass().getSimpleName());
        }
    }
}

// Упрощенная структура из OpenJDK
public class BufferedWriter extends Writer {
    // Внутренний буфер символов в heap JVM
    private char[] cb;
    
    // Текущая позиция записи в буфере
    private int nChars;
    
    // Ссылка на underlying Writer
    private Writer out;
    
    // Разделитель строки для newLine()
    private String lineSeparator;
    
    // Конструкторы
    public BufferedWriter(Writer out) {
        this(out, defaultCharBufferSize); // 8192 по умолчанию
    }
    
    public BufferedWriter(Writer out, int sz) {
        super(out);
        if (sz <= 0) {
            throw new IllegalArgumentException("Buffer size <= 0");
        }
        this.out = out;
        cb = new char[sz]; // Выделение в heap: 8192 * 2 = 16384 байт
        nChars = 0;
        lineSeparator = System.lineSeparator(); // Платформенный разделитель
    }
}

public void write(String s, int off, int len) throws IOException {
    // Если строка не влезает в оставшийся буфер — сброс
    if (len >= cb.length - nChars) {
        flushBuffer(); // Сброс накопленного в underlying Writer
    }
    
    if (len >= cb.length) {
        // Строка больше буфера — запись напрямую, минуя буфер
        writeDirect(s, off, len);
    } else {
        // Копирование строки в буфер
        s.getChars(off, off + len, cb, nChars); // Быстрое копирование из String
        nChars += len;
    }
}

[Java: bw.write("Hello")]
  -> [BufferedWriter: len=5 < cb.length - nChars?]
    -> [s.getChars(0, 5, cb, nChars)] // Копирование char[] из String в buf
      -> [System.arraycopy: копирование 5 char в cb]
    -> [nChars += 5]
  -> [Возврат]

private void flushBuffer() throws IOException {
    if (nChars > 0) {
        out.write(cb, 0, nChars); // Запись в underlying Writer
        nChars = 0; // Сброс позиции
    }
}

[BufferedWriter: flushBuffer()]
  -> [OutputStreamWriter.write(cb, 0, nChars)]
    -> [StreamEncoder: кодирование char[] -> байты UTF-8]
      -> [ByteBuffer: накопление закодированных байт]
        -> [FileOutputStream.write(byte[]): системный вызов]
          -> [Нативный буфер userspace]
            -> [Ядро ОС: syscall write]
              -> [Page Cache: dirty pages]

public void newLine() throws IOException {
    write(lineSeparator); // Запись \n или \r\n из поля lineSeparator
}

// На Unix: запись \n
// На Windows: запись \r\n
// Результат одинаков для кода, различается для файла

public void writeLines(String path, List<String> lines) throws IOException {
    // cb[8192] создается в heap при конструировании BufferedWriter
    try (BufferedWriter writer = new BufferedWriter(
            new OutputStreamWriter(
                new FileOutputStream(path), StandardCharsets.UTF_8))) {
        
        for (String line : lines) {
            writer.write(line);      // Копирование в cb
            writer.newLine();        // Копирование \n или \r\n в cb
            // Системный вызов отсутствует, пока cb не заполнен
        }
        
        // Явный flush для гарантии сброса
        writer.flush();
        
    } // close() с неявным flush()
}

// Допустим, cb заполнен на 8188 символов
// Запись строки "Hello" (5 символов + 1 \n = 6)

writer.write("Hello"); // 8188 + 5 = 8193 > 8192 — сброс!
writer.newLine();        // \n записывается в пустой cb

[write("Hello")]
  -> [len=5 >= cb.length - nChars? 5 >= 4? да]
    -> [flushBuffer()]
      -> [out.write(cb, 0, 8188)] // Сброс 8188 символов в OutputStreamWriter
        -> [StreamEncoder: кодирование 8188 char в байты UTF-8]
          -> [FileOutputStream: системный вызов]
      -> [nChars = 0]
    -> [s.getChars(0, 5, cb, 0)] // "Hello" в cb[0..4]
    -> [nChars = 5]
  
[newLine()]
  -> [write("\n")] // или "\r\n"
    -> [s.getChars(0, 1, cb, 5)] // \n в cb[5]
    -> [nChars = 6]

public void processAndWrite(String inputPath, String outputPath) throws IOException {
    // Все объекты создаются в heap
    try (BufferedReader reader = new BufferedReader(
            new InputStreamReader(new FileInputStream(inputPath), StandardCharsets.UTF_8));
         BufferedWriter writer = new BufferedWriter(
            new OutputStreamWriter(new FileOutputStream(outputPath), StandardCharsets.UTF_8))) {
        
        String line;
        while ((line = reader.readLine()) != null) {
            String processed = processLine(line); // Новая String в heap
            writer.write(processed); // Копирование в cb
            writer.newLine();
            // processed становится мусором, если не сохранена
        }
        
    } // Все потоки закрыты, все буферы освобождены
    
    // reader.cb, writer.cb, ByteBuffer'ы StreamEncoder — недостижимы
    // GC собирает все при следующей minor collection
}

// Строка длиной 100 000 символов
String hugeLine = generateHugeLine();

// write() обнаруживает, что len >= cb.length
// Прямая запись, минуя буфер
writer.write(hugeLine);

import java.io.*;
import java.nio.charset.StandardCharsets;
import java.util.List;

public class LineWriter {
    
    public void writeLines(String path, List<String> lines) throws IOException {
        // Путь данных:
        // String -> char[] -> cb[BufferedWriter] -> ByteBuffer[StreamEncoder] -> FileOutputStream -> page cache -> диск
        
        try (BufferedWriter writer = new BufferedWriter(
                new OutputStreamWriter(
                    new FileOutputStream(path), StandardCharsets.UTF_8))) {
            
            for (String line : lines) {
                writer.write(line);   // Копирование в cb
                writer.newLine();      // Платформенный разделитель
            }
            
            // Явный flush перед закрытием
            writer.flush();
            
        } // close() с неявным flush()
        
        // Все буферы в heap освобождены, GC собирает
    }
    
    // Альтернатива: запись с заголовком и подвалом
    public void writeReport(String path, String header, 
                           List<String> data, String footer) throws IOException {
        try (BufferedWriter writer = new BufferedWriter(
                new OutputStreamWriter(
                    new FileOutputStream(path), StandardCharsets.UTF_8))) {
            
            writer.write(header);
            writer.newLine();
            writer.newLine(); // Пустая строка
            
            for (String line : data) {
                writer.write(line);
                writer.newLine();
            }
            
            writer.newLine(); // Пустая строка перед подвалом
            writer.write(footer);
            writer.newLine();
            
        }
    }
}

// Антипаттерн: запись без буферизации
public void writeUnbuffered(String path, List<String> lines) throws IOException {
    try (OutputStreamWriter writer = new OutputStreamWriter(
            new FileOutputStream(path), StandardCharsets.UTF_8)) {
        
        for (String line : lines) {
            writer.write(line); // Каждый символ = системный вызов!
            writer.write('\n');
        }
    }
}

import java.io.*;

public class Task250626 {
    public static void main(String[] args) throws IOException {
        File file = new File("test.txt");
        try (BufferedWriter bw = new BufferedWriter(new FileWriter(file))) {
            bw.write(65);
        }
        try (BufferedReader br = new BufferedReader(new FileReader(file))) {
            System.out.println(br.readLine());
        }
        file.delete();
    }
}