package jdk_concurrent;

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

import jdk_future.RealData;

public class FutureMain {

	public static void main(String[] args) throws InterruptedException, ExecutionException {
		// 构造FutureTask
		FutureTask<String> futureTask = new FutureTask<>(new RealData("a"));
		ExecutorService service = Executors.newFixedThreadPool(1);
		// 执行FutureTask相当于上例的Client.request("name")发送请求
		// 在这里开启线程进行RealData的Call()执行
		service.execute(futureTask);
		System.out.println("请求完毕");
		try {

			Thread.sleep(2000);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
		// 相当于Data.getResult()
		System.out.println("数据=" + futureTask.get());
	}

}