FetrueTask做java方法超时处理


前言

我们先来了解下同步、异步有什么区别?
同步(Sync)

所谓同步,就是发出一个功能调用时,在没有得到结果之前,该调用就不返回或继续执行后续操作。

根据这个定义,Java中所有方法都是同步调用,应为必须要等到结果后才会继续执行。我们在说同步、异步的时候,一般而言是特指那些需要其他端协作或者需要一定时间完成的任务。

简单来说,同步就是必须一件一件事做,等前一件做完了才能做下一件事。

异步(Async)

异步与同步相对,当一个异步过程调用发出后,调用者在没有得到结果之前,就可以继续执行后续操作。当这个调用完成后,一般通过状态、通知和回调来通知调用者。对于异步调用,调用的返回并不受调用者控制。

对于通知调用者的三种方式,具体如下:

情况 作用
状态 即监听被调用者的状态(轮询),调用者需要每隔一定时间检查一次,效率会很低。
通知 当被调用者执行完成后,发出通知告知调用者,无需消耗太多性能。
回调 与通知类似,当被调用者执行完成后,会调用调用者提供的回调函数。

FutureTask概念

FutureTask一个可取消的异步计算,FutureTask 实现了Future的基本方法,可以查询计算是否已经完成,并且可以获取计算的结果。结果只可以在计算完成之后获取,get方法会阻塞当计算没有完成的时候,一旦计算已经完成,那么计算就不能再次启动或是取消。

一个FutureTask 可以用来包装一个 Callable 或是一个runnable对象。因为FurtureTask实现了Runnable方法,所以一个 FutureTask可以提交(submit)给一个Excutor执行(excution).

FutureTask使用场景

FutureTask可用于异步获取执行结果或取消执行任务的场景。通过传入Runnable或者Callable的任务给FutureTask,直接调用其run方法或者放入线程池执行,之后可以在外部通过FutureTask的get方法异步获取执行结果,因此,FutureTask非常适合用于耗时的计算,主线程可以在完成自己的任务后,再去获取结果。另外,FutureTask还可以确保即使调用了多次run方法,它都只会执行一次Runnable或者Callable任务,或者通过cancel取消FutureTask的执行等。

FutureTask执行多任务计算的使用场景

利用FutureTask和ExecutorService,可以用多线程的方式提交计算任务,主线程继续执行其他任务,当主线程需要子线程的计算结果时,在异步获取子线程的执行结果。
这里写了一个小demo直接上代码:

package com.silin;

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.FutureTask;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;

public class Test03 {

        public static ExecutorService executor =  Executors.newSingleThreadExecutor(); //创建一个线程池
         
        public static  long start = System.currentTimeMillis(); //获取执行到这行代码的系统时间
        
        public static boolean flag = false; //定义个标识
        
        public static int time = 5000;  //定义方法的消耗时间
        
        public static int timeout = 2000;   //定义超时的时间
        /**
         * @param args
         */
        public static void main(String[] args) {
        
                // TODO Auto-generated method stub
               try{
                String result = timeoutMethod(timeout);  //调用timeoutMethod(timeout)方法,并传一个实参
                System.out.println("整个方法实际耗时:" + (System.currentTimeMillis() - start) + "毫秒");  //打印执行完timeoutMethod(timeout)的方法时间
                System.out.println("结果:" + result);
               }catch(Exception e){
                   e.printStackTrace();
                   System.out.println("异常");
               }
           
        }

        /**
         * 有超时时间的方法
         * @param timeout
         * @return
         */
        private  static String timeoutMethod(int timeout)  throws Exception{
            String result = "false";
            FutureTask<String> futureTask = new FutureTask<>(new Callable<String>() { //一个可取消的异步计算。该类提供了一个基类

                @Override
                public String call() throws Exception {
                    //TODO
                    boolean bool = unknowMethod(time); //调用unkonwMethod(time)方法
                    return "false";
                }
            });

            executor.execute(futureTask); //池化线程或调用中执行futureTask
            try {
                result = futureTask.get(timeout, TimeUnit.MILLISECONDS); //这个方法会阻塞,直到任务完成时会返回
            } catch (InterruptedException | ExecutionException | TimeoutException e) {
                //e.printStackTrace();
                
                flag = true;
                futureTask.cancel(true); // 为false时,会等待这个任务执行完,返回true;若任务还没执行,取消任务后返回true,如任务执行完,返回false
                result = "false";
                System.out.println("方法实际执行时间:" + (System.currentTimeMillis() - start) + "毫秒");
                executor.shutdown();
                
                
            }

            return result;
        }

        /**
         * 这个方法的耗时
         * @return
         */
       
        private static boolean unknowMethod (int time) throws  Exception{
            if(flag){
                Thread.sleep(time);
                System.out.println("任务需要耗时: " + time + "毫秒" + "___标志" + flag);
            }else{
                System.out.println("不执行");
            }
           return flag;
        }
    
}

FeatureTast部分方法:

情况 作用
report(int s) 返回已完成任务的结果或引发异常。
isCancelled() 判断task是否在正常完成前取消掉了。
isDone() 返回ture或false
cancel(boolean mayInterruptIfRunning) 取消task的执行,如果task已完成、已被取消、或者由于某些原因取消不了,则返回false
get() 等待task完成,并获取执行结果。可能会抛出异常
get(long timeout, TimeUnit unit) 在指定的时间内等待task完成,并获取执行结果。可能抛出异常(含TimeoutException)

总结:

通过一个小小的demo,进行修改,改成小伙伴所需的。
如果写的不好,还请小伙伴多多批评指正。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 194,088评论 5 459
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 81,715评论 2 371
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 141,361评论 0 319
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 52,099评论 1 263
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 60,987评论 4 355
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 46,063评论 1 272
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 36,486评论 3 381
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 35,175评论 0 253
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 39,440评论 1 290
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 34,518评论 2 309
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 36,305评论 1 326
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 32,190评论 3 312
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 37,550评论 3 298
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 28,880评论 0 17
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 30,152评论 1 250
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 41,451评论 2 341
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 40,637评论 2 335

推荐阅读更多精彩内容