线程安全(2)--多线程逸出分析和正确处理

简介: 多线程溢出写法: public class ThisEscape {     public ThisEscape(EventSource source) {         source.registerListener(new EventListener() {             public void onEvent(Event e) {                

多线程溢出写法:

public class ThisEscape {

    public ThisEscape(EventSource source) {
        source.registerListener(new EventListener() {
            public void onEvent(Event e) {
                doSomething(e);
            }
        });

    }

}

点评:加粗的这一段隐式this事件线程已经暴露给ThisEscape构造函数,而构造函数在该类中首先被其他类调用,因此整个this都暴露了。只要其他线程在ThisEscape未构造之前(构造返回状态)调用这个类,那么this就会被新建线程共享并识别它(线程溢出)。

因此正确的写法:

public class ThisEscape{
    private final EventListener listener;
    private ThisEscape() {
        listener = new EventListener() {
            public void onEvent(Event e) {
                doSomething(e);
            }
        };
    }
    public static ThisEscape newInstance(EventSource source) {
        ThisEscape safe = new ThisEscape();
        source.registerListener(safe.listener);
        return safe;
    }

点评:利用工厂模式来规避EventListener线程溢出,新建的线程无法在构造函数之前共享和识别safe,从而保证线程安全。

我们在做jdbc连接一般也是采用工厂模式,但很少考虑是否存在线程溢出的现象,应尽量避免使用静态块,因此需要引起足够的重视。

案例分析:

public class ConnectionPool {
    private Vector<Connection> pool;
    private String url="jdbc:mysql://localhost:3306/xxx";
    private String username="root";
    private String password="root";
    private String driverClassName="com.mysql.jdbc.Driver";

    /**
     * 连接池的大小,连接数
     */
    private int poolSize=10;
    
    private static ConnectionPool instance =null;
    /**
     * 私有的构造方法,禁止外部创建本类的对象,要想获得本类的对,通过getIstance方法
     * 使用了设计模式中的单子模式
     */
    private ConnectionPool(){
        init();
    }
    private void init(){
        pool =new Vector<Connection>(poolSize);
        //readConfig();
        addConnection();
    }

    public synchronized void release(Connection conn){
        pool.add(conn);
    }
    /**
     * 关闭连接池中所有数据库的连接
     */
    public synchronized void closePool(){
        for(int i=0;i<pool.size();i++){
            try{
                ((Connection)pool.get(i)).close();
            }catch(SQLException e){
                e.printStackTrace();
            }
            pool.remove(i);
        }
    }
    /**
     * 返回当前连接池中的一个对象
     */
    public static ConnectionPool getInstance(){
        if(instance==null){
            instance=new ConnectionPool();
        }
        return instance;
    }

    /**
     * 返回连接池中的一个数据库连接
     */
    public synchronized Connection getConnection(){
        if(pool.size()>0){
            Connection conn=pool.get(0);
            pool.remove(conn);
            return conn;
        }else{
            return null;
        }
    }
    private void addConnection(){
        Connection conn=null;
        for(int i=0;i<poolSize;i++){
            try{
                Class.forName(driverClassName);
                conn=DriverManager.getConnection(url,username,password);
                pool.add(conn);
            }catch(ClassNotFoundException e){
                e.printStackTrace();
            }catch(SQLException r){
                r.printStackTrace();
            }
        }
    }
    private void readConfig(){
        try{
            String path=System.getProperty("use.dir")+"\\dbpool.properties";
            FileInputStream is=new FileInputStream(path);
            Properties props=new Properties();
            props.load(is);
            this.driverClassName=props.getProperty("driverClassName");
            this.username=props.getProperty("username");
            this.password=props.getProperty("password");
            this.url=props.getProperty("url");
            this.poolSize=Integer.parseInt(props.getProperty("poolSize"));
        }catch(Exception e){
            e.printStackTrace();
            System.out.println("读取属性文件错误");
        }
    }

点评:这个连接池算是比较健全了,但还是有不足的地方,看下标记的绿色的部分应加上final,橙色加粗部分应加上volatile

目录
相关文章
|
2月前
|
设计模式 消息中间件 安全
【JUC】(3)常见的设计模式概念分析与多把锁使用场景!!理解线程状态转换条件!带你深入JUC!!文章全程笔记干货!!
JUC专栏第三篇,带你继续深入JUC! 本篇文章涵盖内容:保护性暂停、生产者与消费者、Park&unPark、线程转换条件、多把锁情况分析、可重入锁、顺序控制 笔记共享!!文章全程干货!
306 1
|
3月前
|
数据采集 存储 弹性计算
高并发Java爬虫的瓶颈分析与动态线程优化方案
高并发Java爬虫的瓶颈分析与动态线程优化方案
|
存储 NoSQL Redis
Redis 新版本引入多线程的利弊分析
【10月更文挑战第16天】Redis 新版本引入多线程是一个具有挑战性和机遇的改变。虽然多线程带来了一些潜在的问题和挑战,但也为 Redis 提供了进一步提升性能和扩展能力的可能性。在实际应用中,我们需要根据具体的需求和场景,综合评估多线程的利弊,谨慎地选择和使用 Redis 的新版本。同时,Redis 开发者也需要不断努力,优化和完善多线程机制,以提供更加稳定、高效和可靠的 Redis 服务。
297 1
线程CPU异常定位分析
【10月更文挑战第3天】 开发过程中会出现一些CPU异常升高的问题,想要定位到具体的位置就需要一系列的分析,记录一些分析手段。
304 0
|
11月前
|
并行计算 安全 Java
Python GIL(全局解释器锁)机制对多线程性能影响的深度分析
在Python开发中,GIL(全局解释器锁)一直备受关注。本文基于CPython解释器,探讨GIL的技术本质及其对程序性能的影响。GIL确保同一时刻只有一个线程执行代码,以保护内存管理的安全性,但也限制了多线程并行计算的效率。文章分析了GIL的必要性、局限性,并介绍了多进程、异步编程等替代方案。尽管Python 3.13计划移除GIL,但该特性至少要到2028年才会默认禁用,因此理解GIL仍至关重要。
879 16
Python GIL(全局解释器锁)机制对多线程性能影响的深度分析
|
调度 开发者
核心概念解析:进程与线程的对比分析
在操作系统和计算机编程领域,进程和线程是两个基本而核心的概念。它们是程序执行和资源管理的基础,但它们之间存在显著的差异。本文将深入探讨进程与线程的区别,并分析它们在现代软件开发中的应用和重要性。
464 4
|
安全 Java API
Java线程池原理与锁机制分析
综上所述,Java线程池和锁机制是并发编程中极其重要的两个部分。线程池主要用于管理线程的生命周期和执行并发任务,而锁机制则用于保障线程安全和防止数据的并发错误。它们深入地结合在一起,成为Java高效并发编程实践中的关键要素。
195 0
|
存储 监控 Java
|
安全 Java 开发者
Swing 的线程安全分析
【8月更文挑战第22天】
300 4
|
Java 数据库连接 数据库
当线程中发生异常时的情况分析
【8月更文挑战第22天】
267 4

热门文章

最新文章