Отмена операции считывания

Question

DataInputStream in; 

byte[] b = new byte[1024]; 
for (;;){ 
in.read(b); 
//do something 
} 

У меня есть вышеуказанный код. В другом потоке я обрабатываю некоторые другие события. В этом потоке я хочу отменить операцию чтения, показанную в приведенном выше коде. Как я могу сделать?

Answer 1

Что делать, если вы отправляете из другого потока некоторых данных

final byte[] TERMINATOR = ...; 
in.Write(TERMINATOR) 

Показания нить может в этом случае не следует использовать для цикла, но проверить для последовательности «терминатора».

Answer 2

Вы должны использовать java.nio пакет, проверить здесь http://rox-xmlrpc.sourceforge.net/niotut/

Answer 3

Вы можете либо закрыть InputStream вы читаете из, или вы можете переработать свой код только для чтения данных, когда на самом деле какие-либо данные read-which, возможно, почти невозможно, если вы не контролируете письменную сторону.

Answer 4

Вам необходимо использовать java.nio для чтения из вашего потока, после чего вы можете позвонить thread.interrupt() с другой темы, чтобы прервать любые текущие read.

Answer 5

Вы можете сбросить входной поток, если вы хотите:

DataInputStream in; 

byte[] b = new byte[1024]; 
in.mark(b.length()); 
try { 
for (;;){ 
in.read(b); 
//do something 
} 
} 
catch (InterruptedException e) { 
in.reset(); 
} 

Answer 6

Может быть, я что-то не понял, но я думаю, что вы хотите использовать шаблон Observer.