博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Callable与Runable接口 submit与execute区别
阅读量:5053 次
发布时间:2019-06-12

本文共 2328 字,大约阅读时间需要 7 分钟。

execute(Runnable x) 没有返回值。可以执行任务,但无法判断任务是否成功完成。

submit(Runnable x) 返回一个future。可以用这个future来判断任务是否成功完成。

 

 

在Java5之后,任务分两类:一类是实现了Runnable接口的类,一类是实现了Callable接口的类。

两者都可以被ExecutorService执行

Future future = pool.submit(new RunnableTest("Task2"));

        
        try {
            if(future.get()==null){//如果Future's
 get返回null,任务完成
                System.out.println("任务完成");
            }
        } catch (InterruptedException e) {
        } catch (ExecutionException e) {
            //否则我们可以看看任务失败的原因是什么
            System.out.println(e.getCause().getMessage());
        }
Runnable任务没有返回值(见上面代码),Callable中的call()方法类似Runnable的run()方法,就是前者有返回值,后者没有。

 

同样,将Runnable的对象传递给ExecutorService的submit方法,则该run方法自动在一个线程上执行,并且会返回执行结果Future对象,但是在该Future对象上调用get方法,将返回null。

 

当将一个Callable的对象传递给ExecutorService的submit方法,则该call方法自动在一个线程上执行,并且会返回执行结果Future对象。

 

import java.util.concurrent.Callable;

import java.util.concurrent.CompletionService;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorCompletionService;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;

public class CallableAndFuture {
    
    public static void main(String[] args) {
        
        //1s内得不到结果就抛异常
        ExecutorService threadPool=Executors.newSingleThreadExecutor();
        
        Future<String> future=threadPool.submit(new Callable<String>() {

            @Override

            public String call() throws Exception {
                Thread.sleep(2000);//休息2s
                return "hello";
            }
        });
        
        try {
            System.out.println(future.get(1000, TimeUnit.MILLISECONDS));
        } catch (InterruptedException e) {
    
            e.printStackTrace();
        } catch (Exception e) {
        
            e.printStackTrace();
        }
        
        //提交一组任务,take方法返回已完成的任务的一个任务对应的Future对象
        
        ExecutorService threadPool2=Executors.newFixedThreadPool(10);
        CompletionService<Integer> completionService=new ExecutorCompletionService<>(threadPool2);
        for (int i=1;i<=10;i++){
            final  int seq=i;
        completionService.submit(new Callable<Integer>() {

            @Override

            public Integer call() throws Exception {
                Thread.sleep(new Random().nextInt(3000));
                return seq;
            }
            
        });
        }
        
         for (int i=1;i<=10;i++){
        try {
            System.out.println(completionService.take().get());
        } catch (InterruptedException | ExecutionException e) {
            e.printStackTrace();
        }
        }
    }

}

参考文章:

submit与execute区别

http://blog.csdn.net/ryantotti/article/details/6956175

Callable与Runable接口

http://blog.csdn.net/yuzhiboyi/article/details/7775266

转载于:https://www.cnblogs.com/yuyu666/p/10075563.html

你可能感兴趣的文章
windows上面链接使用linux上面的docker daemon
查看>>
每天一个小程序—0005题(批量处理图片大小)
查看>>
js-创建对象的几种方式
查看>>
JDK JRE Java虚拟机的关系
查看>>
2018.11.20
查看>>
word20161215
查看>>
dijkstra (模板)
查看>>
编译Linux驱动程序 遇到的问题
查看>>
大型分布式网站架构技术总结
查看>>
[算法之美] KMP算法的直观理解
查看>>
EntityFramework 性能优化
查看>>
【ASP.NET开发】菜鸟时期的ADO.NET使用笔记
查看>>
android圆角View实现及不同版本号这间的兼容
查看>>
OA项目设计的能力③
查看>>
Cocos2d-x3.0 文件处理
查看>>
全面整理的C++面试题
查看>>
Activity和Fragment生命周期对比
查看>>
查找 EXC_BAD_ACCESS 问题根源的方法
查看>>
日常报错
查看>>
list-style-type -- 定义列表样式
查看>>