多线程-Future Task

在开发中如果碰到处理稍大数据量的场景可以考虑使用多线程来提高效率. 用法如示例:

1.引入 math3(计算 μ δ)

 
        
            org.apache.commons
            commons-math3
            3.6.1

2.示例

import com.alibaba.fastjson.JSON;
import dintalk.cn.common.demo.Student;

import java.util.*;
import java.util.concurrent.*;
import java.util.stream.Collectors;

import org.apache.commons.math3.stat.StatUtils;
import org.apache.commons.math3.stat.descriptive.moment.StandardDeviation;


/**
 * @ClassName: FutureTaskDemo
 * @Description:
 * @Author: song hui
 * @Date: 2022/1/14
 */
public class FutureTaskDemo {

    public static void main(String[] args) throws ExecutionException, InterruptedException {

        /**
         * 需求:
         *   统计 各个年级中,学生的分数处于 所在年级 所有学生分数计算的 μ +- 1.5δ 之外. 的学生
         */
        Map result = new HashMap<>();
        // 1. 获取 学生, 按照年级分组
        List studentList = getStudents();
        Map> studentMap = 			studentList.stream().collect(Collectors.groupingBy(Student::getGrade));

        // 2. 创建多线程 task, 处理数据
        Map> allTaskMap = new HashMap<>();
        ExecutorService executor = Executors.newFixedThreadPool(studentMap.size());

        // 3. 按照年级 , 提交 task
        for (Map.Entry> gradeEntry : studentMap.entrySet()) {
            Future objectFuture = submitStudentTask(executor, gradeEntry.getValue());
            allTaskMap.put(gradeEntry.getKey(), objectFuture);
        }
        executor.shutdown();

        // 4. 所有线程执行完毕后,封装数据
        for (Map.Entry> taskEntry : allTaskMap.entrySet()) {
            String grade = taskEntry.getKey();
            Future futureTask = taskEntry.getValue();
            List gradeStudents = (List) futureTask.get();
            result.put(grade, gradeStudents);
        }

        // 5. 看结果
        System.out.println(JSON.toJSONString(result));
    }

    private static Future submitStudentTask(ExecutorService executor, List studentList) {
        Callable callable = () -> {
            List result = new ArrayList<>();
            try {
                // 1. 获取 分数 数组
                double[] scoreArr = studentList.stream().mapToDouble(Student::getScore).toArray();

                // 2. 计算 μ 和 δ (使用 math3)
                double mean = StatUtils.mean(scoreArr);
                StandardDeviation standardDeviation = new StandardDeviation();
                double sigma = standardDeviation.evaluate(scoreArr);
                double left = mean - sigma * 1.5;
                double right = mean + sigma * 1.5;

                // 3. 判断异常
                result = studentList.stream().filter(e -> e.getScore() > right || e.getScore() < left)
                        .collect(Collectors.toList());

            } catch (Exception e) {
                // 异常处理 ...
            }
            return result;
        };
        return executor.submit(callable);
    }


    // 获取 学生列表
    private static List getStudents() {
        List list = new ArrayList<>();
        for (int i = 0; i < 100; i++) {
            Student student = new Student();
            student.setAge(i);
            student.setName("name" + i);
            student.setGrade(String.valueOf((i % 2) + 1));
            student.setScore(i * (i % 2) * 1.1);
            list.add(student);
        }
        return list;
    }


}

						  
					  
						
							


						

							
							
			java多线程							
						



						

						
						


						

						
					
					

					
					

						
相关

						

				
						
			

																
								

										
JavaWeb的三大作用域

									
									

								 

        

								

							
							

																
								

										
python多线程控制

									
									

								 

        

								

							
							

																
								

										
java中常用数组copy方法

									
									

								 

        

								

							
							

																
								

										
6.Java方法

									
									

								 

        

								

							
							

																
								

										
Java web开发：从零到 Run 一个现有的 Spring Boot 前后端分离项目（前端Vue）

									
									

								 

        

								

							
							

																
								

										
javascript基础知识(29) 实现继承的方式

									
									

								 

        

								

							
							

																
								

										
java  正则表达式

									
									

								 

        

								

							
							

																
								

										
JAVA List<Object[]>取值问题

									
									

								 

        

								

							
							

																
								

										
初次接触Java感受

									
									

								 

        

								

							
							

																
								

										
99乘法表   java for循环

									
									

								 

        

								

							
							

																
								

										
基于java.net.socket包的对象传递

									
									

								 

        

								

							
							

																
								

										
Idea Java项目文件夹后面提示百分数怎么去掉

									
									

								 

        

								

							
							
            
            
            
                                    
           
  			
						

					

					
				

				

														
					
					

					
									

					
									   
标签

										

										
    
										

									

										
										

									

					

					
				


			
		
		
		
			


						





	

	
一品网 冀ICP备14022925号-6