Future :多线程设计模式

当一个线程串行执行多个任务处理会花费大量时间时，可以考虑把串行任务分解成并行任务去处理，节约时间。例如：原来一个线程串行处理两个任务，每个任务3秒，总共用时6秒；现在就可以新启一个线程去执行其中一个任务，这样并行处理两个任务，总用时在3秒多一点。

Client：程序的发起端 main方法
FutureClient：程序处理端
FutureData ：新线程任务的执行与返回数据

package com.test.future;

public class Client {
    
    public static void main(String[] args) throws Exception {
        for(int i=0; i<10; i++){
            Client client = new Client();
            client.test(i);
        }
    }
    
    public void test(int i) throws InterruptedException{
        
        System.out.println("主线程开始运行" + i);  
        FutureClient futureClient = new FutureClient();
        FutureData futureData = futureClient.getfutureData(String.valueOf(i));
        
        System.out.println("主线程继续处理自己的业务");
        String realData = futureData.getRealData();     
        System.out.println(i + realData);
    }
    
}

package com.test.future;

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

public class FutureClient {
    
    // 创建线程池 ，新线程都从executor线程池中获取
    private static ExecutorService executor = Executors.newCachedThreadPool();
    
    public FutureData getfutureData(final String str) {
        // 先返回给发送请求的客户端一个空futureData，也告诉客户端请求收到，可以做其他事情了
        final FutureData futureData = new FutureData();
        // 从线程池中获取一个线程
        executor.execute(new Runnable() {
            @Override
            public void run() {
                futureData.handler(str);
            }
        });
        // 先给主线程返回一个对象，让主线程继续往下运行
        return futureData;
    }   

}

package com.test.future;

public class FutureData{
    
    private boolean isReady = false;
    private String realData;

    public synchronized String getRealData() throws InterruptedException{
        // 如果新线程的业务还没有处理完，则一直处于阻塞状态
        while(!isReady){
            System.err.println("新线程还没处理完，请等待一会");
            wait();
        }
        return realData;
    }

    /**
     * 新线程中处理业务的部分
     * @param str
     */
    public synchronized void handler(String str) {
        
        System.err.println("新线程接收到请求信息：" + str);
        System.err.println("新线程处理自己的业务------------------");
        
        this.realData = "新线程处理完业务返回数据" + str;
        isReady = true;
        // 新线程的业务处理完毕，发送通知
        notify();
    }
    
    
}

最后编辑于：2018.03.11 16:46:33