threadLocal Java并发编程之threadLocal

时间:2021-09-29 黑夜中的小迷途人气:0

想了解Java并发编程之threadLocal的相关内容吗，黑夜中的小迷途在本文为您仔细讲解threadLocal 的相关知识和一些Code实例，欢迎阅读和指正，我们先划重点：Java并发编程threadLocal,Java并发编程,threadLocal，下面大家一起来学习吧。

1、ThreadLocal介绍

多个线程访问同一个共享变量时特别容易出现并发问题，特别是多线程需要对共享变量进行写入时。为了保证线程安全，一般使用者在访问共享变量的时候需要进行适当的同步，如图

同步的一般措施是加锁，这就需要使用者对锁有一定的了解，这显然加重了使用者的负担，那么有没有一种方法可以做到，当创建一个变量后，每个线程对其进行访问的时候访问的是自己线程的变量呢？其实ThreadLocal就可以做到。

ThreadLocal是JDK包提供的，它提供了线程本地变量，也就是说如果创建了一个ThreadLocal变量，那么访问这个变量的每一个线程都会有这个变量的一个本地副本。当多线程操作这个变量的时候，实际操作的就是自己本地内存的里面的里面的变量，从而避免了线程安全问题。创建一个ThreadLocal变量后，每一个线程都会复制一个变量到自己的本地内存。

2、ThreadLocal使用实例

package com.heiye.learn1;

public class ThreadLocalTest {
    //print方法
    static void print(String threadName) {
        //打印当前线程本地内存中LocalVariable变量的值
        System.out.println(threadName + ":" + localVariable.get());
        //清除当前线程本地内存中的localVariable变量值
        //localVariable.remove();
    }

    //创建ThreadLocal变量
    static ThreadLocal<String> localVariable = new ThreadLocal<>();

    public static void main(String[] args) {
        //创建线程threadOne
        Thread threadOne = new Thread(new Runnable() {
            @Override
            public void run() {
                //设置线程one变量localVariable值
                localVariable.set("threadOne local Variable");
                //调用打印函数
                print("threadOne");
                //打印本地变量值
                System.out.println("threadOne remove after" + ":" + localVariable.get());
            }
        });
        //创建线程threadTwo
        Thread threadTwo = new Thread(new Runnable() {
            @Override
            public void run() {
                //设置线程two变量localVariable值
                localVariable.set("threadTwo local Variable");
                //调用打印函数
                print("threadTwo");
                //打印本地变量值
                System.out.println("threadTwo remove after" + ":" + localVariable.get());
            }
        });

        threadOne.start();
        threadTwo.start();
    }
}

线程one首先通过set()方法为threadLocal变量设置了一个值，这其实设置的就是线程one本地内存中对于threadLocal变量的一个副本。这个副本是线程two访问不了的。

如果清除当前线程本地内存中的localVariable变量值，也就是执行localVariable.remove() ;则：

3、ThreadLocal实现原理

首先查看一下ThreadLocal类图结构

由该图可知，Thread类有一个ThreadLocals和inheritableThreadLocals，它们都是ThreadLocalMap类型的变量，而ThreadLocalMap是一个定制化的HashMap。在默认的情况下，每个线程中的两个变量都为null，只有当第一个线程调用ThreadLocal的set或者get方法时才会创建它们，其实每个线程得到本地变量不是存放在ThreadLocal实例里面，而是存放在具体的线程内存空间里。ThreadLocal就是一个工具壳，它通过set方法把value值存放在调用线程的threadlocals里面并存放起来，当调用线程调用它的get()方法的时候，再从当前线程的threadLocals变量里面将其拿出来使用。

分析set，get，remove逻辑

 //set
 public void set(T value) {
        //获取当前线程
        Thread t = Thread.currentThread();
        //将当前线程作为key,到ThreadLocalMap取查找对应的线程变量
        ThreadLocalMap map = getMap(t);
        //如果找到，则设置
        if (map != null)
            map.set(this, value);
        else //第一次调用就创建当前线程所在的hashmap
            createMap(t, value);
    }

 //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();
    }

 //remove
 public void remove() {
         ThreadLocalMap m = getMap(Thread.currentThread());
         if (m != null)
             m.remove(this);
     }

在每一个线程内都有一个名为threadLocals的成员变量，该变量的类型为HashMap,其中的key为我们定义的threadLocal变量的this引用，value为我们使用set方法设置的值。每个线程的本地变量存放在自己的内存变量ThreadLocals中，如果当前线程一直不消亡，那么这些本地变量会一直存在，所有可能造成内存溢出。

加载全部内容