服务器之家

服务器之家 > 正文

浅谈在Java中使用Callable、Future进行并行编程

时间:2021-02-28 10:38     来源/作者:老鹰

使用CallableFuture进行并行编程

Java中进行并行编程最常用的方式是继承Thread类或者实现Runnable接口。这两种方式的缺点是在任务完成后无法直接获取执行结果,必须通过共享变量或线程间通信,使用起来很不方便。

从Java1.5开始提供了Callable和Future两个接口,通过使用它们可以在任务执行完毕后得到执行结果。

下面我们来学习下如何使用Callable、Future和FutureTask。

Callable接口

Callable接口位于java.util.concurrent包,这是一个泛型接口,里面只声明了一个call()方法:

?
1
2
3
public interface Callable<T> {
  T call() throws Exception;
}

一般配合ExecutorService接口来使用它,在ExecutorService接口中声明了几个重载的submit方法:

?
1
2
3
<T> Future<T> submit(Callable<T> task);
<T> Future<T> submit(Runnable task, T result);
Future<?> submit(Runnable task);

第一个submit方法里面的参数类型就是Callable,另外两个本文暂时不涉及。

Future和FutureTask

Future接口的实现类可以对Runnable或者Callable的任务执行取消、查询、获取结果的操作。

Future接口也位于java.util.concurrent包下:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
public interface Future<T> {
  /**
  *取消任务
  *@param mayInterruptIfRunning
  *是否允许取消正在执行却没有执行完毕的任务,如果设置true,则表示可以取消正在执行过程中的任务
  *如果任务正在执行,则返回true
  *如果任务还没有执行,则无论mayInterruptIfRunning为true还是false,返回true
  *如果任务已经完成,则无论mayInterruptIfRunning为true还是false,返回false
  */
  boolean cancel(boolean mayInterruptIfRunning);
  /**
  *任务是否被取消成功,如果在任务正常完成前被取消成功,则返回 true
  */
  boolean isCancelled();
  /**
  *任务是否完成
  */
  boolean isDone();
  /**
  *通过阻塞获取执行结果
  */
  T get() throws InterruptedException, ExecutionException;
  /**
  *通过阻塞获取执行结果。如果在指定的时间内没有返回,则返回null
  */
  T get(long timeout, TimeUnit unit)
    throws InterruptedException, ExecutionException, TimeoutException;
}

总结下来Future提供了三种功能:

?
1
2
3
判断任务是否完成
能够中断任务
能够获取任务执行的结果

JDK中为我们提供了一个Future接口的实现类FutureTask,它有如下两个构造函数。

?
1
2
3
4
public FutureTask(Callable<T> callable) {
}
public FutureTask(Runnable runnable, T result) {
}

示例代码

使用Callable、Future

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
import java.util.concurrent.*;
public class Test {
  public static void main(String[] args) {
    ExecutorService executorService = Executors.newCachedThreadPool();
    Task task = new Task();
    Future<Integer> future = executorService.submit(task);
    executorService.shutdown();
    
    System.out.println("主线程在执行任务...");
    try {
      Thread.sleep(2000);
    } catch(InterruptedException ex) {
      ex.printStackTrace();
    }
     
    try {
      System.out.println("task运行结果:"+future.get());
    } catch (InterruptedException ex) {
      ex.printStackTrace();
    } catch (ExecutionException ex) {
      ex.printStackTrace();
    }
    System.out.println("所有任务执行完毕");
  }
}
class Task implements Callable<Integer>{
  @Override
  public Integer call() throws Exception {
    System.out.println("子线程在执行任务...");
    //模拟任务耗时
    Thread.sleep(5000);
    return 1000;
  }
}

执行结果:

?
1
2
3
4
子线程在执行任务...
主线程在执行任务...
task运行结果:1000
所有任务执行完毕

使用Callable、FutureTask

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
import java.util.concurrent.*;
public class Test {
  public static void main(String[] args) {
    ExecutorService executorService = Executors.newCachedThreadPool();
    Task task = new Task();
    FutureTask<Integer> futureTask = new FutureTask<Integer>(task);
    executorService.submit(futureTask);
    executorService.shutdown();
    
    System.out.println("主线程在执行任务...");
    try {
      Thread.sleep(2000);
    } catch (InterruptedException ex) {
      ex.printStackTrace();
    }
     
    try {
      System.out.println("task运行结果:"+futureTask.get());
    } catch (InterruptedException ex) {
      ex.printStackTrace();
    } catch (ExecutionException ex) {
      ex.printStackTrace();
    }
     
    System.out.println("所有任务执行完毕");
  }
}
class Task implements Callable<Integer>{
  @Override
  public Integer call() throws Exception {
    System.out.println("子线程在执行任务...");
    //模拟任务耗时
    Thread.sleep(5000);
    return 1000;
  }
}

执行结果:

?
1
2
3
4
子线程在执行任务...
主线程在执行任务...
task运行结果:1000
所有任务执行完毕

总结

以上就是本文关于浅谈在Java中使用Callable、Future进行并行编程的全部内容,希望对大家有所帮助。感兴趣的朋友可以继续参阅本站其他相关专题,如有不足之处,欢迎留言指出。感谢朋友们对本站的支持!

原文链接:https://segmentfault.com/a/1190000012291442

标签:

相关文章

热门资讯

2020微信伤感网名听哭了 让对方看到心疼的伤感网名大全
2020微信伤感网名听哭了 让对方看到心疼的伤感网名大全 2019-12-26
yue是什么意思 网络流行语yue了是什么梗
yue是什么意思 网络流行语yue了是什么梗 2020-10-11
Intellij idea2020永久破解,亲测可用!!!
Intellij idea2020永久破解,亲测可用!!! 2020-07-29
背刺什么意思 网络词语背刺是什么梗
背刺什么意思 网络词语背刺是什么梗 2020-05-22
苹果12mini价格表官网报价 iPhone12mini全版本价格汇总
苹果12mini价格表官网报价 iPhone12mini全版本价格汇总 2020-11-13
返回顶部