Java中的Future & Callable

最简单的基本流程是:

  1. Callable任务通过ExecutorService来提交;
  2. 任务结束后返回的结果交给Future;
  3. Future通过get()方法去获得实际的运算结果。

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

class Merge implements Callable<String>{
    
    private String strA;
    private String strB;
    
    Merge(String strA, String strB){
        this.strA = strA;
        this.strB = strB;
    }

    @Override
    public String call() throws Exception {
        return strA+strB;
    }
    
}

public class CallableTest {

    public static void main(String[] args) throws InterruptedException, ExecutionException {
        ExecutorService es = Executors.newFixedThreadPool(1);
        Merge task = new Merge("Hello " ,"World!");
        Future<String> future = es.submit(task);
        String result = future.get();
        System.out.println(result);

        es.shutdown();
    }
}

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

相关阅读更多精彩内容

友情链接更多精彩内容