2022-01周

文章目录

1. 问题解决

1.1. 多线程中上下文对象内容丢失？如：获取不到登陆用户信息1.2. 使用list的subList方法后遍历集合出现java.util.ConcurrentModificationException: null异常1.3. 多线程中使用@Autowird注入的对象为null 2. 技术使用

2.1. 导入导出：EasyExcel2.2. CountDownLatch并行处理不受影响的多任务

2.2.1 作用2.2.2 适用场景2.2.3 函数列表2.2.4 扩展 2.3. ForkJoin对大的任务进行分解处理-二分法

2.3.1 作用2.3.2 原理2.3.3 使用步骤2.3.4 ForkJoin可以实现的三个类2.3.5 异常处理 2.4. Pair返回两个数据结果

1. 问题解决 1.1. 多线程中上下文对象内容丢失？如：获取不到登陆用户信息

问题：在主线程中启用另外线程后，导致登录i西南西丢失，即获取不到登陆用户信息

原因：Spring Security的安全上下文是存储在ThreadLocal（也就是线程本地）的，启动其他线程执行的时候，就会丢失掉上线文信息

解决办法：从网上查到的方法是在主线程中获取到安全上下文，再将其设置到其他线程中
1. 主线程中获取安全上下文： SecurityContext securityContext = SecurityContextHolder.getContext();
2. 子线程中设置安全上下文：SecurityContextHolder.setContext(securityContext);
3. 在finally中清除：SecurityContextHolder.clearContext();

1.2. 使用list的subList方法后遍历集合出现java.util.ConcurrentModificationException: null异常

解决办法：
需要将subList的集合重新赋值给一个新定义的集合

List subList = new ArrayList<>(list.subList(2, list.size()));List subList = new ArrayList<>();
subList.addAll(list.subList(2, list.size()));

1.3. 多线程中使用@Autowird注入的对象为null

解决办法：

实现ApplicationContextAware的工具类

public class SpringBeanUtil implements ApplicationContextAware {

    private static ApplicationContext applicationContext = null;

    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        SpringBeanUtil.applicationContext = applicationContext;
    }

    public static Object getBeanByName(String beanName) {
        if (applicationContext == null){
            return null;
        }
        return applicationContext.getBean(beanName);
    }

    public static T getBean(Class type) {
        return (T) applicationContext.getBean(type);
    }
}

使用SpringBeanUtil获取Spring对象

private static CacheManager cacheManager = ((CacheManager) SpringContextHolder.getBean("cacheManager"));

2. 技术使用 2.1. 导入导出：EasyExcel

参考文档：https://alibaba-easyexcel.github.io/

2.2. CountDownLatch并行处理不受影响的多任务 2.2.1 作用

允许1或者N个线程等待其他线程完成执行

2.2.2 适用场景

任务A需要等待其他几个任务执行完毕之后才能执行，但其他几个任务之间不受影响，可以并发执行。此时就可以使用CountLatchDowm来实现了

2.2.3 函数列表

public CountDownLatch(int count){} //通过构造器设置计数值

public void await() throws InterruptedException { }; //调用await()方法的线程会被挂起，它会等待直到count值为0才继续执行

public boolean await(long timeout, TimeUnit unit) throws InterruptedException { }; //和await()类似，只不过等待一定的时间后count值还没变为0的话就会继续执行

public void countDown() { }; //将count值减1

2.2.4 扩展

CyclicBarrier和Semaphore

2.3. ForkJoin对大的任务进行分解处理-二分法 2.3.1 作用

执行一种特殊的任务：把一个大任务拆成多个小任务并行执行，每个小任务执行完成之后，再将各个小任务的结果进行汇总，从而得到最终的结果。

2.3.2 原理

判断一个任务是否足够小，如果是，直接计算；否则，就拆分成几个小任务分别计算，可以看作是反复“裂变”成一系列小任务。

2.3.3 使用步骤

分割原任务执行子任务合并子任务的结果

if(任务很小）{
    直接计算得到结果
}else{
    分拆成N个子任务
    调用子任务的fork()进行计算（分为两部分任务，左、右）
    调用子任务的join()合并计算结果
}

2.3.4 ForkJoin可以实现的三个类

RecursiveAction：无返回值的任务。——CallableRecursiveTask：有返回值的任务。——RunableCountedCompleter：完成任务后将触发其他任务。 2.3.5 异常处理

在处理任务时如果抛出了异常，需要另这个任务睡眠1秒。

Thread.sleep(1)

再在主线程中捕获异常。

try {
    forkJoinPoolHttp.awaitTermination(1, TimeUnit.DAYS);
} catch (InterruptedException e) {
    e.printStackTrace();
}

if (distinctimportHttpDataTask.isCompletedAbnormally()) {
    isSuccess.set(false);
    log.error("ServerInfoService-batchimport-DistinctimportHTTPDataTask-BusinessException", distinctimportHttpDataTask.getException());
    throw new BusinessException(EmResultCode.SERVERINFO_import_ERROR.message());
}

参考:http://ifeve.com/fork-join-5/

2.4. Pair返回两个数据结果

当我们调用一个方法时，需要该方法返回一个信息对时，可以使用Pair。

javax.util包中的Pair

Pair pair = new Pair<>("value1", "value2");
pair.getKey();
pair.getValue();

Apache Commons中的Pair

Pair pair = Pair.of("value1", "value2");
pair.getLeft();
pair.getRight();