异步将用户信息存入 Redis 缓存

主要是为了解决Redis的缓存问题，异步将用户信息存入Redis缓存

首先我们需要引入一部线性池

核心概念

1. 异步执行：

   • 异步执行是指任务提交后不会立即等待其完成，而是立即返回并继续执行其他任务。任务将在后台执行，执行结果可以通过回调、Future、Promise 等机制获取。
   • 异步执行通常意味着任务不会阻塞当前线程，也就是当前线程可以继续做其他事情。

2. 线程池：

   • 线程池是一个维护一组线程的集合，任务提交给线程池后，线程池会从线程池中取出一个空闲线程来执行任务，而不是每次都新建一个线程。线程池能够有效地管理线程的生命周期，避免线程创建和销毁的开销。

3. 任务提交与执行：

   • 异步线程池中的任务是被异步地执行的。任务可以通过提交接口（例如 submit() 或 execute()）被提交到线程池中，线程池的线程会异步执行这些任务。提交的任务一般是 Callable 或 Runnable 类型。

4. 异步结果：

   • 异步任务执行完毕后，通常会返回一个结果。Java 中可以通过 Future 对象获取结果或状态。通过 Future.get() 方法可以获取任务执行的结果（注意 get() 是阻塞方法），如果你只关心任务是否完成，可以使用 isDone() 方法。

@Configuration
public class ThreadPoolConfig {@Bean(name = "taskExecutor")public Executor taskExecutor() {ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();executor.setCorePoolSize(10);executor.setMaxPoolSize(50);executor.setQueueCapacity(200);executor.setKeepAliveSeconds(30);executor.setThreadNamePrefix("UserExecutor-");// 拒绝策略：由调用线程处理（一般为主线程）executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());// 等待所有任务结束后再关闭线程池executor.setWaitForTasksToCompleteOnShutdown(true);// 设置等待时间executor.setAwaitTerminationSeconds(60);executor.initialize();return executor;}
}

下面展示用户信息存入 Redis 缓存的部分代码

        // 根据用户 ID 查询用户信息UserDO userDO = userDOMapper.selectById(userId);// 判空if (Objects.isNull(userDO)) {threadPoolTaskExecutor.execute(() -> {// 防止缓存穿透，将空数据存入 Redis 缓存 (过期时间不宜设置过长)long expirationTime = 60 + RandomUtil.randomInt(60);redisTemplate.opsForValue().set("这里自己定义key值", "null", expirationTime, TimeUnit.SECONDS);});throw new （根据自己设置的异常）;}