JAVA并发处理经验(四)并行模式与算法2:Future模式

简介: 一、前言首先我举个例子说明一下:你(client)要去海南的亲戚家里玩耍,你叫爸爸给你海南的二叔打电话告诉他你周六晚上8点得飞机到海南(call1只是通知),你真倒海南你二叔接到你了旅...

一、前言

首先我举个例子说明一下:

你(client)要去海南的亲戚家里玩耍,你叫爸爸给你海南的二叔打电话告诉他你周六晚上8点得飞机到海南(call1只是通知),你真倒海南你二叔接到你了旅行得以完成(call2是真实结果)

本来准备画图的,但是还是来自互联网的图片,足以说明一下;


说明一下这个模式的几个要素:

参与 作用
Main 系统启动,调用clent 
Client 调用Data对象,立即返回Future,开启线程装配RealData
FutureData Future数据,构造很快,但是需要装备真实realTure
RealData 真实数据,但是构造比较慢
   

二、Future模式

2.1 首先需要一个Data 让Future与real都快要继承

package pattern.fature;

/**
 * Created by ycy on 16/1/16.
 */
public interface Data {
public String getResult();
}

2.2 我们需要一个future,并开始装配realData

package pattern.fature;

import javafx.scene.chart.XYChart;

/**
 * Created by ycy on 16/1/16.
 */
public class FutureDate implements Data {

    protected RealData realData=null;//Future是realData的包装
    protected boolean isReady=false;

    public synchronized void setRealData(RealData realData){
        if (isReady){
            return;
        }
        this.realData = realData;
        isReady=true;
        notifyAll();//realDate 已经被注入,通知getResult
    }


    public String getResult() {
        while (!isReady){
            try {
                wait();//一直等待,直到realData被注入
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        return realData.result;//有realdata实现
    }
}

2.3 是我们真正需要的数据realData

package pattern.fature;

/**
 * Created by ycy on 16/1/16.
 */
public class RealData implements  Data{
    protected  final String result;
    public RealData(String para){
        //RealData 的构造可能很慢,需要用户等待很久,这里用sleep代替
        StringBuffer sb=new StringBuffer();
        for (int i = 0; i <10 ; i++) {
            sb.append(para);
        }
        try {
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        result=sb.toString();
    }

    public String getResult() {
        return result;
    }
}

2.4 我们需要一个client去获取我们的future数据与real数据

package pattern.fature;

/**
 * Created by ycy on 16/1/16.
 */
public class Client {
    public Data request(final String queryStr){
        final FutureDate futureDate=new FutureDate();
        new Thread(){
            @Override
            public void run() {
                RealData realData=new RealData(queryStr);
                futureDate.setRealData(realData);
            }
        }.start();
    return futureDate;
    }

}

2.5是真正的调用的着main

我们先回去的data:是future,最后得到的数据才是Result

package pattern.fature;

/**
 * Created by ycy on 16/1/16.
 */
public class Main {
    public static void main(String[] args) {
        Client client=new Client();
        //这里会立即返回,因为得到的FutureData 而不是realData
        Data data=client.request("name");
        System.out.println("请求完毕");
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("数据="+data.getResult());
    }
}

三、JDK中Future模式运用

3.1 构造我们真的数据realData

package pattern.fature.jdkFutrue;

import java.util.concurrent.Callable;

/**
 * Created by ycy on 16/1/16.
 */
public class RealData  implements Callable<String>{
    private String para;
    public RealData(String para){
        this.para=para;
    }

    public String call() throws Exception {
        StringBuilder sb=new StringBuilder();
        for (int i = 0; i <10 ; i++) {
            sb.append(para);
            Thread.sleep(1000);

        }
        return sb.toString();
    }
}

3.2 构造我们的调用main

package pattern.fature.jdkFutrue;

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

/**
 * Created by ycy on 16/1/16.
 */
public class FutureMian {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        //构造FutureTask
        FutureTask<String> futureTask=new FutureTask<String>(new RealData("A"));
        ExecutorService es= Executors.newFixedThreadPool(1);
        //执行FutureTask,相当于上例中的client.request("a")发送请求
        //在这里开启线程Realdata 的call执行
        es.submit(futureTask);

        //额外的操作
        try {
            Thread.sleep(2000);
            System.out.println("ddd");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        //相当于data.getResult(),取得call()方法的返回值,此时call方法没有执行完成,则会等待
        if (futureTask.isDone()){
            System.out.println("数据="+futureTask.get());
        }


    }
}

四、总结

适用future模式实现一些很慢的处理程序,中间你又要做其他事情的东西,或者你根本不用管理这;

目录
相关文章
|
11天前
|
缓存 Java 调度
Java并发编程:深入解析线程池与Future任务
【7月更文挑战第9天】线程池和Future任务是Java并发编程中非常重要的概念。线程池通过重用线程减少了线程创建和销毁的开销,提高了资源利用率。而Future接口则提供了检查异步任务状态和获取任务结果的能力,使得异步编程更加灵活和强大。掌握这些概念,将有助于我们编写出更高效、更可靠的并发程序。
|
11天前
|
缓存 算法 NoSQL
Java中的分布式缓存与一致性哈希算法
Java中的分布式缓存与一致性哈希算法
|
16天前
|
并行计算 Java 大数据
Java中的高效并行计算与多线程编程技术
Java中的高效并行计算与多线程编程技术
|
24天前
|
算法 Java
基于java雪花算法工具类SnowflakeIdUtils-来自chatGPT
基于java雪花算法工具类SnowflakeIdUtils-来自chatGPT
19 3
|
26天前
|
算法 Java
java算法_输出只有235组成的数字
java算法_输出只有235组成的数字
15 5
|
8天前
|
存储 算法 Java
分布式自增ID算法---雪花算法(SnowFlake)Java实现
分布式自增ID算法---雪花算法(SnowFlake)Java实现
|
10天前
|
算法 Java 开发者
Java面试题:Java内存探秘与多线程并发实战,Java内存模型及分区:理解Java堆、栈、方法区等内存区域的作用,垃圾收集机制:掌握常见的垃圾收集算法及其优缺点
Java面试题:Java内存探秘与多线程并发实战,Java内存模型及分区:理解Java堆、栈、方法区等内存区域的作用,垃圾收集机制:掌握常见的垃圾收集算法及其优缺点
11 0
|
13天前
|
算法 搜索推荐 Java
在Java中实现高效的算法与数据结构
在Java中实现高效的算法与数据结构
|
15天前
|
Java 调度 Windows
Java面试之程序、进程、线程、管程和并发、并行的概念
Java面试之程序、进程、线程、管程和并发、并行的概念
12 0
|
15天前
|
并行计算 监控 Java
Java中的并行计算与任务分发策略
Java中的并行计算与任务分发策略