Как узнать, закрыт ли поток BufferedReader

Question

У меня есть два потока в Java.

Первого потока закрытие BufferedReader (br.close())

Когда второй поток выполняет чтение на тот же читатель, я получаю IOException (Stream Closed)

Я получаю это исключение, даже если я использую br.ready()

ли есть ли способ узнать, закрыт ли поток?

Answer 1

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

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

Answer 2

Если вы уже начали операцию чтения, вы будете уведомлены с помощью исключения IOEx, что поток закрыт. Даже если вы ранее вызывали br.ready(), исключение происходит, когда ваш код блокируется при чтении.

Невозможно избежать этого. Напротив, вы должны ожидать, что операция чтения вызовет исключение и будет подготовлена ​​к его правильной обработке.

Answer 3

Действительно, глядя на secureOpen(), он проверяет, нет ли объекта. Поскольку он является частным, мы не можем получить к нему доступ извне. Но если вам это действительно нужно, вы можете использовать отражение.

BufferedReader myBR = new BufferedReader(new FileReader("c:/somefile.txt")); 
myBR.close(); 

Class c = myBR.getClass(); 
Field in = c.getDeclaredField("in"); 
in.setAccessible(true);   
Object inReader = in.get(myBR); 


if(inReader == null){ 
    System.out.println("is closed"); 
} 
else{ 
    System.out.println("is open"); 
} 

Answer 4

Метод ready() будет выдавать исключение, если оно закрыто. Но даже если вы добавили закрытый метод проверки, пока блокировка освобождается между вызовами (что соответствует BufferedReader), читатель может быть закрыт к тому моменту, когда вы его прочитаете.

Я вижу три варианта:

1. Оберните чтения вызова с помощью попытаться/поймать блок для обработки закрытого корпуса.
2. Создайте подкласс BufferedReader, который расширяет close(), чтобы установить свою собственную переменную, чтобы может использоваться, чтобы проверить, не закрыт ли читатель. Это также требует переопределения большого количества методов для выполнения любых действий, которые вы хотите, с помощью закрытого считывателя, если вы хотите, чтобы он делал что-то около броска IOException.
3. Добавьте свою собственную блокировку и используйте ее как для закрытия читателя (один поток), так и для убедитесь, что буфер готов и прочитан из него. Вы можете либо установить переменную непосредственно для проверки, либо просто сгруппировать вызовы ready() и read() в один и тот же синхронизированный блок.

Answer 5

Другим способом было бы расширить BufferedReader в вашем собственном классе, переопределив метод close(), чтобы указать, был ли он закрыт.

Answer 6

Если вы только что прочитали из BufferedReader и закроете это ваши потоки, я бы просто сделал синхронизированный раздел и установил некоторые плоские при закрытии Reader.Поэтому в каждом потоке вы должны:

1. Открыть синхронизированный раздел.
2. Проверьте, не закончился ли поток (отметьте флаг).
3. Читайте с потока.
4. Закрыть поток.
5. Установите флаг.
6. End synchronized section.

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