【JavaWeb学习笔记】17 - ThreadLocal

项目代码

https://github.com/yinhai1114/JavaWeb_LearningCode/tree/main/threadlocal/src/com/yinhai/thread

目录

项目代码

一、什么是ThreadLocal?

二、ThreadLocal快速入门

三、源码解读

---

一、什么是ThreadLocal?

1. ThreadLocal的作用，可以实现在同一个线程数据共享从而解决多线程数据安全问题。

2. ThreadLocal可以给当前线程关联一个数据(普通变量、对象、数组)set方法

3. ThreadLocal可以像Map一样存取数据，key为当前线程, get方法

4.每一个ThreadLocal对象，只能为当前线程关联一个数据， 如果要为当前线程关联多个数据，就需要使用多个ThreadLocal对象实例

5.每个ThreadLocal对象实例定义的时候，一般为 static类型

6. ThreadLocal中保存数据，在线程销毁后，会自动释放

二、ThreadLocal快速入门

T1类?

package com.yinhai.thread;

import com.sun.javafx.tk.Toolkit;

/**
 * @author 银小海
 * @version 1.0
 * @email yinhai14@qq.com
 */
public class T1 {
    //创建ThreadLocal对象 做成static
    public static ThreadLocal<Object> threadLocal1 = new ThreadLocal<>();
    //Task是线程类 是内部类
    public static class Task implements Runnable{

        @Override
        public void run() {
            Dog dog = new Dog();
            Pig pig = new Pig();
            //给threadLocal1对象放入set dog
            System.out.println("t1 task 放入这只狗" + dog);
            threadLocal1.set(dog);//放到这个线程里 就跟这个线程相关的
            System.out.println("在T1内的Task内部类run 方法中的线程=" + Thread.currentThread().getName());
            new T1Service().update();
        }
    }
    public static void main(String[] args) {
        new Thread((new Task())).start();
    }
}

T1Service类?

package com.yinhai.thread;

/**
 * @author 银小海
 * @version 1.0
 * @email yinhai14@qq.com
 */
public class T1Service {
    public void update(){
        Object o = T1.threadLocal1.get();
        System.out.println("T1Service取出了线程关联的对象" + o);
        //获取当前线程名字
        String name = Thread.currentThread().getName();
        System.out.println("在T1Service的update()线程是" + name);

        //调用T2DAO的update方法
        new T2DAO().update();
    }
}

?T2DAO类

package com.yinhai.thread;

/**
 * @author 银小海
 * @version 1.0
 * @email yinhai14@qq.com
 */
public class T2DAO {

    public void update(){
        Object o = T1.threadLocal1.get();
        System.out.println("T2DAO取出了线程关联的对象" + o);
        //获取当前线程名字
        String name = Thread.currentThread().getName();
        System.out.println("在T2DAO的update()线程是" + name);
    }
}

三、源码解读

这个线程管理多个ThreadLocal

package com.yinhai.thread;

import com.sun.javafx.tk.Toolkit;

/**
 * @author 银小海
 * @version 1.0
 * @email yinhai14@qq.com
 */
public class T1 {
    //创建ThreadLocal对象 做成static
    public static ThreadLocal<Object> threadLocal1 = new ThreadLocal<>();
    //Task是线程类 是内部类
    public static class Task implements Runnable{

        @Override
        public void run() {
            Dog dog = new Dog();
            Pig pig = new Pig();
            //给threadLocal1对象放入set dog
            System.out.println("t1 task 放入这只狗" + dog);
            /*
                public void set(T value) {
                    //1. 获取当前线程, 关联到当前线程!
                    Thread t = Thread.currentThread();
                    //2. 通过线程对象, 获取到ThreadLocalMap
                    //这个线程管理多个ThreadLocal
                    //   ThreadLocalMap 类型是 ThreadLocal.ThreadLocalMap(一个静态内部类)
                    ThreadLocalMap map = getMap(t);
                    //3. 如果map不为null, 将数据(dog,pig..) 放入map - key:threadLocal value:存放的数据（对象）
                    //   从这个源码我们已然看出一个threadlocal只能关联一个数据，如果再set, 就会替换
                    //4. 如果map为null, 就创建一个和当前线程关联的ThreadLocalMap, 并且该数据放入
                    if (map != null)
                        map.set(this, value);
                    else
                        createMap(t, value);
                }

             */
            threadLocal1.set(dog);//放到这个线程里 就跟这个线程相关的
            System.out.println("在T1内的Task内部类run 方法中的线程=" + Thread.currentThread().getName());
            new T1Service().update();
        }
    }
    public static void main(String[] args) {
        new Thread((new Task())).start();
    }
}

?get方法

package com.yinhai.thread;

/**
 * @author 银小海
 * @version 1.0
 * @email yinhai14@qq.com
 */
public class T1Service {
    public void update(){
        Object o = T1.threadLocal1.get();
        /*
         * public T get() {
         *          //1. 先得到当前的线程对象
         *         Thread t = Thread.currentThread();
         *         //2.通过线程获取到对应的ThrealLocalMap
         *         ThreadLocalMap map = getMap(t);
         *         if (map != null) {
         *              //3. 如果map不为空, 根据当前的 threadlocal对象，得到对应的Entry
         *             ThreadLocalMap.Entry e = map.getEntry(this);
         *             //4. 如果e 不为null
         *             if (e != null) {
         *                 @SuppressWarnings("unchecked")
         *                 //返回当前threadlocal关联的数据value
         *                 T result = (T)e.value;
         *                 return result;
         *             }
         *         }
         *         return setInitialValue();
         *     }
         *
         */
        System.out.println("T1Service取出了线程关联的对象" + o);
        //获取当前线程名字
        String name = Thread.currentThread().getName();
        System.out.println("在T1Service的update()线程是" + name);

        //调用T2DAO的update方法
        new T2DAO().update();
    }
}