Future.get(超时)的基础线程行为

我们正在使用Future以超时来完成任务。 当时间限制超过时,我们会收到TimeOutException 。 从thread dump的行为,我意识到底层线程继续。

是这样的吗? 如何处理漫游的multithreading? 如果从池中删除的线程没有IOException ,该怎么办?

如果这是真的,那么kill底层线程的方法是什么。 在我的情况下,它一直在等待外部IO

线程转储的一部分:

 Thread 29587: (state = IN_NATIVE) - java.net.SocketInputStream.socketRead0(java.io.FileDescriptor, byte[], int, int, int) @bci=0 (Compiled frame; information may be imprecise) - java.net.SocketInputStream.read(byte[], int, int) @bci=84, line=129 (Compiled frame) - java.io.BufferedInputStream.fill() @bci=175, line=218 (Compiled frame) - java.io.BufferedInputStream.read1(byte[], int, int) @bci=44, line=258 (Compiled frame) - java.io.BufferedInputStream.read(byte[], int, int) @bci=49, line=317 (Compiled frame) - sun.net.www.MeteredStream.read(byte[], int, int) @bci=16, line=116 (Compiled frame) - java.io.FilterInputStream.read(byte[], int, int) @bci=7, line=116 (Compiled frame) - sun.net.www.protocol.http.HttpURLConnection$HttpInputStream.read(byte[], int, int) @bci=4, line=2672 (Compiled frame) - javax.imageio.stream.FileCacheImageInputStream.readUntil(long) @bci=64, line=121 (Compiled frame) - javax.imageio.stream.FileCacheImageInputStream.read(byte[], int, int) @bci=69, line=167 (Compiled frame) - com.sun.imageio.plugins.jpeg.JPEGImageReader.readImageHeader(long, boolean, boolean) @bci=0 (Compiled frame) - com.sun.imageio.plugins.jpeg.JPEGImageReader.readNativeHeader(boolean) @bci=12, line=532 (Compiled frame) - com.sun.imageio.plugins.jpeg.JPEGImageReader.checkTablesOnly() @bci=92, line=277 (Compiled frame) - com.sun.imageio.plugins.jpeg.JPEGImageReader.gotoImage(int) @bci=41, line=409 (Compiled frame) - com.sun.imageio.plugins.jpeg.JPEGImageReader.readHeader(int, boolean) @bci=2, line=525 (Compiled frame) - com.sun.imageio.plugins.jpeg.JPEGImageReader.readInternal(int, javax.imageio.ImageReadParam, boolean) @bci=3, line=968 (Compiled frame) - com.sun.imageio.plugins.jpeg.JPEGImageReader.read(int, javax.imageio.ImageReadParam) @bci=8, line=948 (Compiled frame) - javax.imageio.ImageIO.read(javax.imageio.stream.ImageInputStream) @bci=55, line=1422 (Compiled frame) - javax.imageio.ImageIO.read(java.net.URL) @bci=42, line=1374 (Compiled frame) 

一旦发生TimeOutException(对于循环中的任何任务),我们取消这样的任务:

 for(Entry<Requests, Future> futureTask : futureTasks.entrySet()) { Future future = futureTask.getValue(); if(!future.isDone() || future.isCancelled()) { future.cancel(true); } } 

它不应该解决问题吗?

请指教。

提前致谢。

是的,这是你的线程继续执行任务不受影响的情况。 TimeoutException表示您没有在适当的时间获得结果。

如果要中断底层线程,可以处理exception并使用Future的已实现实现中的cancel(true)方法。

编辑

我错过了你的线程正在等待阻塞I / O的情况,因为你的堆栈跟踪解释了。 从future.cancel(true)调用的Thread.interrupt()在这种情况下无济于事。

这种情况的共同模式是关闭潜在的输入流。 我对javax.imageio包不是很熟悉,但在ImageIO上有一个重载方法接受InputStream 。 您可能希望将其存储在某个位置,然后在超时时将其关闭。

它将在SocketInputStream上调用close() ,而SocketInputStream又调用底层Socket的 close()方法,该方法正在等待阻塞读取完成。 在此套接字上的I / O操作(根据您的跟踪)阻塞的执行线程将停止等待带有SocketException的 EOF。