ThreadLocal.ThreadLocalMap threadLocals = null;

/** 
 * 返回當(dāng)前線程的 this 副本中的值 
 * 線程局部變量。如果變量沒有值 
 * 當(dāng)前線程，首先初始化為返回值 
 * 通過調(diào)用 {@link #initialValue} 方法。 
 * 
 * @return 這個線程本地的當(dāng)前線程的值 
 */  
public T get() {  
    Thread t = Thread.currentThread();  
    ThreadLocalMap map = getMap(t);  
    if (map != null) {  
        ThreadLocalMap.Entry e = map.getEntry(this);  
        if (e != null)  
            return (T)e.value;  
    }  
    return setInitialValue();  
}  
/** 
 * 設(shè)置這個線程局部變量的當(dāng)前線程的副本 
 * 到指定值。大多數(shù)子類將不需要  
 * 重寫此方法，僅依賴于 {@link #initialValue} 
 * 設(shè)置線程局部變量值的方法。 
 * 
 * @param value 要存儲在當(dāng)前線程的副本中的值。
 */  
public void set(T value) {  
    Thread t = Thread.currentThread();  
    ThreadLocalMap map = getMap(t);  
    if (map != null)  
        map.set(this, value);  
    else  
        createMap(t, value);  
}  
/** 
 * 刪除此線程本地的當(dāng)前線程的值 
 * 多變的。如果此線程局部變量隨后 
 * {@linkplain #get read} 被當(dāng)前線程讀取，其值為 
 * 通過調(diào)用其 {@link #initialValue} 方法重新初始化， 
 * 除非它的值是當(dāng)前線程的 {@linkplain #set set} 
 * 在過渡期。這可能會導(dǎo)致多次調(diào)用 
 * 當(dāng)前線程中的 <tt>initialValue</tt> 方法。 
 * 
 * @自 1.5 
 */  
 public void remove() {  
     ThreadLocalMap m = getMap(Thread.currentThread());  
     if (m != null)  
         m.remove(this);  
 }  

import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
public class ThreadLocalOOMExample {
    /**
     * 定義一個 10m 大的類
     */
    static class MyTask {
        // 創(chuàng)建一個 10m 的數(shù)組（單位轉(zhuǎn)換是 1M -> 1024KB -> 1024*1024B）
        private byte[] bytes = new byte[10 * 1024 * 1024];
    }
    // 定義 ThreadLocal
    private static ThreadLocal<MyTask> taskThreadLocal = new ThreadLocal<>();
    // 主測試代碼
    public static void main(String[] args) throws InterruptedException {
        // 創(chuàng)建線程池
        ThreadPoolExecutor threadPoolExecutor =
                new ThreadPoolExecutor(5, 5, 60,
                        TimeUnit.SECONDS, new LinkedBlockingQueue<>(100));
        // 執(zhí)行 10 次調(diào)用
        for (int i = 0; i < 10; i++) {
            // 執(zhí)行任務(wù)
            executeTask(threadPoolExecutor);
            Thread.sleep(1000);
        }
    }
    /**
     * 線程池執(zhí)行任務(wù)
     * @param threadPoolExecutor 線程池
     */
    private static void executeTask(ThreadPoolExecutor threadPoolExecutor) {
        // 執(zhí)行任務(wù)
        threadPoolExecutor.execute(new Runnable() {
            @Override
            public void run() {
                System.out.println("創(chuàng)建對象");
                // 創(chuàng)建對象（10M）
                MyTask myTask = new MyTask();
                // 存儲 ThreadLocal
                taskThreadLocal.set(myTask);
                // 將對象設(shè)置為 null，表示此對象不在使用了
                myTask = null;
            }
        });
    }
}

import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
public class App {
    /**
     * 定義一個 10m 大的類
     */
    static class MyTask {
        // 創(chuàng)建一個 10m 的數(shù)組（單位轉(zhuǎn)換是 1M -> 1024KB -> 1024*1024B）
        private byte[] bytes = new byte[10 * 1024 * 1024];
    }
    // 定義 ThreadLocal
    private static ThreadLocal<MyTask> taskThreadLocal = new ThreadLocal<>();
    // 測試代碼
    public static void main(String[] args) throws InterruptedException {
        // 創(chuàng)建線程池
        ThreadPoolExecutor threadPoolExecutor =
                new ThreadPoolExecutor(5, 5, 60,
                        TimeUnit.SECONDS, new LinkedBlockingQueue<>(100));
        // 執(zhí)行 n 次調(diào)用
        for (int i = 0; i < 10; i++) {
            // 執(zhí)行任務(wù)
            executeTask(threadPoolExecutor);
            Thread.sleep(1000);
        }
    }
    /**
     * 線程池執(zhí)行任務(wù)
     * @param threadPoolExecutor 線程池
     */
    private static void executeTask(ThreadPoolExecutor threadPoolExecutor) {
        // 執(zhí)行任務(wù)
        threadPoolExecutor.execute(new Runnable() {
            @Override
            public void run() {
                System.out.println("創(chuàng)建對象");
                try {
                    // 創(chuàng)建對象（10M）
                    MyTask myTask = new MyTask();
                    // 存儲 ThreadLocal
                    taskThreadLocal.set(myTask);
                    // 其他業(yè)務(wù)代碼...
                } finally {
                    // 釋放內(nèi)存
                    taskThreadLocal.remove();
                }
            }
        });
    }
}