我有一个线程,其中在循环中调用InputStream的read()方法.当没有更多字节要读取时,流将阻塞,直到新数据到达.
如果我从另一个线程调用InputStream上的close(),则流将关闭,但阻塞的read()调用仍然被阻止.我假设read()方法现在应该以值-1返回以指示流的结束,但它不会.相反,它会被阻塞几分钟,直到发生tcp超时.
如何取消阻止close()调用?
编辑:
显然,当阻塞的read()调用对应的流或套接字是close()’时,常规JRE会立即抛出SocketException.但是,我使用的Android Java运行时不会.
解决方法
只有有可用数据时才调用read().
做那样的事情:
while( flagBlock ) { if( stream.available() > 0 ) { stream.read( byteArray ); } }
设置flagBlock以停止读取.