future模式：
其实相当于是前端的ajax
比如我们使用多线程下载文件时候，每一个线程都会发送http请求资源。而我如何知道，文件下载完毕呢？
也就是说，主线程如何获得子线程的执行结果呢？
创建多线程中的实现runnable接口方式和继承thread类，然后start方法都是直接执行代码的，无法知道执行的结果（主线程无法知道进度）。
这里要说的是新方式：使用callable接口和future模式
我要评论public class callabletest {
public static void main(string[] args) throws exception {
executorservice newcachedthreadpool = executors.newcachedthreadpool();
future<string> submit = newcachedthreadpool.submit(new taskcallable());
system.out.println("主线程运行");
string result = submit.get();
system.out.println(result);
}
}
class taskcallable implements callable {
@override
public string call() throws exception {
system.out.println("开始执行任务");
thread.sleep(3000);
system.out.println("执行任务结束");
return "success";
}
}
打印：
主线程运行 开始执行任务 执行任务结束 success
future模式核心：去除了主函数的等待时间，并使得原本需要等待的时间段可以用于处理其他业务逻辑
future模式实例：对于多线程，如果线程a要等待线程b的结果，那么线程a没必要等待b，直到b有结果，可以先拿到一个未来的future，等到b有结果时再取真实的结果
自己实现future模式：
/**
* 公共data数据结果
*/
public abstract class data {
/**
* 返回线程的执行结果
* @return string
*/
public abstract string getrequest();
}
/**
* 获取真实数据
*/
public class realdata extends data {
private string result;
realdata(string data) {
system.out.println("正在使用data->" + data + " 进行网络请求");
try {
thread.sleep(3000);
} catch (exception e) {
e.printstacktrace();
}
system.out.println("操作执行完毕");
this.result = "success";
}
@override
public string getrequest() {
return result;
}
}
/**
* 当有线程要获取realdata的时候
* 程序会被阻塞
* 等到realdata被注入才会使用getrequest方法
*/
public class futuredata extends data {
private boolean flag = false;
private realdata realdata;
/**
* 读取data数据
*/
public synchronized void setrealdata(realdata realdata) {
//如果获取到数据直接返回
if (flag) {
return;
}
//如果没有获取到数据
this.realdata = realdata;
flag = true;
notify();
}
@override
public synchronized string getrequest() {
while (!flag) {
try {
wait();
} catch (exception e) {
e.printstacktrace();
}
}
return realdata.getrequest();
}
}
public class futureclient {
public data submit(string requestdata){
futuredata futuredata = new futuredata();
new thread(new runnable() {
@override
public void run() {
realdata realdata = new realdata(requestdata);
futuredata.setrealdata(realdata);
}
}).start();
return futuredata;
}
}
测试类：
public class main {
public static void main(string[] args) {
futureclient futureclient = new futureclient();
data request = futureclient.submit("666");
system.out.println("主线程数据发送成功");
system.out.println("主线程执行其他任务");
string result = request.getrequest();
system.out.println(result);
}
}
打印如下：
主线程数据发送成功 主线程执行其他任务 正在使用data->666 进行网络请求 操作执行完毕 success
如对本文有疑问， 点击进行留言回复！！
集合框架——Map、泛型以及Collection算法常用方法
Elasticsearch 升级 7.x 版本后，我感觉掉坑里了
Mybatis的插件运行原理以及如何编写一个Mybatis的插件
网友评论