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