`
humn_chou
  • 浏览: 23014 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

Hibernate ThreadLocal讲解

阅读更多
[size=large][/size][size=medium]首先,ThreadLocal 不是用来解决共享对象的多线程访问问题的,一般情况下,通过ThreadLocal.set() 到线程中的对象是该线程自己使用的对象,其他线程是不需要访问的,也访问不到的。各个线程中访问的是不同的对象。

另外,说ThreadLocal使得各线程能够保持各自独立的一个对象,并不是通过ThreadLocal.set()来实现的,而是通过每个线程中的new 对象 的操作来创建的对象,每个线程创建一个,不是什么对象的拷贝或副本
。通过ThreadLocal.set()将这个新创建的对象的引用保存到各线程的自己的一个map中,每个线程都有这样一个map,执行ThreadLocal.get()时,各线程从自己的map中取出放进去的对象,因此取出来的是各自自己线程中的对象,ThreadLocal实例是作为map的key来使用的。

如果ThreadLocal.set()进去的东西本来就是多个线程共享的同一个对象,那么多个线程的ThreadLocal.get()取得的还是这个共享对象本身,还是有并发访问问题。

下面来看一个hibernate中典型的ThreadLocal的应用:
private static final ThreadLocal threadSession = new ThreadLocal();   
  
public static Session getSession() throws InfrastructureException {   
    Session s = (Session) threadSession.get();   
    try {   
        if (s == null) {   
            s = getSessionFactory().openSession();   
            threadSession.set(s);   
        }   
    } catch (HibernateException ex) {   
        throw new InfrastructureException(ex);   
    }   
    return s;   
}  


可以看到在getSession()方法中,首先判断当前线程中有没有放进去session,如果还没有,那么通过sessionFactory().openSession()来创建一个session,再将session set到线程中,实际是放到当前线程的ThreadLocalMap这个map中,这时,对于这个session的唯一引用就是当前线程中的那个ThreadLocalMap(下面会讲到),而threadSession作为这个值的key,要取得这个session可以通过threadSession.get()来得到,里面执行的操作实际是先取得当前线程中的ThreadLocalMap,然后将threadSession作为key将对应的值取出。这个session相当于线程的私有变量,而不是public的。
显然,其他线程中是取不到这个session的,他们也只能取到自己的ThreadLocalMap中的东西。要是session是多个线程共享使用的,那还不乱套了。
试想如果不用ThreadLocal怎么来实现呢?可能就要在action中创建session,然后把session一个个传到service和dao中,这可够麻烦的。或者可以自己定义一个静态的map,将当前thread作为key,创建的session作为值,put到map中,应该也行,这也是一般人的想法,但事实上,ThreadLocal的实现刚好相反,它是在每个线程中有一个map,而将ThreadLocal实例作为key,这样每个map中的项数很少,而且当线程销毁时相应的东西也一起销毁了,不知道除了这些还有什么其他的好处。


总之,ThreadLocal不是用来解决对象共享访问问题的,而主要是提供了保持对象的方法和避免参数传递的方便的对象访问方式。归纳了两点:
1。每个线程中都有一个自己的ThreadLocalMap类对象,可以将线程自己的对象保持到其中,各管各的,线程可以正确的访问到自己的对象。
2。将一个共用的ThreadLocal静态实例作为key,将不同对象的引用保存到不同线程的ThreadLocalMap中,然后在线程执行的各处通过这个静态ThreadLocal实例的get()方法取得自己线程保存的那个对象,避免了将这个对象作为参数传递的麻烦。


当然如果要把本来线程共享的对象通过ThreadLocal.set()放到线程中也可以,可以实现避免参数传递的访问方式,但是要注意get()到的是那同一个共享对象,并发访问问题要靠其他手段来解决。但一般来说线程共享的对象通过设置为某类的静态变量就可以实现方便的访问了,似乎没必要放到线程中


ThreadLocal的应用场合,我觉得最适合的是按线程多实例(每个线程对应一个实例)的对象的访问,并且这个对象很多地方都要用到。


下面来看看ThreadLocal的实现原理(jdk1.5源码)
public class ThreadLocal<T> {   
    /**  
     * ThreadLocals rely on per-thread hash maps attached to each thread  
     * (Thread.threadLocals and inheritableThreadLocals).  The ThreadLocal  
     * objects act as keys, searched via threadLocalHashCode.  This is a  
     * custom hash code (useful only within ThreadLocalMaps) that eliminates  
     * collisions in the common case where consecutively constructed  
     * ThreadLocals are used by the same threads, while remaining well-behaved  
     * in less common cases.  
     */  
    private final int threadLocalHashCode = nextHashCode();   
  
    /**  
     * The next hash code to be given out. Accessed only by like-named method.  
     */  
    private static int nextHashCode = 0;   
  
    /**  
     * The difference between successively generated hash codes - turns  
     * implicit sequential thread-local IDs into near-optimally spread  
     * multiplicative hash values for power-of-two-sized tables.  
     */  
    private static final int HASH_INCREMENT = 0x61c88647;   
  
    /**  
     * Compute the next hash code. The static synchronization used here  
     * should not be a performance bottleneck. When ThreadLocals are  
     * generated in different threads at a fast enough rate to regularly  
     * contend on this lock, memory contention is by far a more serious  
     * problem than lock contention.  
     */  
    private static synchronized int nextHashCode() {   
        int h = nextHashCode;   
        nextHashCode = h + HASH_INCREMENT;   
        return h;   
    }   
  
    /**  
     * Creates a thread local variable.  
     */  
    public ThreadLocal() {   
    }   
  
    /**  
     * Returns the value in the current thread's copy of this thread-local  
     * variable.  Creates and initializes the copy if this is the first time  
     * the thread has called this method.  
     *  
     * @return the current thread's value of this thread-local  
     */  
    public T get() {   
        Thread t = Thread.currentThread();   
        ThreadLocalMap map = getMap(t);   
        if (map != null)   
            return (T)map.get(this);   
  
        // Maps are constructed lazily.  if the map for this thread   
        // doesn't exist, create it, with this ThreadLocal and its   
        // initial value as its only entry.   
        T value = initialValue();   
        createMap(t, value);   
        return value;   
    }   
  
    /**  
     * Sets the current thread's copy of this thread-local variable  
     * to the specified value.  Many applications will have no need for  
     * this functionality, relying solely on the {@link #initialValue}  
     * method to set the values of thread-locals.  
     *  
     * @param value the value to be stored in the current threads' copy of  
     *        this thread-local.  
     */  
    public void set(T value) {   
        Thread t = Thread.currentThread();   
        ThreadLocalMap map = getMap(t);   
        if (map != null)   
            map.set(this, value);   
        else  
            createMap(t, value);   
    }   
  
    /**  
     * Get the map associated with a ThreadLocal. Overridden in  
     * InheritableThreadLocal.  
     *  
     * @param  t the current thread  
     * @return the map  
     */  
    ThreadLocalMap getMap(Thread t) {   
        return t.threadLocals;   
    }   
  
    /**  
     * Create the map associated with a ThreadLocal. Overridden in  
     * InheritableThreadLocal.  
     *  
     * @param t the current thread  
     * @param firstValue value for the initial entry of the map  
     * @param map the map to store.  
     */  
    void createMap(Thread t, T firstValue) {   
        t.threadLocals = new ThreadLocalMap(this, firstValue);   
    }   
  
    .......   
  
    /**  
     * ThreadLocalMap is a customized hash map suitable only for  
     * maintaining thread local values. No operations are exported  
     * outside of the ThreadLocal class. The class is package private to  
     * allow declaration of fields in class Thread.  To help deal with  
     * very large and long-lived usages, the hash table entries use  
     * WeakReferences for keys. However, since reference queues are not  
     * used, stale entries are guaranteed to be removed only when  
     * the table starts running out of space.  
     */  
    static class ThreadLocalMap {   
  
    ........   
  
    }   
  
}  


可以看到ThreadLocal类中的变量只有这3个int型:
private final int threadLocalHashCode = nextHashCode();   
private static int nextHashCode = 0;   
private static final int HASH_INCREMENT = 0x61c88647; 


而作为ThreadLocal实例的变量只有 threadLocalHashCode 这一个,nextHashCode 和HASH_INCREMENT 是ThreadLocal类的静态变量,实际上HASH_INCREMENT是一个常量,表示了连续分配的两个ThreadLocal实例的threadLocalHashCode值的增量,而nextHashCode 的表示了即将分配的下一个ThreadLocal实例的threadLocalHashCode 的值。

可以来看一下创建一个ThreadLocal实例即new ThreadLocal()时做了哪些操作,从上面看到构造函数ThreadLocal()里什么操作都没有,唯一的操作是这句:

private final int threadLocalHashCode = nextHashCode();  


那么nextHashCode()做了什么呢:
private static synchronized int nextHashCode() {   
    int h = nextHashCode;   
    nextHashCode = h + HASH_INCREMENT;   
    return h;   
} 


就是将ThreadLocal类的下一个hashCode值即nextHashCode的值赋给实例的threadLocalHashCode,然后nextHashCode的值增加HASH_INCREMENT这个值。

因此ThreadLocal实例的变量只有这个threadLocalHashCode,而且是final的,用来区分不同的ThreadLocal实例,ThreadLocal类主要是作为工具类来使用,那么ThreadLocal.set()进去的对象是放在哪儿的呢?

看一下上面的set()方法,两句合并一下成为

ThreadLocalMap map = Thread.currentThread().threadLocals; 


这个ThreadLocalMap 类是ThreadLocal中定义的内部类,但是它的实例却用在Thread类中:

public class Thread implements Runnable {   
    ......   
  
    /* ThreadLocal values pertaining to this thread. This map is maintained  
     * by the ThreadLocal class. */  
    ThreadLocal.ThreadLocalMap threadLocals = null;     
    ......   
}  


再看这句:
if (map != null)   
    map.set(this, value);  



也就是将该ThreadLocal实例作为key,要保持的对象作为值,设置到当前线程的ThreadLocalMap 中,get()方法同样大家看了代码也就明白了,ThreadLocalMap 类的代码太多了,我就不帖了,自己去看源码吧。


-----以上内容均来之网络  仅供自己参考学习[/size]
分享到:
评论

相关推荐

    hibernate

    可以使用 `ThreadLocal` 变量来解决这个问题,确保每个线程都有自己的 `Session` 实例。 #### 三、使用 Hibernate 的基本步骤 **1. 创建 Configuration 对象** ```java Configuration config = new Configuration...

    Hibernate的课件以及一些配置的帮助

    【描述】:“Hibernate的课件包括了对主键生成策略的讲解,以及详尽的Hibernate参数设置一览表,这些都是在实际项目中不可或缺的知识。” **主键生成策略**: 1. **Identity策略**:由数据库自动分配主键,如MySQL...

    javaee课件

    这个类的目的是为了方便生成Configuration对象和SessionFactory对象,并且使用ThreadLocal保证每个线程都有一份独立的Session。 掌握Hibernate框架和API的使用,可以有效地解决传统JDBC编程中复杂和繁琐的问题。...

    轻量级J2EE企业应用实战(part 4)共分5个part

    - **ThreadLocal**: 用来实现线程间的数据隔离,确保每个线程都有自己的副本,避免了多线程间的同步问题。 ##### 3. Session的创建与管理 - **不加拦截器的Session创建**:通过`sessionFactory.openSession()`直接...

    j2ee的aop方式记录日志

    本教程将详细讲解如何在SSH框架中利用Spring AOP实现日志记录,并结合ThreadLocal存储用户和请求信息。 首先,理解AOP的基本概念。AOP允许我们定义“切面”,这些切面可以包含方法拦截器,这些拦截器在目标方法执行...

    JavaGuide-master

    - **多线程**:深入理解线程的创建、同步和通信,如synchronized关键字、ThreadLocal、ExecutorService等。 - **I/O流**:文件操作、网络通信等涉及的输入输出流,包括字节流、字符流、缓冲流和转换流等。 - **...

    Java编程宝典:十年典藏版5

    此外,还会讨论线程同步和并发编程,如synchronized关键字、volatile变量、ThreadLocal、CountDownLatch等工具的使用。 再者,Java集合框架是Java开发中的重要组成部分。书中会详细解析ArrayList、LinkedList、...

    Spring整合多数据源实现动态切换的实例讲解

    Spring整合多数据源实现动态切换的实例讲解 在实际项目中,我们经常需要连接多个数据库,而不同的业务需求在实现过程中往往需要访问不同的数据库。今天,我们将探讨如何使用Spring框架来实现多数据源的动态切换。 ...

    阿里巴巴Java开发手册(纪念版)

    1. ORM框架:讲解Hibernate、MyBatis等ORM框架的最佳实践,包括SQL优化、事务管理等。 2. 数据库设计:强调规范化设计,减少冗余,提高查询效率。 五、网络编程 1. HTTP协议:讨论HTTP请求与响应的处理,包括连接池...

    Java 就业培训教程及源代码

    6. **多线程编程**:讨论线程的创建、同步、通信,以及线程池的使用,理解线程安全问题及其解决方案,如synchronized关键字、volatile、ThreadLocal等。 7. **网络编程**:介绍Socket编程,包括TCP和UDP协议,以及...

    java笔试题大集合及答案(另附各大公司笔试题)

    以下将针对这些知识点进行详细讲解。 1. **Java基础语法**:这是学习Java的第一步,包括变量、数据类型、运算符、流程控制语句(如if、for、while)、方法、类与对象等。了解这些基础知识是解答任何Java笔试题的...

    疯狂Java实战演义光盘

    - **运算符与控制结构**:讲解赋值、比较、逻辑运算符,以及if语句、switch语句、for、while、do-while循环的用法。 - **方法**:如何定义、调用和传递参数的方法,理解方法重载和重写的概念。 - **对象与类**:...

    java 面试葵花宝典

    《Java面试葵花宝典》是一本专门为Java开发者准备的面试...《Java面试葵花宝典》将这些知识点逐一剖析,结合实例讲解,是Java开发者面试必备的参考资料,能够帮助你全面了解和掌握Java领域的核心知识,提升面试成功率。

    经典JAVA.EE企业应用实战.基于WEBLOGIC_JBOSS的JSF_EJB3_JPA整合开发.pdf

    第二部分详细讲解了jsf ri、jta、jndi、rmi、jms、javamail、ejb 3的session bean、message driven bean、jpa、jax-ws 2、jaas等java ee知识,这部分知识以jsf+ejb 3+jpa整合开发为重点,通过使用netbeans ide工具...

Global site tag (gtag.js) - Google Analytics