时间:2021-05-19
任务超时处理是比较常见的需求,比如在进行一些比较耗时的操作(如网络请求)或者在占用一些比较宝贵的资源(如数据库连接)时,我们通常需要给这些操作设置一个超时时间,当执行时长超过设置的阈值的时候,就终止操作并回收资源。Java中对超时任务的处理有两种方式:一种是基于异步任务结果的超时获取,一种则是使用延时任务来终止超时操作。下文将详细说明。
一、基于异步任务结果的超时获取
基于异步任务结果的获取通常是跟线程池一起使用的,我们向线程池提交任务时会返回一个Future对象,在调用Future的get方法时,可以设置一个超时时间,如果超过设置的时间任务还没结束,就抛出异常。接下来看代码:
public class FutureDemo { static ExecutorService executorService= Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors()*2); public static void main(String[] args) { Future<String> future = executorService.submit(new Callable<String>() { @Override public String call() { try { TimeUnit.SECONDS.sleep(10); } catch (InterruptedException e) { System.out.println("任务被中断。"); } return "OK"; } }); try { String result = future.get(2, TimeUnit.SECONDS); } catch (InterruptedException |ExecutionException | TimeoutException e) { future.cancel(true); System.out.println("任务超时。"); }finally { System.out.println("清理资源。"); } }}运行代码,输出如下:
二、使用延时任务来终止超时操作
还有一种实现任务超时处理的思路是在提交任务之前先设置一个定时器,这个定时器会在设置的时间间隔之后去取消任务。当然如果任务在规定的时间内完成了,要记得取消定时器。首先来看一下我们的工作线程:
public class RunningTask { private volatile boolean isStop; public void stop(){ this.isStop=true; } public void doing() { int i=1; while (!isStop){ try { TimeUnit.SECONDS.sleep(1); } catch (InterruptedException e) { } } System.out.println("任务被中断。"); }}这个工作线程每隔一秒钟会去检查下isStop变量,因此我们可以通过isStop变量来取消任务。至于取消任务的逻辑我们放在了定时器里面,代码如下:
public class CancelTask implements Runnable { private RunningTask runningTask; public CancelTask(RunningTask runningTask) { this.runningTask = runningTask; } @Override public void run() { runningTask.stop(); }}可以看到,该定时器的作用就是在一定的时间之后去中断工作线程的运行。接下来测试一下:
public class ScheduleDemo { static ScheduledExecutorService executorService= Executors.newScheduledThreadPool(Runtime.getRuntime().availableProcessors()*2); public static void main(String[] args) { RunningTask runningTask=new RunningTask(); ScheduledFuture<?> scheduledFuture = executorService.schedule(new CancelTask(runningTask), 3, TimeUnit.SECONDS); runningTask.doing(); if(!scheduledFuture.isDone()){ scheduledFuture.cancel(true); } }}运行结果如下:
可以看到,任务在超时之后也可以被取消。
总结
以上所述是小编给大家介绍的Java实现任务超时处理方法,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对网站的支持!
如果你觉得本文对你有帮助,欢迎转载,烦请注明出处,谢谢!
声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。
本文实例分析了PHP进行批量任务处理不超时的解决方法。分享给大家供大家参考,具体如下:PHP批量任务处理PHP在批量处理任务的时候会超时,其实解决方法很简单了,
公司项目需求,要实现任务卡片在不同任务列表之间进行拖拽实现任务类别的更改。于是找了一下相关文章,稍微学习了一下。实现效果如下图。拖拽实现主要用到的是H5自带的拖
CommandLineRunner接口可以实现任务的自动加载,当项目启动完后,就会自动去执行CommandLineRunner接口里的run方法,你可以实现多个
java对象的克隆一、对象的浅克隆(1)需要克隆类需要重写Object类的clone方法,并且实现Cloneable接口(标识接口,无需实现任何方法)(2)当需
任务队列是指能够实现任务在多线程间安全传递的先入先出的队列。任务是指组合了数据和操作的对象,这里面定义为CTask类的对象。任务的实现:Task.cpp#inc