在阅读JTA源码的时候,看到事务管理器的是有,遇到这样一段代码。
// 此处 transactionHolder 用于将 Transaction 所代表的事务对象关联到线程上
private static ThreadLocal<TransactionImpl> transactionHolder
= new ThreadLocal<TransactionImpl>();
//TransacationMananger 必须维护一个全局对象,因此使用单实例模式实现
private static TransactionManagerImpl singleton = new TransactionManagerImpl();
private TransactionManagerImpl(){
}
public static TransactionManagerImpl singleton(){
return singleton;
}
public void begin() throws NotSupportedException, SystemException {
//XidImpl 实现了 Xid 接口,其作用是唯一标识一个事务
XidImpl xid = new XidImpl();
// 创建事务对象,并将对象关联到线程
TransactionImpl tx = new TransactionImpl(xid);
transactionHolder.set(tx);
}
其中的TheadLocal引起了我的注意。
通过查阅资料得知。
TheadLocal,是一种用来处理并发的方式。
应用场景:
在多个线程同时使用一个变量的时候,多个线程会对同一个变量的值都产生影响,这是在高并发情况下经常出现的问题。
我们常用的处理方式是加“同步锁”,使用synchronized 方法来保证同一时间段只能有一个线程能使用该变量。
这只是一种处理方式,还有一种处理方式,拷贝多份变量,让每一个线程使用的都是自己独有的一个对象。
下面简单介绍一个ThreadLocal。
TheadLocal的大概含义就是:维护了一个Map,让线程作为Map的key,让我们使用的变量作为Map的value,从而实现了每个线程单独享用自己的变量。
ThreadLocal 最主要使用的就四个方法:
1. protected T initialValue() {
return null;
}
这个是最最重要的,同时我们也注意到它是一个protected方法,也就是专门用来被子类继承的。(注意,protected方法,不能被类自己的对象,也不能被子类的对象直接调用。)
这个方法的会被内部的get()方法调用在于,当我们使用 get方法获取当前线程内的变量发现为Null的时候,就会调用这个方法。(这也相当于懒加载的一个实际应用。)
2.get()方法的代码如下,该方法获取线程独享的变量。
public T get() {
Thread t = Thread.currentThread();
ThreadLocalMap map = getMap(t);
if (map != null) {
ThreadLocalMap.Entry e = map.getEntry(this);
if (e != null) {
@SuppressWarnings("unchecked")
T result = (T)e.value;
return result;
}
}
return setInitialValue();
}
3.set()方法,这是用来改变当前线程的变量的值用的,和HasHmap中的put(key,value)方法类似,只不过由于key都是当前的线程,所以就省略了。
代码如下:
public void set(T value) {
Thread t = Thread.currentThread();
ThreadLocalMap map = getMap(t);
if (map != null)
map.set(this, value);
else
createMap(t, value);
}
4.remove()方法
销毁当前线程里的value值。不用的时候销毁,这样也就能省一些资源。
代码如下:
public void remove() {
ThreadLocalMap m = getMap(Thread.currentThread());
if (m != null)
m.remove(this);
}
关于为什么这里能够真正的释放掉变量的内存,这里其实很有意思。
看代码的时候我们发现,这个Map中所保存的entru对象是一个弱引用。
static class Entry extends WeakReference<ThreadLocal<?>> {
/** The value associated with this ThreadLocal. */
Object value;
Entry(ThreadLocal<?> k, Object v) {
super(k);
value = v;
}
}
这也算是我第一次看见弱引用的使用实例。
http://blog.csdn.net/lufeng20/article/details/24314381
这篇文章有一个例子,可以帮助理解ThreaLocal。
ps:关于 强引用 、软引用、弱引用、虚引用的知识,请参考JVM虚拟机。