ThreadLocal--线程封闭--高并发场景下

叁歲伎倆 2022-11-26 08:49 202阅读 0赞

ThreadLocal:用于实现线程内部的数据共享叫线程共享（对于同一个线程内部数据一致），即相同的一段代码 多个线程来执行 ，每个线程使用的数据只与当前线程有关。  
实现原理：ThreadLocal相当于一个map 当前线程 存储当前的变量的时候 map.put(确定线程的唯一值（比如变量名称）,变量)，然后获取的时候直接拿过来就行

一般用法：定义一个全局变量ThreadLoacl t 将新建线程要使用的变量 存进去 比如

1.当存储的为基本变量或者包装对象时

package com.yanghs.test.traditional;
     
    /** * @author yanghs * @Description: * @date 2018/3/31 16:24 */
    public class ThreadLocalTest  { 
        /*定义一个全局变量 来存放线程需要的变量*/
        public static ThreadLocal<Integer> ti = new ThreadLocal<Integer>();
        public static void main(String[] args) { 
            /*创建两个线程*/
            for(int i=0; i<2;i++){ 
                new Thread(new Runnable() { 
                    @Override
                    public void run() { 
                        Double d = Math.random()*10;
                        /*存入当前线程独有的值*/
                        ti.set(d.intValue());
                        new A().get();
                        new B().get();
                    }
                }).start();
            }
        }
        static class A{ 
            public void get(){ 
                /*取得当前线程所需要的值*/
                System.out.println(ti.get());
            }
        }
        static class B{ 
            public void get(){ 
                /*取得当前线程所需要的值*/
                System.out.println(ti.get());
            }
        }
    }

2.当存储的为对象时 就是数据集合 比如前台传过来的参数，每一个人传过来的 都是这个人独有的，才能保证数据准确性，抽取业务数据为一个对象

class ThreadLocalDemo{ 
        /*把线程相关的部分内聚到 类里面 相当于map 每个类是对应key*/
        private static ThreadLocal<ThreadLocalDemo> t = new ThreadLocal<ThreadLocalDemo>();
        private ThreadLocalDemo(){ }
        public static ThreadLocalDemo getThreadInstance(){ 
            ThreadLocalDemo threadLocalDemo  = t.get();
            if(null == threadLocalDemo){ //当前线程无绑定的对象时，直接绑定一个新的对象
                threadLocalDemo = new ThreadLocalDemo();
                t.set(threadLocalDemo);
            }
            return threadLocalDemo;
        }
     
        private String name;
     
        public String getName() { 
            return name;
        }
     
        public void setName(String name) { 
            this.name = name;
        }
    }

把ThreadLocal 放在业务对象里面提现高内聚,实现的目的是每一个线程都有一个独立的ThreadLocalDemo对象。 使用的时候只需要 ThreadLocalDemo.getInstance()就可以得到当前线程的所需要的值。

package com.yanghs.test.traditional;
     
    /** * @author yanghs * @Description: * @date 2018/3/31 16:24 */
    public class ThreadLocalTest  { 
        public static void main(String[] args) { 
            for(int i=0; i<2;i++){ 
                new Thread(new Runnable() { 
                    @Override
                    public void run() { 
                        Double d = Math.random()*10;
                        ThreadLocalDemo.getThreadInstance().setName("name"+d);
                        new A().get();
                        new B().get();
                    }
                }).start();
            }
        }
        static class A{ 
            public void get(){ 
                System.out.println(ThreadLocalDemo.getThreadInstance().getName());
            }
        }
        static class B{ 
            public void get(){ 
                System.out.println(ThreadLocalDemo.getThreadInstance().getName());
            }
        }
    }

多线程使用可能值会改变静态变量的值

public class LocalContextUtil { 
        private static ThreadLocal<String> localUserCode = new ThreadLocal<>();
        private static ThreadLocal<String> localUserName = new ThreadLocal<>();
        private static ThreadLocal<String> localOwnRegion = new ThreadLocal<>();
        private static ThreadLocal<String> localRolesName = new ThreadLocal<>();
    
    
        public static String getUserCode() { 
            return  localUserCode.get();
        }
    
        public static void setUserCode(String userCode) { 
            localUserCode.set(userCode);
        }
    
        public static String getUserName() { 
            return localUserName.get();
        }
    
        public static void setUserName(String userName) { 
            localUserName.set(userName);
        }
    
        public static String getOwnRegion() { 
            return localOwnRegion.get();
        }
    
        public static void setRolesName(String rolesName) { 
            localRolesName.set(rolesName);
        }
    
        public static String getRolesName() { 
            return localRolesName.get();
        }
    
        public static void setOwnRegion(String ownRegion) { 
            localOwnRegion.set(ownRegion);
        }
    
    
    
        /** * 销毁 */
        public static void removeAllThreadLocal(){ 
            localUserCode.remove();
            localUserName.remove();
            localOwnRegion.remove();
            localRolesName.remove();
        }