当前位置: 首页 > article >正文

Spring Bean 作用域设置为prototype在并发场景下是否是线程安全的

在并发场景下,将 Spring Bean 作用域设置为 prototype 通常能在一定程度上保证线程安全,但这并不意味着绝对的线程安全

1. prototype 作用域的特点

在 Spring 中,Bean 的作用域定义了 Bean 的生命周期和可见性。prototype 作用域表示每次从 Spring 容器中获取 Bean 时,容器都会创建一个新的 Bean 实例。这与 singleton 作用域不同,singleton 作用域的 Bean 在整个 Spring 容器中只有一个实例。

2. 为何通常能在一定程度上保证线程安全

由于每次请求都会创建一个新的 Bean 实例,不同线程获取到的是不同的 Bean 对象。因此,各个线程对 Bean 的操作不会相互影响,避免了多个线程同时访问和修改同一个 Bean 实例的状态,从而减少了线程安全问题的发生。

以下是一个简单的示例代码:

import org.springframework.context.annotation.AnnotationConfigApplicationContext;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Scope;

// 配置类
@Configuration
class AppConfig {
    @Bean
    @Scope("prototype")
    public MyBean myBean() {
        return new MyBean();
    }
}

// 自定义 Bean 类
class MyBean {
    private int count = 0;

    public void increment() {
        count++;
        System.out.println(Thread.currentThread().getName() + " - Count: " + count);
    }
}

// 主类
public class PrototypeScopeExample {
    public static void main(String[] args) {
        AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(AppConfig.class);

        // 创建两个线程
        Thread thread1 = new Thread(() -> {
            MyBean bean1 = context.getBean(MyBean.class);
            for (int i = 0; i < 3; i++) {
                bean1.increment();
            }
        });

        Thread thread2 = new Thread(() -> {
            MyBean bean2 = context.getBean(MyBean.class);
            for (int i = 0; i < 3; i++) {
                bean2.increment();
            }
        });

        // 启动线程
        thread1.start();
        thread2.start();

        try {
            // 等待线程执行完毕
            thread1.join();
            thread2.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        // 关闭 Spring 容器
        context.close();
    }
}

在上述代码中,MyBean 的作用域为 prototypethread1thread2 分别获取到不同的 MyBean 实例,它们对各自实例的 count 变量进行操作,不会相互干扰。

3. 为何不是绝对的线程安全

虽然 prototype 作用域的 Bean 本身不会被多个线程共享,但如果 Bean 内部引用了其他 singleton 作用域的 Bean,并且这些 singleton Bean 不是线程安全的,那么仍然可能会出现线程安全问题。

例如:

import org.springframework.context.annotation.AnnotationConfigApplicationContext;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Scope;

// 配置类
@Configuration
class AppConfig2 {
    @Bean
    @Scope("prototype")
    public MyPrototypeBean myPrototypeBean() {
        return new MyPrototypeBean();
    }

    @Bean
    public MySingletonBean mySingletonBean() {
        return new MySingletonBean();
    }
}

// 单例 Bean 类
class MySingletonBean {
    private int sharedCount = 0;

    public void incrementSharedCount() {
        sharedCount++;
        System.out.println(Thread.currentThread().getName() + " - Shared Count: " + sharedCount);
    }
}

// 原型 Bean 类
class MyPrototypeBean {
    private final MySingletonBean singletonBean;

    public MyPrototypeBean() {
        AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(AppConfig2.class);
        this.singletonBean = context.getBean(MySingletonBean.class);
    }

    public void doSomething() {
        singletonBean.incrementSharedCount();
    }
}

// 主类
public class PrototypeWithSingletonExample {
    public static void main(String[] args) {
        AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(AppConfig2.class);

        // 创建两个线程
        Thread thread1 = new Thread(() -> {
            MyPrototypeBean bean1 = context.getBean(MyPrototypeBean.class);
            for (int i = 0; i < 3; i++) {
                bean1.doSomething();
            }
        });

        Thread thread2 = new Thread(() -> {
            MyPrototypeBean bean2 = context.getBean(MyPrototypeBean.class);
            for (int i = 0; i < 3; i++) {
                bean2.doSomething();
            }
        });

        // 启动线程
        thread1.start();
        thread2.start();

        try {
            // 等待线程执行完毕
            thread1.join();
            thread2.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        // 关闭 Spring 容器
        context.close();
    }
}

在这个示例中,MyPrototypeBeanprototype 作用域的 Bean,但它内部引用了 MySingletonBean 这个 singleton 作用域的 Bean。多个 MyPrototypeBean 实例可能会同时访问和修改 MySingletonBeansharedCount 变量,从而导致线程安全问题。

综上所述,将 Spring Bean 作用域设置为 prototype 可以在一定程度上避免线程安全问题,但不能完全保证线程安全,需要根据 Bean 的具体实现和依赖关系进行综合考虑。


http://www.kler.cn/a/572107.html

相关文章:

  • 【第14节】C++设计模式(行为模式)-Strategy (策略)模式
  • http 状态码秒记速查(附速记口诀)
  • 【redis】redis持久化
  • 京东Hive SQL面试题实战:APP路径分析场景解析与幽默生存指南
  • 爬虫:一文掌握 Celery 分布式爬虫,及对应实战案例
  • 【应急响应工具教程】一款自动化分析网络安全应急响应工具--FindAll
  • ArcGIS操作:12 矢量shp属性筛选并导出
  • 盛元广通中小型科技创新实验室LIMS系统
  • 基于SpringBoot+Vue的医院挂号管理系统+LW示例参考
  • DeepSeek 助力 Vue3 开发:打造丝滑的表格(Table)示例2: 分页和排序
  • Python----数据分析(Matplotlib三:绘图二:箱图,散点图,饼图,热力图,3D图)
  • anolis8.9-k8s1.32-系统基本配置
  • Tomcat原理:HTTP协议与HTTPS协议
  • FastGPT 源码:RRF、Rerank 相关代码
  • Spring Boot 中短时间连续请求时出现Cookie获取异常问题
  • uniapp+vue3搭建项目
  • 【powerjob】 powerjobserver注册服务IP错误
  • .h264/.h265文件 前端直接播放
  • 2 Redis 字符串(String) 命令大全
  • 【TCP/IP协议栈】【网络层】子网划分、子网掩码