Проблемы многопоточности Java

Question

У меня проблема с синхронизированным чтением моего файла. Случай прост: обрабатывать данные в файле. Моя проблема - синхронизация. Я пытаюсь сделать это на объектном читателе класса BufferedReader, но у меня две проблемы. Если я инициализирую читателя в «try with resourses» моего метода read(), я перейду к различным объектам BufReader для одного и того же объекта, когда буду использовать его в разных ададах. Второй я инициализирую его в классе и получаю тот же объект для потоков, но большую проблему с исключениями и непредсказуемым поведением. Я напишу код для второй ситуации. Можете ли вы посоветовать мне, как решить. Я сейчас учусь, вот почему я хочу советов.

class FileReaderClass { 
    private File file = new File("src\\exer1\\Transfers.txt"); 
    private BufferedReader reader = null; 
    private FileReader fr = null; 

    StringBuilder sb = new StringBuilder(); 

    void read() throws IOException { 
     try { 
      fr = new FileReader(file); 
      reader = new BufferedReader(fr); 
      String buftext; 
       while ((buftext = reader.readLine()) != null){ 
        synchronized (reader) { 
         System.out.println(Thread.currentThread().getName());//for testing 
         sb.append(buftext).append("\n"); 
         //System.out.println(buftext); 
        } 
       } 
      } 
     catch (IOException e) { 
      e.printStackTrace(); 
     } 
     finally { 
      if (reader != null) 
       reader.close(); 
      if (fr != null) 
       fr.close(); 
     } 
    } 
} 

class Reader1 implements Runnable { 

    private FileReaderClass frc; 

    public Reader1(FileReaderClass frc) { 
     this.frc = frc; 
    } 

    @Override 
    public void run() { 
     try { 
      frc.read(); 
     } catch (IOException e) { 
      e.printStackTrace(); 
     } 
    } 
} 
public class Ex1 { 
    public static void main(String[] args) throws InterruptedException { 
     FileReaderClass frc = new FileReaderClass(); 
     Thread t1 = new Thread(new Reader1(frc)); 
     Thread t2 = new Thread(new Reader2(frc)); 

     t1.start(); 
     t2.start(); 
     t1.join(); 
     t2.join(); 
     System.out.println("---------------------"); 
     System.out.println(frc.sb); 

    } 
} 

Answer 1

Вы разделяете тот же FileReaderClass экземпляр (т.е. frc) в двух потоках. Ваш FileReaderClass не является потокобезопасным, что вызывает проблемы. Здесь есть две альтернативы:

• Создайте еще один экземпляр FileReaderClass, так что оба потока будут использовать разные экземпляры.
• Отметить метод read как snychronized.

Вы синхронизируетесь на неправильном уровне. Ваш защитник синхронизации бесполезен, так как на самом деле есть два reader s. Это потому, что каждый раз вызывается read, будет создан reader, который будет отдельным экземпляром. Мы не можем даже точно знать, какой экземпляр был предметом синхронизации.

Answer 2

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

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

Ваш код, как это имеет следующие проблемы

1. Вы всегда создание новых читателей, при этом каждый поток вызова этого метода будет начать с самого начала.
2. Как уже было сказано другим ответом, вы синхронизируете себя на неправильном уровне, любой поток может читать, и планировщик потоков может приостановить его сразу же после того, как ваша запись в объект StringBuilder будет неработоспособной (я думаю, что она не предназначена) ,