Future模式能够这样来描述:我有一个任务,提交给了Future,Future替我完成这个任务。期间我本身能够去作任何想作的事情。一段时 间以后,我就即可以从Future那儿取出结果。就至关于下了一张定货单,一段时间后能够拿着提订单来提货,这期间能够干别的任何事情。其中Future 接口就是定货单,真正处理订单的是Executor类,它根据Future接口的要求来生产产品。java
Future接口提供方法来检测任务是否被执行完,等待任务执行完得到结果,也能够设置任务执行的超时时间。这个设置超时的方法就是实现Java程序执行超时的关键。ui
Future接口是一个泛型接口,严格的格式应该是Future<V>,其中V表明了Future执行的任务返回值的类型。 Future接口的方法介绍以下:线程
boolean cancel (boolean mayInterruptIfRunning) 取消任务的执行。参数指定是否当即中断任务执行,或者等等任务结束code
boolean isCancelled () 任务是否已经取消,任务正常完成前将其取消,则返回 true对象
boolean isDone () 任务是否已经完成。须要注意的是若是任务正常终止、异常或取消,都将返回true接口
V get () throws InterruptedException, ExecutionException 等待任务执行结束,而后得到V类型的结果。InterruptedException 线程被中断异常, ExecutionException任务执行异常,若是任务被取消,还会抛出CancellationException
get
V get (long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException 同上面的get功能同样,多了设置超时时间。参数timeout指定超时时间,uint指定时间的单位,在枚举类TimeUnit中有相关的定义。若是计 算超时,将抛出TimeoutException产品
Future的实现类有java.util.concurrent.FutureTask<V>即 javax.swing.SwingWorker<T,V>。一般使用FutureTask来处理咱们的任务。FutureTask类同时又 实现了Runnable接口,因此能够直接提交给Executor执行。使用FutureTask实现超时执行的代码以下:it
ExecutorService executor = Executors.newSingleThreadExecutor(); FutureTask<String> future = new FutureTask<String>(new Callable<String>() {//使用Callable接口做为构造参数 public String call() { //真正的任务在这里执行,这里的返回值类型为String,能够为任意类型 }}); executor.execute(future); //在这里能够作别的任何事情 try { result = future.get(5000, TimeUnit.MILLISECONDS); //取得结果,同时设置超时执行时间为5秒。一样能够用future.get(),不设置执行超时时间取得结果 } catch (InterruptedException e) { futureTask.cancel(true); } catch (ExecutionException e) { futureTask.cancel(true); } catch (TimeoutException e) { futureTask.cancel(true); } finally { executor.shutdown(); }
不直接构造Future对象,也可使用ExecutorService.submit方法来得到Future对象,submit方法即支持以 Callable接口类型,也支持Runnable接口做为参数,具备很大的灵活性。使用示例以下:io
ExecutorService executor = Executors.newSingleThreadExecutor(); FutureTask<String> future = executor.submit( new Callable<String>() {//使用Callable接口做为构造参数 public String call() { //真正的任务在这里执行,这里的返回值类型为String,能够为任意类型 }}); //在这里能够作别的任何事情 //同上面取得结果的代码