java 给任务传递参数-白红宇

java 给任务传递参数

阅读量：6265 次

发布时间：2019-06-22

本文共 2101 字，大约阅读时间需要 7 分钟。

之前https://www.cnblogs.com/kexb/p/10228369.html没有参数，这里介绍参数什么传入package com.hra.riskprice;import com.hra.riskprice.SysEnum.Factor_Type;import com.hra.riskprice.pojo.RskFactor;import com.hra.riskprice.service.impl.RskFactorBulkMapper;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import java.util.*;import java.util.concurrent.*;@SpringBootApplicationpublic class RiskpriceApplication {    public static void main(String[] args) throws InterruptedException, ExecutionException{        new  RiskpriceApplication().exec();    }    void exec() throws InterruptedException, ExecutionException {        //进行异步任务列表        List
     
      
       > futureTasks = new ArrayList
       
        
         >();        //线程池 初始化十个线程 和JDBC连接池是一个意思 实现重用        ExecutorService executorService = Executors.newFixedThreadPool(10);        long start = System.currentTimeMillis();        int jj=0;        //类似与run方法的实现 Callable是一个接口，在call中手写逻辑代码        for(int i=0;i<10;i++){            cccc c1=new cccc();            c1.setIndex(i);            FutureTask
         
           futureTask = new FutureTask
          
           (c1); futureTasks.add(futureTask); //提交异步任务到线程池，让线程池管理任务 特爽把。 //由于是异步并行任务，所以这里并不会阻塞 executorService.submit(futureTask); } int count = 0; for (FutureTask
           
             futureTask : futureTasks) { //futureTask.get() 得到我们想要的结果 //该方法有一个重载get(long timeout, TimeUnit unit) 第一个参数为最大等待时间，第二个为时间的单位 count+= futureTask.get(); } long end = System.currentTimeMillis(); System.out.println("线程池的任务全部完成:结果为:"+count+"，main线程关闭，进行线程的清理"); System.out.println("使用时间："+(end-start)+"ms"); //清理线程池 executorService.shutdown(); } private int arg; class cccc implements Callable
            
             { private int index; public int getIndex(){ return index; } public void setIndex(int i){ this.index=i; } @Override public Integer call() throws Exception { System.out.println("任务执行 is "+index+"个"); Integer res = new Random().nextInt(100); Thread.sleep(1000); System.out.println("任务执行:获取到结果 :"+res); return res; } }}