本文主要是介绍异步线程阻塞等待结果Futrue，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
package com.bjsxt.height.design014;public class Main {public static void main(String[] args) throws InterruptedException {FutureClient fc = new FutureClient();Data data = fc.request("请求参数");System.out.println(Thread.currentThread()+"请求发送成功!");System.out.println(Thread.currentThread()+"做其他的事情...");String result = data.getRequest();//此时阻塞System.out.println(Thread.currentThread()+result);}
}
package com.bjsxt.height.design014;public class FutureClient {public Data request(final String queryStr){//同步了一个结果 一步了一个结果//1 我想要一个代理对象（Data接口的实现类）先返回给发送请求的客户端，告诉他请求已经接收到，可以做其他的事情final FutureData futureData = new FutureData();//2 启动一个新的线程，去加载真实的数据，传递给这个代理对象new Thread(new Runnable() {@Overridepublic void run() {//3 这个新的线程可以去慢慢的加载真实对象，然后传递给代理对象System.out.println(Thread.currentThread()+"real 开启子线程开始耗时");RealData realData = new RealData(queryStr);futureData.setRealData(realData);//通知已经不要阻塞}}).start();System.out.println(Thread.currentThread()+"直接返回了futureData");return futureData;}}
package com.bjsxt.height.design014;public interface Data {String getRequest();}
package com.bjsxt.height.design014;public class FutureData implements Data{private RealData realData ;private boolean isReady = false;public synchronized void setRealData(RealData realData) {//如果已经装载完毕了，就直接返回if(isReady){return;}//如果没装载，进行装载真实对象this.realData = realData;isReady = true;//进行通知notify();}@Overridepublic synchronized String getRequest() {//如果没装载好 程序就一直处于阻塞状态while(!isReady){try {System.out.println(Thread.currentThread()+"开始阻塞");wait();} catch (InterruptedException e) {e.printStackTrace();}}//装载好直接获取数据即可return this.realData.getRequest();}}
package com.bjsxt.height.design014;public class RealData implements Data{private String result ;public RealData (String queryStr){System.out.println(Thread.currentThread()+"根据" + queryStr + "进行查询，这是一个很耗时的操作..");try {Thread.sleep(5000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println(Thread.currentThread()+"操作完毕，获取结果");result = "查询结果";}@Overridepublic String getRequest() {return result;}}
Thread[main,5,main]直接返回了futureData
Thread[Thread-0,5,main]real 开启子线程开始耗时
Thread[main,5,main]请求发送成功!
Thread[main,5,main]做其他的事情...
Thread[main,5,main]开始阻塞
Thread[Thread-0,5,main]根据请求参数进行查询，这是一个很耗时的操作..
Thread[Thread-0,5,main]操作完毕，获取结果
Thread[main,5,main]查询结果
这篇关于异步线程阻塞等待结果Futrue的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
