如何在Android上解锁InputStream.read()？

我有一个线程,其中在循环中调用InputStream的read()方法.当没有更多字节要读取时,流将阻塞,直到新数据到达.

如果我从另一个线程调用InputStream上的close(),则流将关闭,但阻塞的read()调用仍然被阻止.我假设read()方法现在应该以值-1返回以指示流的结束,但它不会.相反,它会被阻塞几分钟,直到发生tcp超时.

如何取消阻止close()调用？

编辑：

显然,当阻塞的read()调用对应的流或套接字是close()’时,常规JRE会立即抛出SocketException.但是,我使用的Android Java运行时不会.

任何有关Android环境解决方案的提示都将不胜感激.

解决方法

只有有可用数据时才调用read().

做那样的事情：

while( flagBlock )
    {
        if( stream.available() > 0 )
        {
            stream.read( byteArray );
        }
    }

设置flagBlock以停止读取.