通过CLR同步SQL Server和Sharepoint List数据（三）

菲示嚎且在前文中我们讲过ThreadLocal相当于是每个线程有一个小书包线程之间的小书包是隔离的只存放了属于当前线程自己的变量因此不会发生数据安全的问题。前文博客浅谈ThreadLocal----每个线程一个小书包 https://www.cnblogs.com/jilodream/p/19118986但是有时任务太繁重时父线程希望new出新的子线程来为自己的业务提供帮助同时希望子线程在处理时也能用到自己保存在ThreadLocal中的变量。现在有三种办法1直接把父线程的ThreadLocalMap传递给子线程让子线程直接拿去用如sonThread.threadLocalsparent.threadLocals2父线程在创建子线程时将子线程需要用到的ThreadLocal数据专门指定。如复制代码Thread sonThreadnew Thread(new Runnable() {Overridepublic void run() {threadLocal1.set(xxx1); //手动指定threadLocal2.set(xxx2); //手动指定threadLocal3.set(xxx3); //手动指定}});复制代码3将父线程中threadLocals 中的数据打包整理后统一传递给子线程。第一种显然不行如果两者指向了相同的Map 会导致缓存数据被共享父子线程存在并发读写又会导致安全问题。方法二虽然灵活但是指定起来过于繁琐每个子线程都要单独设置一遍。java选用的是方法三但是实现起来稍有不同java 定义了一个InheritableThreadLocal类。通过这个类来实现线程可继承的ThreadLocal定义中的Inheritable [?nher?t?bl]adj. 可继承的会遗传的InheritableThreadLocal指可以继承/遗传的ThreadLocal。接下来看源码在Thread类中定义了以下属性ThreadLocal.ThreadLocalMap inheritableThreadLocals null;类似于thread.threadLocals这是给InheritableThreadLocal 来存储可以继承的属性的Map。InheritableThreadLocal类的源码它继承了ThreadLocal复制代码public class InheritableThreadLocal extends ThreadLocal {/*** Creates an inheritable thread local variable.*/public InheritableThreadLocal() {}/*** Computes the childs initial value for this inheritable thread-local* variable as a function of the parents value at the time the child* thread is created. This method is called from within the parent* thread before the child is started.** This method merely returns its input argument, and should be overridden* if a different behavior is desired.** param parentValue the parent threads value* return the child threads initial value*/protected T childValue(T parentValue) {return parentValue;}/*** Get the map associated with a ThreadLocal.** param t the current thread*/ThreadLocalMap getMap(Thread t) {return t.inheritableThreadLocals;}/*** Create the map associated with a ThreadLocal.** param t the current thread* param firstValue value for the initial entry of the table.*/void createMap(Thread t, T firstValue) {t.inheritableThreadLocals new ThreadLocalMap(this, firstValue);}}复制代码通过源码我们可以发现它的用法和实现与ThreadLocal基本相同但是它重写了父类ThreadLocal的几个方法1首先是getMap(),重写的目的是当需要操作map对象时(防盗连接本文首发自http://www.cnblogs.com/jilodream/ )请使用inheritableThreadLocals而不是再是父类中的t.threadLocals写法这样所有使用的map就都切换到了ThreadLocal.ThreadLocalMap inheritableThreadLocals这个属性上来了。2其次是createMap() 方法该方法的主要目的是初始化Map对象这里强调了初始化的是 t.inheritableThreadLocals 属性。为啥没直接用getMap() 方法来获取 t.inheritableThreadLocals呢这是由于 t.inheritableThreadLocals 还没有初始化返回是null你调用getMap()没有意义。3最后是 childValue() 方法它是指当发生继承动作时父类中的存储的变量转化为子类对象的转化转换。这里直接抽象成方法了方便大家重写自己的InheritableThreadLocal类时可以直接重写该方法。如我们想前边加一个标签代表是子线程专用亦或者进行翻译转换等等总之方便你自己实现转换。来看下继承动作具体是怎么操作的继承主要发生在主线程创建子线程程时我们来看下Thread的构造方法源码经过一堆跳转最后会跳转进这个方法复制代码private Thread(ThreadGroup g, Runnable target, String name,long stackSize, AccessControlContext acc,boolean inheritThreadLocals) {//....if (inheritThreadLocals parent.inheritableThreadLocals ! null)this.inheritableThreadLocals ThreadLocal.createInheritedMap(parent.inheritableThreadLocals);/* Stash the specified stack size in case the VM cares */this.stackSize stackSize;/* Set thread ID */this.tid nextThreadID();}复制代码方法参数中的boolean inheritThreadLocals表示是否要继承/遗传。手动创建的线程这里都会是true代表要继承/遗传。parent.inheritableThreadLocals ! null 判断父线程的inheritableThreadLocals 属性是否为null 是否初始化了如果不为null父线程有需要遗传的本地变量才发生遗传动作。条件都满足则发生遗传(防盗连接本文首发自http://www.cnblogs.com/jilodream/ )入参为父线程的遗传本地变量也就是属性inheritableThreadLocals。之后进入ThreadLocalMap的构造方法开始构造子线程的inheritableThreadLocals 属性复制代码private ThreadLocalMap(ThreadLocalMap parentMap) {Entry[] parentTable parentMap.table;int len parentTable.length;setThreshold(len);table new Entry[len];for (Entry e : parentTable) {if (e ! null) {SuppressWarnings(unchecked)ThreadLocalkey (ThreadLocal) e.get();if (key ! null) {Object value key.childValue(e.value);Entry c new Entry(key, value);int h key.threadLocalHashCode (len - 1);while (table[h] ! null)h nextIndex(h, len);table[h] c;size;}}}}复制代码方法中就是遍历父线程的Map生成子线程自己的Map.Entry 了。这里注意在获取Entry的key 时通过entry.get() 拿到父线程的Map 的key的弱引用强制转化为ThreadLocal类型即可。在获取value 值时调用的是key的childValue()方法也就是InheritableThreadLocal.childValue()中重写的方法将父线程的value值转为子线程的value时。这样子线程中:1、map初始化好了2、entry元素也通过父线程都转移到子线程中了3、获取的遗传map使用的都是遗传map了。通过getMap()重写map的get set remove 等核心逻辑都直接使用父类的逻辑。因为InheritableThreadLocal继承自ThreadLocal并且没有重写这段逻辑总体上了来说ThreadLocalInheritableThreadLocal的实现都非常的优雅不但很好的利用了对象的继承保证用户在使用时无感知的发生了继承。其次用户在自定义自己的InheritableThreadLocal class时(防盗连接本文首发自http://www.cnblogs.com/jilodream/ )也只需要完成如何转化即可。非常值得我们自己在设计类结构和关系时参考这里的细节设计。类关系整体的结构如下Itlleitu除此之外我们也可以通过源码发现InheritableThreadLocal的一个特性就是属性的遗传来自于父InheritableThreadLocal的全量属性是不能根据某个线程自定义的。并且在遗传时子线程是在被new出实例时就已经获得了此刻全部的属性如果父线程后续调整了InheritableThreadLocal的范围子线程是感知不到的。来看这样一个例子即可复制代码public static void main(String[] args) {ThreadLocal tl1 new InheritableThreadLocal();ThreadLocal tl2 new InheritableThreadLocal();ThreadLocal tl3 new InheritableThreadLocal();tl1.set(t1);tl2.set(t2);Thread sonThread new Thread(new Runnable() {Overridepublic void run() {String s1 tl1.get();String s2 tl2.get();String s3 tl3.get();System.out.println(out: s1);System.out.println(out: s2);System.out.println(out: s3);}});tl2.set(newTl2Value);sonThread.start();}