package com.ThreadPoolHadel;
import com.sqlSource.SqlHadle;
import java.util.List;
import java.util.concurrent.Callable;
/**
 * Created by df on 2018/9/20.
 */
public class ThredQuery implements Callable<List> {
    SqlHadle sqlHadle=new SqlHadle();
    private String search;//查詢條件 根據(jù)條件來(lái)定義該類的屬性
    private int bindex;//當(dāng)前頁(yè)數(shù)
    private int num;//每頁(yè)查詢多少條
    private String table;//要查詢的表名，也可以寫死，也可以從前面?zhèn)?
    private List page;//每次分頁(yè)查出來(lái)的數(shù)據(jù)
    public  ThredQuery(int bindex,int num,String table) {
        this.bindex=bindex;
        this.num=num;
        this.table=table;
        //分頁(yè)查詢數(shù)據(jù)庫(kù)數(shù)據(jù)
        page=sqlHadle.queryTest11(bindex,num,table);
    }
    @Override
    public List call() throws Exception {
        //返回?cái)?shù)據(jù)給Future
        return page;
    }
}      

package com.service;
import com.ThreadPoolHadel.ThredQuery;
import com.sqlSource.SqlHadle;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.*;
/**
 * Created by df on 2018/9/20.
 */
@Service
public class TheardQueryService {
    SqlHadle sqlHadle=new SqlHadle();
    public List<List> getMaxResult(String table) throws InterruptedException, ExecutionException {
        long start = System.currentTimeMillis();//開始時(shí)間
        List<List> result = new ArrayList<>();//返回結(jié)果
        //查詢數(shù)據(jù)庫(kù)總數(shù)量
        int count = sqlHadle.count(table);
        int num = 8000;//一次查詢多少條
        //需要查詢的次數(shù)
        int times = count / num;
        if (count % num != 0) {
            times = times + 1;
        }
        //開始頁(yè)數(shù)  連接的是orcle的數(shù)據(jù)庫(kù)  封裝的分頁(yè)方式  我的是從1開始
        int bindex = 1;
        //Callable用于產(chǎn)生結(jié)果
        List<Callable<List>> tasks = new ArrayList<>();
        for (int i = 0; i < times; i++) {
            Callable<List> qfe = new ThredQuery(bindex, num, table);
            tasks.add(qfe);
            bindex += bindex;
        }
        //定義固定長(zhǎng)度的線程池  防止線程過多
        ExecutorService executorService = Executors.newFixedThreadPool(15);
        //Future用于獲取結(jié)果
        List<Future<List>> futures=executorService.invokeAll(tasks);
        //處理線程返回結(jié)果
        if(futures!=null&&futures.size()>0){
            for (Future<List> future:futures){
             result.addAll(future.get());
            }
        }
        executorService.shutdown();//關(guān)閉線程池
        long end = System.currentTimeMillis();
        System.out.println("線程查詢數(shù)據(jù)用時(shí):"+(end-start)+"ms");
        return result;
    }
}