java——》Supplie

╰半橙微兮° 2024-02-19 19:10 18阅读 0赞

版权声明：本文为博主原创文章，无需授权即可转载，甚至无需保留以上版权声明，转载时请务必注明作者。  
[https://blog.csdn.net/weixin\_43453386/article/details/88569380][https_blog.csdn.net_weixin_43453386_article_details_88569380]

#### java——》Supplie ####

*  一、描述
 *  二、源码
 *  三、示例
 *  四、作用
 *  五、我的使用场景
 *   *  1、简单描述一下我的需求
     *  2、我的最终实现

## 一、描述 ##

Supplier< T>接口没有入参，返回一个T类型的对象，类似工厂方法

## 二、源码 ##

package java.util.function;
    
    /**
     * Represents a supplier of results.
     *
     * <p>There is no requirement that a new or distinct result be returned each
     * time the supplier is invoked.
     *
     * <p>This is a <a href="package-summary.html">functional interface</a>
     * whose functional method is {@link #get()}.
     *
     * @param <T> the type of results supplied by this supplier
     *
     * @since 1.8
     */
    @FunctionalInterface
    public interface Supplier<T> {
        
    
        /**
         * Gets a result.
         *
         * @return a result
         */
        T get();
    }

## 三、示例 ##

public class T {
        
    	public static void main(String[] args) {
        
    		//创建Supplier容器，声明为T类型，此时并不会调用对象的构造方法，即不会创建对象
    		Supplier<T> sup= T::new;
    		//调用get()方法，此时会调用对象的构造方法，即获得到真正对象
    		T t1 = sup.get();
    		//每次get都会调用构造方法，即获取的对象不同
    		T t2 = sup.get();
    		
    		System.out.println(t1);
    		System.out.println(t2);
    		
    		Supplier<Integer> supplier= () -> 100;
    		System.out.println(supplier.get());
        }
    }

Connected to the target VM, address: '127.0.0.1:49711', transport: 'socket'
    Disconnected from the target VM, address: '127.0.0.1:49711', transport: 'socket'
    0
    0
    com.ejudata.platform.test.T@50675690
    com.ejudata.platform.test.T@31b7dea0
    100
    
    Process finished with exit code 0

## 四、作用 ##

在程序里，我们传递的是Supplier对象，直到调用get方法时，运算才会执行。这就是所谓的惰性求值。  
所以，我们可以把耗资源运算放到get方法里。

## 五、我的使用场景 ##

### 1、简单描述一下我的需求 ###

excel的每一行，都需要调用5个不同的接口（有的接口快，有的接口慢），并把每一行的结果回写到excel中对应的位置

注意：

*  excel最少1w行
 *  行与行之前可以并行执行，但执行的结果要与行对应上
 *  每行调用的5个接口的耗时是不一样的，不能因为其中一个接口就阻塞其它接口的执行

### 2、我的最终实现 ###

/*代码片段一：把每一行要执行的5个方法放入list*/
    private List searchOnLineWriteRow(int i, String text, String city) {
        
            List list = new ArrayList<>();
            list.add((Supplier) () -> mapSearch(i,city, text, Constans.GaoDe));
            list.add((Supplier) () -> mapSearch(i,city, text, Constans.BaiDu));
            list.add((Supplier) () -> notMapSearch(i,city, text, Constans.LianJia));
            list.add((Supplier) () -> notMapSearch(i,city, text, Constans.AnJuKe));
            list.add((Supplier) () -> notMapSearch(i,city, text, Constans.FangTx));
            return list;
        }
    
    /*代码片段二：把所有行的所有方法放入一个list*/
    List<Supplier<Map<String, CommunityInfo>>> suppliers = new ArrayList<>();
            for (int i = 0; i < needHandleList.size(); i++) {
        
                String text = needHandleList.get(i).get("text");
                String city = needHandleList.get(i).get("city");
                if (StringUtils.isNotBlank(text) && StringUtils.isNotBlank(city)) {
        
                    suppliers.addAll(searchOnLineWriteRow(i, text, city));
                }
            }
    
    /*代码片段三：把最终要执行的方法开多线程去并行执行*/
    List<Map<String,CommunityInfo>> communityInfoListTemp = new ThreadsUtils().executeFutures(suppliers, e->{
        
                return e.get();
            },true,20);

[https_blog.csdn.net_weixin_43453386_article_details_88569380]: https://blog.csdn.net/weixin_43453386/article/details/88569380