在Java中，是否可以在一段时间内执行方法并在达到时间限制后停止？
|
我有以下代码可下载网页：
HttpURLConnection connection;
private String downloadContent() {
InputStream content;
Source parser;
try {
content = connection.getInputStream(); //<--here is the download
parser = new Source(content);
content.close();
return parser.toString();
} catch (Exception e) {
return null;
}
}
没有找到相关结果
已邀请:
5 个回复
粟痢凰副
public class TimeOut { public static class MyJob implements Callable<String> { @Override public String call() throws Exception { // Do something return \"result\"; } } public static void main(String[] args) { Future<String> control = Executors.newSingleThreadExecutor().submit(new MyJob()); try { String result = control.get(5, TimeUnit.SECONDS); } catch (TimeoutException ex) { // 5 seconds expired, we cancel the job !!! control.cancel(true); } catch (InterruptedException ex) { } catch (ExecutionException ex) { } } }降女陷费券
注释（我是开发人员）：@Timeable(limit = 1, unit = TimeUnit.SECONDS) String downloadContent() { if (Thread.currentThread.isInterrupted()) { throw new IllegalStateException(\"time out\"); } // download }并将其设置为会引发异常。这是终止Java中线程的唯一方法。 另外，有关更多详细说明，请查看此帖子：http://www.yegor256.com/2014/06/20/limit-method-execution-time.html芜任亮蜡
痰嫉
private static final long TIMEOUT = TimeUnit.SECONDS.toMillis(20); private String downloadContent() { connection.setConnectTimeout(TIMEOUT); /* Set connect timeout. */ long start = System.nanoTime(); final InputStream content; try { content = connection.getInputStream(); } catch (IOException ex) { return null; } /* Compute how much time we have left. */ final long delay = TIMEOUT - TimeUnit.NANOS.toMillis(System.nanoTime() - time); if (delay < 1) return null; /* Start a thread that can close the stream asynchronously. */ Thread killer = new Thread() { @Override public void run() { try { Thread.sleep(delay); /* Wait until time runs out or interrupted. */ } catch (InterruptedException expected) { Thread.currentThread().interrupt(); } try { content.close(); } catch (IOException ignore) { // Log this? } } }; killer.start(); try { String s = new Source(content).parser.toString(); /* Task completed in time; clean up immediately. */ killer.interrupt(); return s; } catch (Exception e) { return null; } }拟僚疽刊剔