当前位置:首页 > 开发 > 编程语言 > 多线程 > 正文

ThreadLocal源码学习

发表于: 2014-07-29   作者:_crazysnail_   来源:转载   浏览次数:
摘要: ThreadLocal,线程本地化对象,在多线程环境中,使用ThreadLocal对象来维护变量时,ThreadLocal为每个使用该变量的线程维护一个独立的线程副本。 ThreadLocal.java源文件内容为: /** * ThreadLocal内部包含一个用数组实现的哈希表,用来存储对应到每个线程的局部对象的值 * 其中,ThreadLocal对象担当key,实际通过thr

ThreadLocal,线程本地化对象,在多线程环境中,使用ThreadLocal对象来维护变量时,ThreadLocal为每个使用该变量的线程维护一个独立的线程副本。

ThreadLocal.java源文件内容为:

/**
  * ThreadLocal内部包含一个用数组实现的哈希表,用来存储对应到每个线程的局部对象的值
  * 其中,ThreadLocal对象担当key,实际通过threadLocalHashCode值来进行检索
  */
public class ThreadLocal<T> {
	//其中 T 类型代表的是被多个线程访问的局部变量类型 
	/** 
	* 在ThreadLocalMaps中用于产生哈希值 
	*/ 
	private final int threadLocalHashCode = nextHashCode(); 
	/** 
	* Returns the current thread's "initial value" for this 
	* thread-local variable. This method will be invoked the first 
	* time a thread accesses the variable with the {@link #get} 
	* method, unless the thread previously invoked the {@link #set} 
	* method, in which case the <tt>initialValue</tt> method will not 
	* be invoked for the thread. Normally, this method is invoked at 
	* most once per thread, but it may be invoked again in case of 
	* subsequent invocations of {@link #remove} followed by {@link #get}. 
	* * <p>This implementation simply returns <tt>null</tt>; if the 
	* programmer desires thread-local variables to have an initial 
	* value other than <tt>null</tt>, <tt>ThreadLocal</tt> must be 
	* subclassed, and this method overridden. Typically, an 
	* anonymous inner class will be used. 
	* * @return the initial value for this thread-local(返回当前线程局部对象的初始值) 
	*/ 
	protected T initialValue() { 
		//protected成员,期望被子类继承 
		return null; 
	} 
	/** 
	* 返回在当前线程中的线程局部对象的值, 
	* 若线程局部对象对于当前线程没有值,则被初始化微 initialValue方法的返回值 
	*/ 
	public T get() { 
		Thread t = Thread.currentThread(); 
		ThreadLocalMap map = getMap(t); 
		if (map != null) { 
			ThreadLocalMap.Entry e = map.getEntry(this); 
			if (e != null) 
				return (T)e.value; 
		} 

			return setInitialValue(); 
	} 

	/** 
	* Sets the current thread's copy of this thread-local variable 
	* to the specified value. Most subclasses will have no need to 
	* override this method, relying solely on the method to set the values of thread-locals. 
	*/ 
	public void set(T value) { 
		Thread t = Thread.currentThread(); 
		ThreadLocalMap map = getMap(t); 
		if (map != null) 
			//以当前线程对象为key,设置当前局部对象的值
			map.set(this, value); 
		else 
			createMap(t, value); 
	} 

	/** 
	* Removes the current thread's value for this thread-local 
	* variable. If this thread-local variable is subsequently 
	* {@linkplain #get read} by the current thread, its value will be 
	* reinitialized by invoking its {@link #initialValue} method, 
	* unless its value is {@linkplain #set set} by the current thread 
	* in the interim. This may result in multiple invocations of the 
	* <tt>initialValue</tt> method in the current thread. 
	*/ 
	public void remove() { 
		ThreadLocalMap m = getMap(Thread.currentThread()); 
		if (m != null) 
			//从ThreadLocalMap中移除对象
			m.remove(this); 
	} 

	/** 
	* Get the map associated with a ThreadLocal. Overridden in 
	* InheritableThreadLocal. 
	* * @param t the current thread 
	* @return the map 
	*/ 
	ThreadLocalMap getMap(Thread t) { 
		//返回当前Threadlocal相关的ThreadLocalMap对象 
		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对象 
	} 

	//ThreadLocalMap是一个定制的只能用来存储线程局部对象的哈希映射 
	//使用弱引用来当做key,只有当表空间不够时,旧的对象才会被移除 
	static class ThreadLocalMap { 
		//ThreadLocalMap的内部数组的元素类型:使用对ThreadLocal的弱引用类型来作为元素类型 
		static class Entry extends WeakReference<ThreadLocal> { 
		/** 
		* The value associated with this ThreadLocal. 
		*/ 
		Object value; 

		Entry(ThreadLocal k, Object v) { 
			super(k); 
			value = v; 
		} 
	} 

	//哈希表的初始大小 
	private static final int INITIAL_CAPACITY = 16; 

	/** 
	* 用于存储ThreadLocal弱引用的数组 
	*/ 
	private Entry[] table; 

	//ThreadLocalMap使用延迟初始化,当我们需要向ThreadLocalMap中放元素时,才会初始化它 
	ThreadLocalMap(ThreadLocal firstKey, Object firstValue) { 
		table = new Entry[INITIAL_CAPACITY]; 
		int i = firstKey.threadLocalHashCode & (INITIAL_CAPACITY - 1); 
		table[i] = new Entry(firstKey, firstValue); //初始时,使用ThreadLocal.threadLocalHashCode作为哈希表的哈希值 size = 1; 

		//设定ThreadLocalMap中元素个数 
		setThreshold(INITIAL_CAPACITY); 
	} 

	/** 
	* Set the value associated with key. 
	* * @param key the thread local object 
	* @param value the value to be set 
	*/ 
	private void set(ThreadLocal key, Object value) { 
		// We don't use a fast path as with get() because it is at 
		// least as common to use set() to create new entries as 
		// it is to replace existing ones, in which case, a fast 
		// path would fail more often than not. 
		Entry[] tab = table; 
		int len = tab.length; 
		int i = key.threadLocalHashCode & (len-1); 
		for (Entry e = tab[i]; e != null; e = tab[i = nextIndex(i, len)]) { 
			ThreadLocal k = e.get(); 
			if (k == key) { 
				e.value = value; 
				return; 
			} 

			if (k == null) { 
				replaceStaleEntry(key, value, i); 
				return;
			} 
		} 

		tab[i] = new Entry(key, value); 
		int sz = ++size; 
		if (!cleanSomeSlots(i, sz) && sz >= threshold) 
			rehash(); 
	} 

	/** 
	* Remove the entry for key. 
	*/ 
	private void remove(ThreadLocal key) { 
		Entry[] tab = table; 
		int len = tab.length; 
		int i = key.threadLocalHashCode & (len-1); 
		for (Entry e = tab[i]; e != null; e = tab[i = nextIndex(i, len)]) { 
			if (e.get() == key) { 
				e.clear(); 
				expungeStaleEntry(i); 
				return; 
			} 
		} 
	} 
}

 

 ThreadLocal使用一个ThreadLocalMap对象(内部通过数组和哈希来保存,以当前线程为键)来为每一个线程保存一份变量的本地化对象。

ThreadLocal源码学习

  • 0

    开心

    开心

  • 0

    板砖

    板砖

  • 0

    感动

    感动

  • 0

    有用

    有用

  • 0

    疑问

    疑问

  • 0

    难过

    难过

  • 0

    无聊

    无聊

  • 0

    震惊

    震惊

编辑推荐
1. ThreadLocal字面理解? 不是"本地线程",而是Thread的局部变量; 2. ThreadLocal如何维护变量?
背景:1、如果一个对象中有成员,当通过调用对象的方法操作(修改、查询等)成员时,如果没有加锁或
在阅读《Java Concurrency In Practice》时,书中提到ThreadLocal是一种更为规范常用的Thread Confi
threadLocal能够保证变量在每个线程中单独存在,各个线程互相不会影响。 通常我们这么写threadLocal
我在之前的文章《Android中的Looper,Handler及HandlerThread简析》(http://maosidiaoxian.iteye.co
我们知道Spring通过各种DAO模板类降低了开发者使用各种数据持久技术的难度。这些模板类都是线程安全
1. 感觉自己在多线程方面知识很欠缺,平时做WEB开发,体会不是很深,因为Servlet容器、各种WEB框架
这一篇之所以讲ThreadLocal,是因为之前在读Handler,Looper的源码过程(见http://maosidiaoxian.itey
上篇讲到了ThreadLocal类(http://maosidiaoxian.iteye.com/blog/1939142),这篇继续讲ThreadLocal
ThreadLocal概述 学习JDK中的类,首先看下JDK API对此类的描述,描述如下: 该类提供了线程局部 (th
版权所有 IT知识库 CopyRight © 2009-2015 IT知识库 IT610.com , All Rights Reserved. 京ICP备09083238号