码迷,mamicode.com
首页 > 其他好文 > 详细

Future模式

时间:2017-05-12 11:41:44      阅读:193      评论:0      收藏:0      [点我收藏+]

标签:阻塞   pac   nts   future   color   返回   blog   cut   new   

Future模式核心思想是异步调用。我们可以先拿到调用的凭证,让方法先返回,让他在后台慢慢的处理这个请求。通过这个可以实现异步操作。

 

JDK经准备好了一套完美的实现方式。我们用于执行的异步线程需要继承Callable接口,相当于Runnable,Callable接口中有一个方法call(),相当于run(),在里面写自己的业务。把这个线程放在futureTask中,这个相当于凭证。把futureTask交给线程池来进行异步处理,我们可以通过futureTask中的get()方法返回结果,结果没有返回会阻塞。

具体实现:

package jdkFuture;

import java.util.concurrent.Callable;

public class ReaLData implements Callable<String>{
    private String para;
    public ReaLData(String para){
        this.para = para;
    }
    @Override
    public String call() throws Exception {
        StringBuffer sb = new StringBuffer();
        for(int i = 0;i < 10;i ++){
            sb.append(para);
            try{
                Thread.sleep(100);
            }catch(InterruptedException e){
                e.printStackTrace();
            }
        }
        return sb.toString();
    }
    
}
package jdkFuture;

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

public class FutureMain {
    public static void main(String[] args) {
        FutureTask<String> future = new FutureTask<String>(new ReaLData("a"));
        ExecutorService executor = Executors.newFixedThreadPool(1);
        executor.submit(future);
        System.out.println("请求完毕");
        while(true){
            try {
                System.out.println("数据= " + future.get());
            } catch (InterruptedException e) {
                e.printStackTrace();
            } catch (ExecutionException e) {
                e.printStackTrace();
            }
        }
    }
}

 

Future模式

标签:阻塞   pac   nts   future   color   返回   blog   cut   new   

原文地址:http://www.cnblogs.com/caobojia/p/6844540.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!