多线程与高并发(3)——使用Callable和Future创建线程

Callable接口像是Runnable接口的增强版,可以通过call()方法作为线程的执行体,但是call()方法比run()方法功能更加强大:有返回值,可以声明异常。java5提供了Future接口来获得线程执行体Call()方法的返回值,并可以控制它关联的Callable对象。

public class ThirdThread {
    public static void main(String[] args) {
        FutureTask<Integer> task = new FutureTask<Integer>(
                (Callable<Integer>) () -> {
                    int i = 0;
                    for (; i < 100; i++) {
                        System.out.println(Thread.currentThread().getName()
                                + " : " + i);
                    }
                    return i;

                });
        for (int i = 0; i < 100; i++) {
            System.out.println(Thread.currentThread().getName() + " : " + i);
            if (i == 20) {
                new Thread(task, "Thread with return").start();
            }
        }
        try {
            System.out.println("The returned value of sub thread is:"
                    + task.get());
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

值得注意的是:上面FutureTask对象的get()方法将导致主线程被阻塞,必须要call()方法结束并返回为止。另一个重载方法get(long timeout, TimeUnit unit)则是等待指定时间没有返回值则抛出TimeoutException。

java全栈日日学 文章被收录于专栏

java全栈每日必学,不要高估自己一年能做的事,不要低估自己十年能做的事

全部评论

相关推荐

每晚夜里独自颤抖:你cet6就cet6,cet4就cet4,你写个cet证书等是什么意思。专业技能快赶上项目行数,你做的这2个项目哪里能提现你有这么多技能呢
点赞 评论 收藏
分享
喝干太平洋:我是大专 我感觉我当时的简历比你好点 就一个vue吗
点赞 评论 收藏
分享
评论
点赞
收藏
分享

创作者周榜

更多
牛客网
牛客网在线编程
牛客网题解
牛客企业服务