博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
FutureTask两个构造方法介绍
阅读量:5756 次
发布时间:2019-06-18

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

hot3.png

1. Callable

源码:

public FutureTask(Callable<V> callable) {

        if (callable == null)
            throw new NullPointerException();
        this.callable = callable;
        this.state = NEW;       // ensure visibility of callable

}

Callable接口:与Runnable接口区别在于,call()方法可以返回执行结果,而Runnable接口的run方式不行的。

实现Callable接口的类无法提供给Thread使用,所以想通过Thread的方式直接来获得线程执行返回的值是不行的,可以通过FutureTask做一层封装。

FutureTask构造函数传入Callable实现类,使用FutureTask.get()得到线程真正执行结果返回值

2.Runnable

源码:

public FutureTask(Runnable runnable, V result) {

        this.callable = Executors.callable(runnable, result);
        this.state = NEW;       // ensure visibility of callable
}

FutureTask构造函数传入Runnable实现类,使用FutureTask.get()得到传入参数result的值,该值可以用来判断线程是否正常执行等,无法通过它来得到线程执行想要返回的结果。

既然传入的Runnable,为什么还能得到result值喃,因为在Executors.callable(runnable, result)里面使用RunnableAdapter将Runnable封装成了Callable,result值传给了RunnableAdapter.result,然后线程执行call()方法后,原封不动的返回RunnableAdapter.result。

 

写的一段测试代码:

package com.jv.parallel.futuretask;

import java.util.concurrent.Callable;

import java.util.concurrent.ExecutionException;
import java.util.concurrent.Executor;
import java.util.concurrent.Executors;
import java.util.concurrent.FutureTask;

import org.junit.Test;

public class TestFutureTask {

    
    public void test1() throws InterruptedException, ExecutionException{
        FutureTask  f = new FutureTask<String>(new SimpleCallable());
        f.run();
        String s = f.get().toString();
        System.out.println(s);
    }
    
    public void test2() throws InterruptedException, ExecutionException{
        String flag="123";
        FutureTask  f = new FutureTask<String>(new SimpleRunnable(),flag);
        f.run();
        String s = f.get().toString();
        System.out.println("s:"+s);
    }
}

class SimpleCallable implements Callable{

    

    public String call() throws Exception {
        // TODO Auto-generated method stub
        return "abc123";
    }
    
}
class SimpleRunnable implements Runnable{

    

    public void run() {
        int i = 1/2;
        //int i = 1/0;
    }
}

转载于:https://my.oschina.net/u/3049601/blog/888657

你可能感兴趣的文章
Proxy服务器配置_Squid
查看>>
开启“无线网络”,提示:请启动windows零配置wzc服务
查看>>
【SDN】Openflow协议中对LLDP算法的理解--如何判断非OF区域的存在
查看>>
纯DIV+CSS简单实现Tab选项卡左右切换效果
查看>>
栈(一)
查看>>
ios 自定义delegate(一)
查看>>
创建美国地区的appleId
查看>>
例题10-2 UVa12169 Disgruntled Judge(拓展欧几里德)
查看>>
JS 原生ajax写法
查看>>
Composer管理PHP依赖关系
查看>>
React.js学习笔记之JSX解读
查看>>
我所了解的Libevent和SEDA架构
查看>>
Socket编程问题小记
查看>>
基于Flask-Angular的项目组网架构与部署
查看>>
一张图道尽程序员的出路
查看>>
redis 常用命令
查看>>
LVS+Keepalived高可用负载均衡集群架构
查看>>
烂泥:kvm安装windows系统蓝屏
查看>>
iPhone开发面试题--葵花宝典
查看>>
EdbMails Convert EDB to PST
查看>>