zoukankan      html  css  js  c++  java
  • java 线程池简单例子

    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.*;
    
    @SpringBootApplication
    public class RiskpriceApplication {
    
        public static void main(String[] args) throws InterruptedException, ExecutionException{
            new  RiskpriceApplication().exec();
        }
    
    
        void exec() throws InterruptedException, ExecutionException {
            int xy=0;
            //进行异步任务列表
            List<FutureTask<Integer>> futureTasks = new ArrayList<FutureTask<Integer>>();
            //线程池 初始化十个线程 和JDBC连接池是一个意思 实现重用
            ExecutorService executorService = Executors.newFixedThreadPool(10);
            long start = System.currentTimeMillis();
            int jj=0;
            //类似与run方法的实现 Callable是一个接口,在call中手写逻辑代码
            Callable<Integer> callable = new Callable<Integer>(){
    
                @Override
                public Integer call() throws Exception {
                    //System.out.println("任务执行 is "+jj1+"个");
                    Integer res = new Random().nextInt(100);
                    Thread.sleep(1000);
                    System.out.println("任务执行:获取到结果 :"+res);
                    return  res;
                }
            };
    
            for(int i=0;i<10;i++){
    
                //创建一个异步任务
                FutureTask<Integer> futureTask = new FutureTask<Integer>(callable);
                jj=i;
                futureTasks.add(futureTask);
                //提交异步任务到线程池,让线程池管理任务 特爽把。
                //由于是异步并行任务,所以这里并不会阻塞
                executorService.submit(futureTask);
            }
    
            int count = 0;
            for (FutureTask<Integer> 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();
    
        }
    }
  • 相关阅读:
    javaDSA实现加密和解密(签名和验证)
    javaRSA实现加密解密
    javaBase64加密解密
    javaApacheMd5AndSHA1加密
    javaDES加密算法
    javaSHA1实现加密解密
    Time dependent Entire Hierarchy
    BI的需求调研的方法分类
    BW Query Design中实现Key figure排序
    后勤模块PROCESS KEY 的激活及查看
  • 原文地址:https://www.cnblogs.com/kexb/p/10228369.html
Copyright © 2011-2022 走看看