多线程下Spring单例Bean成员变量共享问题求助

你的问题核心在于 UsersBucketForExpiryUtilityService 是Spring的@Component，默认是单例模式——也就是说整个应用里只有这一个实例。所有BucketProcessThread线程拿到的都是同一个Service对象，而listOfAccounts是这个单例的成员变量，自然会被多线程共享、互相覆盖。哪怕每个线程调用processUuidsCommon()时重新初始化，本质上还是在修改同一个对象的属性，所以会出现不同线程读到相同元素的情况。

下面给你几个针对性的解决方案，按推荐优先级排序：

方案1：把listOfAccounts改为方法局部变量（最推荐） #

这是最简单直接的方式，因为方法内的局部变量是线程私有的——每个线程调用processUuidsCommon()时，都会创建自己的ArrayList实例，完全不存在共享问题。

修改代码如下：

@Component
public class UsersBucketForExpiryUtilityService {
    // 删掉原来的成员变量listOfAccounts
    
    ...
    
    public void processUuidsCommon() {
        // 把变量移到方法内部，每个线程调用时都会生成独立的实例
        List<BulkAccountUpdateDetails> listOfAccounts = new ArrayList<BulkAccountUpdateDetails>();
        
        // 后续所有对list的操作都用这个局部变量
        ...
    }
}

这种方式让Service变成无状态Bean，完全符合Spring的最佳实践，线程安全问题彻底解决。

方案2：将listOfAccounts改为ThreadLocal存储（适合跨方法共享场景） #

如果listOfAccounts需要在Service的多个方法之间共享（比如processUuidsCommon()还要调用其他方法，且这些方法也需要用到这个列表），可以用ThreadLocal为每个线程存储独立的实例：

@Component
public class UsersBucketForExpiryUtilityService {
    // 用ThreadLocal初始化每个线程独有的list
    private final ThreadLocal<List<BulkAccountUpdateDetails>> listThreadLocal = ThreadLocal.withInitial(() -> new ArrayList<BulkAccountUpdateDetails>());
    
    ...
    
    public void processUuidsCommon() {
        // 获取当前线程对应的list
        List<BulkAccountUpdateDetails> listOfAccounts = listThreadLocal.get();
        // 清空列表（避免线程复用场景下的旧数据残留，比如用线程池时）
        listOfAccounts.clear();
        
        // 后续操作这个list
        ...
        
        // 可选：如果线程不再使用该变量，调用remove()避免内存泄漏（线程池场景建议加）
        // listThreadLocal.remove();
    }
}

注意：如果你的线程是从线程池获取的（而非每次new新线程），一定要记得在使用后清空或移除ThreadLocal中的数据，否则线程复用会导致旧数据被带到下一次任务中。

方案3：将Service改为原型模式（适合多状态变量独立场景） #

如果Service本身有多个成员变量都需要线程独立，而不仅仅是listOfAccounts，可以把Service改成原型Bean——这样每次获取Service实例时，Spring都会创建一个新的对象，每个线程拿到的都是独立的Service，成员变量自然不会共享。

修改Service的注解：

@Component
@Scope("prototype") // 等价于@Scope(value = ConfigurableBeanFactory.SCOPE_PROTOTYPE)
public class UsersBucketForExpiryUtilityService {
    List<BulkAccountUpdateDetails> listOfAccounts = new ArrayList<BulkAccountUpdateDetails>();
    
    ...
    
    public void processUuidsCommon() {
        listOfAccounts = new ArrayList<BulkAccountUpdateDetails>();
        ...
    }
}

然后创建线程时，要确保每次都获取新的Service实例（如果是手动创建线程，需要从Spring容器中获取原型Bean，而不是直接注入单例）：

// 比如通过ApplicationContext获取原型实例
UsersBucketForExpiryUtilityService service = applicationContext.getBean(UsersBucketForExpiryUtilityService.class);
BucketProcessThread thread = new BucketProcessThread(service);

注意：原型Bean的生命周期不会被Spring管理，需要你自己负责对象的销毁，避免内存泄漏。

方案4：线程持有list并传递给Service方法（无状态Service的另一种实现） #

把listOfAccounts的创建权交给线程，然后作为参数传递给processUuidsCommon()，这样Service完全无状态，线程安全：

@Component
public class UsersBucketForExpiryUtilityService {
    // 移除原来的成员变量listOfAccounts
    
    ...
    
    // 修改方法，接收外部传入的list
    public void processUuidsCommon(List<BulkAccountUpdateDetails> listOfAccounts) {
        // 直接操作传入的list
        ...
    }
}

class BucketProcessThread extends Thread {
    private final UsersBucketForExpiryUtilityService usersBucketForExpiryUtilityService;
    
    public BucketProcessThread(UsersBucketForExpiryUtilityService usersBucketForExpiryUtilityService) {
        this.usersBucketForExpiryUtilityService = usersBucketForExpiryUtilityService;
    }
    
    public void run() {
        ...
        // 每个线程创建自己的list实例
        List<BulkAccountUpdateDetails> listOfAccounts = new ArrayList<BulkAccountUpdateDetails>();
        // 把list传递给Service方法
        usersBucketForExpiryUtilityService.processUuidsCommon(listOfAccounts);
        ...
    }
}

这种方式和方案1类似，都是让Service保持无状态，区别在于list的创建位置不同，适合需要在线程内先处理list再传给Service的场景。

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