Callable接口

桑鱼

发布于 2020-04-23 15:33:59

4190

发布于 2020-04-23 15:33:59

Runnable 是执行工作的独立任务，但是它不返回任何值。如果希望任务在完成时能够返回一个值，那么可以实现Callable 接口而不是 Runnable 接口。在 Java SE5 中引入的 Callable 是一个具有类型参数的泛型，它的类型参数表示的是从方法 call() 中返回的值必须使用ExecutorService.submit() 方法调用实现Callable接口的类的对象 submit方法会产生Future对象，它用Callable返回结果的类型进行了参数化。

示例

import java.util.ArrayList;
import java.util.concurrent.*;

/**
 * Callable+Future使用示例
 * User: pengyapan
 * Date: 2020/4/16
 * Time: 上午10:51
 */
public class TestCallable {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newCachedThreadPool();
        ArrayList<Future<String>> results = new ArrayList<Future<String>>();
        for(int i = 0; i < 10; i++){
            results.add(executorService.submit(new TaskWithResult(i))); // submit方法会产生Future对象，它用Callable返回结果的类型进行了参数化。
        }
        for(Future<String> fs : results){
            try {
                System.out.println(fs.get());
            } catch (InterruptedException e) {
                System.out.println(e);
                return;
            } catch (ExecutionException e) {
                System.out.println(e);
                return;
            }finally {
                executorService.shutdown();
            }
        }
    }
}

class TaskWithResult implements Callable<String>{
    private int id;
    public TaskWithResult(int id){
        this.id = id;
    }
    public String call() throws Exception {
        return "result of TaskWithResult " + id;
    }
}

本文参与腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。

如有侵权请联系 cloudcommunity@tencent.com 删除

java