【Java并发编程】ThreadLocal（一）：使用示例

雨点打透心脏的1/2处 2022-11-12 08:29 125阅读 0赞

> ThreadLocal 系列：
> 
>  *  [【Java并发编程】ThreadLocal（一）：使用示例][Java_ThreadLocal]
>  *  [【Java并发编程】ThreadLocal（二）：从设计思路到源码分析][Java_ThreadLocal 1]
>  *  [【Java并发编程】ThreadLocal（三）：内存泄漏问题分析][Java_ThreadLocal 2]

下面启动 9 个子线程，每个子线程都将名字（thread - i）存在同一个变量中，然后再打印出来。可以想到，如果同一个变量可以做到线程间隔离（互补影响），控制台正确的结果应该是 thread - 0 到 thread - 8。

下面就分别演示演示这个变量的两种实现：1.普通变量String ，2.`ThreadLocal<String>`

### 1.普通变量 ###

public class StringTest {
        
    	// 保存线程名的普通变量value
        private String value;
    	// 不直接设置value，而是暴露出get和set方法
        private String getString() {
         return string; }
        private void setString(String string) {
         this.string = string; }
    
        public static void main(String[] args) {
        
        
            StringTest test= new StringTest ();
            
            int threads = 9; // 要启动的线程个数
            CountDownLatch countDownLatch = new CountDownLatch(threads); // countDownLatch 用于防止主线程在子线程未完成前结束
           
            // 启动9个子线程
            for (int i = 0; i < threads; i++) {
        
                Thread thread = new Thread(() -> {
        
                    test.setString(Thread.currentThread().getName()); // 向变量value中存入线程名 thread - i
                    System.out.println(test.getString()); // 然后打印出来。注：这里可能存在并发
                    countDownLatch.countDown(); // 门栓-1
                }, "thread - " + i); 
                thread.start();
            }
        }
    
    	countDownLatch.await(); // 等countDownLatch为0时，主线程恢复运行
    }

结果如下：

thread - 1
    thread - 2
    thread - 1
    thread - 3
    thread - 4
    thread - 5
    thread - 6
    thread - 7
    thread - 8

可以看到没有 thread - 0，反而 thread - 1 出现了两次，所以使用普通类型的变量无法实现同一变量对于不同线程隔离

### 2.ThreadLocal ###

使用ThreadLocal时，一般声明为static，原因有二：

*  一个类一个ThreadLocal --> 当前线程一个Entry 就够了
 *  使用时调用方便

public class ThreadLocalStringTest {
        
    	// 保存线程名的ThreadLocal变量threadLocal
    	// 注：这里除了是String，也可是别的任何类型（Integer，List，Map...）
        private static ThreadLocal<String> threadLocal = new ThreadLocal<>();
    	// 不直接操作 threadLocal，而是封装成 set/get 方法
        private String getString() {
         return threadLocal.get(); }
        private void setString(String string) {
         threadLocal.set(string);}
    
        public static void main(String[] args) {
        
        
            ThreadLocalStringTest test= new ThreadLocalStringTest();
            
            int threads = 9; // 要创建的子线程个数
            CountDownLatch countDownLatch = new CountDownLatch(threads); // countDownLatch 用于防止主线程在子线程未完成前结束
    		
            // 创建 9 个线程
            for (int i = 0; i < threads; i++) {
        
                Thread thread = new Thread(() -> {
        
                    test.setString(Thread.currentThread().getName()); // 向ThreadLocal中存入当前线程名 thread - i
                    System.out.println(test.getString()); // 向ThreadLocal获取刚存的线程名。注：可能存在并发
                    countDownLatch.countDown(); // 门栓-1
                }, "thread - " + i);
                thread.start();
            }
    		
    		countDownLatch.await(); // 等countDownLatch为0时，主线程恢复运行
        }
    
    }

运行结果：

thread - 0
    thread - 1
    thread - 2
    thread - 3
    thread - 4
    thread - 5
    thread - 6
    thread - 7
    thread - 8

可以看到运行结果符合预期，即ThreadLocal实现了同一变量在线程间隔离。另外ThreadLocal还可以用于单点登录，用来保存不同请求线程的token，然后在解析时取出。

[Java_ThreadLocal]: https://yzhyaa.blog.csdn.net/article/details/115118750
[Java_ThreadLocal 1]: https://yzhyaa.blog.csdn.net/article/details/108889167
[Java_ThreadLocal 2]: https://yzhyaa.blog.csdn.net/article/details/115074130