Java 使用 Callable 和 Future 的ExecutorService示例
时间:2020-02-23 14:35:00 来源:igfitidea点击:
可调用(Callable)接口表示可以返回值的线程。
除了它可以返回一个值之外,它非常类似于可运行的接口。
可调用的接口可用于计算可以返回给调用线程的状态或者结果。
例如:假设我们想要执行某些数字的因子和平方,我们可以使用可调用接口同时进行,这也将返回值。
可调用的只定义了一种如下方法
public interface Callable { V call() throws Exception; }
我们可以定义要在调用方法中执行的任务。
如果它成功执行,则调用方法将返回它必须抛出异常的结果。
我们可以使用ExecutorService的提交来执行可调用的任务。
让我们在ExecutorService中查看提交方法的签名。
Future submit(Callable task);
如果我们注意到,返回类型的提交方式是未来。
将来是通用接口,代表可通过可调用接口返回的值。
随着Callable将在未来的时间内返回值,姓名似乎是合适的。
有两种方法可以从将来获得实际价值。
get():调用此方法时,线程将无限期等待结果。
v get(长超时,时间单位):调用此方法时,线程将仅在指定时间等待结果。
例子:
该计划将展示使用可调用和未来。
我们将创建一个可调用的正方形和一个可递议的阶乘来计算。
我们将向执行的四个任务向Executorservice提交四个方形和25分的阶段。
该计划将展示如何利用可调用和未来同时执行它。
创建名为PowerCalc的类,它实现可调用接口。
package org.igi.theitroad; import java.util.concurrent.Callable; public class PowerCalc implements Callable{ private double number; PowerCalc(double number) public Double call() throws Exception { { this.number=number; } @Override System.out.println("Calculating Square with "+Thread.currentThread().getName()); Thread.sleep(2000); return Math.pow(number, number); } }
创建另一个名为factoriairation的类,它可以实现可调用的接口。
package org.igi.theitroad; import java.util.concurrent.Callable; public class FactorialCalc implements Callable { private double number; FactorialCalc(double number) { public Double call() throws Exception { this.number = number; } @Override System.out.println("Calculating factorial with "+Thread.currentThread().getName()); Thread.sleep(5000); double fact = 1; for (int i = 2; i <= number; i++) { fact *= i; } return fact; } }
现在创建一个名为futurecallablemain.java的主要类。
package org.igi.theitroad; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; import java.util.concurrent.Future; import java.util.concurrent.Executors; public class FutureCallableMain { ExecutorService es=Executors.newFixedThreadPool(4); public static void main(String[] args) { System.out.println("Start : "); Future powerFuture20; powerFuture20=es.submit(new PowerCalc(20)); Future factorialFuture20; Future powerFuture25; Future factorialFuture25; factorialFuture25=es.submit(new FactorialCalc(25)); factorialFuture20=es.submit(new FactorialCalc(20)); powerFuture25=es.submit(new PowerCalc(25)); try { System.out.println("Square of "+25+" : "+powerFuture25.get()); System.out.println("Square of "+20+" : "+powerFuture20.get()); System.out.println("Factorial of "+20+" : "+factorialFuture20.get()); es.shutdown(); System.out.println("Factorial of "+25+" : "+factorialFuture25.get()); } catch (InterruptedException | ExecutionException e) { e.printStackTrace(); } System.out.println("Done"); } }
运行上面的程序时,我们将得到以下输出:
Start : Calculating Square with pool-1-thread-1 Calculating factorial with pool-1-thread-2 Calculating Square with pool-1-thread-3 Square of 20 : 1.048576E26 Calculating factorial with pool-1-thread-4 Factorial of 20 : 2.43290200817664E18 Done Square of 25 : 8.881784197001253E34 Factorial of 25 : 1.5511210043330986E25