JUnit中多线程使用StringRedisTemplate失效原因及解决方法

一、StringRedisTemplate的线程安全性 #

StringRedisTemplate本身是线程安全的。它基于Spring的RedisConnectionFactory实现，你配置的Jedis连接池（JedisPool）同样具备线程安全性，多线程环境下可以安全共享同一个StringRedisTemplate实例，完全不需要在每个线程内重复创建。

二、失效原因 #

测试进程无异常直接退出的核心问题是JUnit测试方法未等待异步线程执行完成：

• 调用executorService.execute(runnable)后，测试方法会直接执行到末尾并结束，JUnit会判定测试完成，直接终止整个进程。
• 此时线程池中的异步任务可能还未启动，或者执行到一半就被强制终止，导致你看不到输出，误以为执行失败。
• 单线程调用runnable.run()是同步执行，测试方法会等待任务完成后才结束，因此能正常输出结果。

三、修复方案 #

方案1：等待线程池任务执行完毕 #

在提交任务后，调用线程池的shutdown()和awaitTermination()方法，强制测试方法等待所有异步任务完成：

@Test
void multiThreadStringRedisTemplate(@Autowired RedisConnectionFactory redisConnectionFactory){
    // 仅创建一次StringRedisTemplate，线程安全可共享
    StringRedisTemplate stringRedisTemplate = new StringRedisTemplate(redisConnectionFactory);
    Runnable runnable = () -> {
        for(int i = 0;i < 50;++i){
            String value = stringRedisTemplate.opsForValue().get("ok");
            System.out.println(i + ":" + value);
        }
    };

    ExecutorService executorService = Executors.newCachedThreadPool();
    for(int i = 0;i < 1;++i){
        executorService.execute(runnable);
    }

    // 等待任务完成
    executorService.shutdown(); // 不再接受新任务
    try {
        // 等待所有任务执行完毕，超时时间可根据实际调整
        if (!executorService.awaitTermination(10, TimeUnit.SECONDS)) {
            executorService.shutdownNow(); // 超时未完成则强制终止
        }
    } catch (InterruptedException e) {
        executorService.shutdownNow();
        Thread.currentThread().interrupt();
    }
}

方案2：使用CountDownLatch等待线程 #

如果需要更灵活的等待控制，可以用CountDownLatch实现精准等待：

@Test
void multiThreadStringRedisTemplate(@Autowired RedisConnectionFactory redisConnectionFactory) throws InterruptedException {
    StringRedisTemplate stringRedisTemplate = new StringRedisTemplate(redisConnectionFactory);
    int threadCount = 1;
    CountDownLatch latch = new CountDownLatch(threadCount);

    Runnable runnable = () -> {
        try {
            for(int i = 0;i < 50;++i){
                String value = stringRedisTemplate.opsForValue().get("ok");
                System.out.println(i + ":" + value);
            }
        } finally {
            latch.countDown(); // 线程执行完毕后计数减1
        }
    };

    ExecutorService executorService = Executors.newCachedThreadPool();
    for(int i = 0;i < threadCount;++i){
        executorService.execute(runnable);
    }

    latch.await(10, TimeUnit.SECONDS); // 等待所有线程完成
    executorService.shutdown();
}

额外优化：复用StringRedisTemplate实例 #

不要在每个Runnable中新建StringRedisTemplate，它的线程安全特性允许单实例满足多线程需求，重复创建会造成不必要的资源浪费。

内容的提问来源于stack exchange，提问作者Kicey