代码如下
import java.util.concurrent.callable;
import java.util.concurrent.executionexception;
import java.util.concurrent.futuretask;
/**
* @author lzq
* @data 2020/4/30 0030 - 下午 4:02
*/
public class test2 {
public static void main(string[] args) throws executionexception, interruptedexception {
mythread thread=new mythread();
futuretask task = new futuretask(thread);
new thread(task,"a").start();
new thread(task,"b").start();
system.out.println(task.get());
}
}
class mythread implements callable {
@override
public string call() {
system.out.println("实现callable");
return "得到返回值";
}
}
执行结果为：
上面是使用callable接口简单实现多线程，使用这个接口要使用futruetask类作为简单的适配类，因为thread构造方法只能接受runnable接口参数，下面源码中看出futruetask的对象为什么也能作为runnable型参数传给thread构造方法
再分析一下结果，可以看到明明启动了a，b两个线程，但是只输出了一个线程的结果，这是因为运行的结果会被缓存，使得线程的执行效率变高。还有一点就是获取线程返回值的get方法可能会产生阻塞，一般放在最后或者使用异步通信来处理。
