/**
 * 典型場景1：每個線程需要一個獨享的對象
 * 利用ThreadLocal，給每個線程分配自己的dateFormat對象，保證了線程安全，高效利用了內(nèi)存
 */
public class Main1 {
    public static ExecutorService tp = Executors.newFixedThreadPool(10);
    public String date(int seconds) {
        SimpleDateFormat df = TSF.df.get();  // 獲取當前線程擁有的 SimpleDateFormat 對象
        return df.format(new Date(1000 * seconds));
    }
    public static void main(String[] args) {
        for (int i = 0; i < 1000; i++) {
            int finalI = i;
            tp.submit(new Runnable() {
                @Override
                public void run() {
                    String date = new Main1().date(finalI);
                    System.out.println(date);
                }
            });
        }
        tp.shutdown();
    }
}
class TSF {  // ThreadSafeFormatter
    // 本類中定義的類變量都是線程內(nèi)部的，可以定義多個
    // 每個類變量的用法都是類似的，即：TSF.類變量名.get()    根據(jù)類變量名可以知道返回哪個對象
    // 底層map中存在鍵值對：(UTSF.df, 該函數(shù)的返回值)
    public static ThreadLocal<SimpleDateFormat> df = new ThreadLocal<SimpleDateFormat>() {
        @Override
        protected SimpleDateFormat initialValue() {
            return new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
        }
    };
}

/**
 * 每個線程內(nèi)需要保存全局變量
 * 同一個線程內(nèi)該全局信息相同，不同線程間該全局信息不同
 * 如下兩個線程，線程1保存全局用戶"wxx"，線程2保存全局用戶"she"
 */
public class Main2 {
    public static void main(String[] args) throws Exception {
        new Thread(() -> new Service1().process("wxx")).start();
        Thread.sleep(100);
        new Thread(() -> new Service1().process("she")).start();
    }
}
class Service1 {  // Service1 調(diào)用 Service2
    public void process(String name) {
        User user = new User(name);
        UserContextHolder.holder.set(user);  // 底層map中存在鍵值對：(UserContextHolder.holder, user)
        System.out.println("Service1:" + user.name);
        new Service2().process();
    }
}
class Service2 {  // Service2 調(diào)用 Service3
    public void process() {
        User user = UserContextHolder.holder.get();
        System.out.println("Service2:" + user.name);
        new Service3().process();
    }
}
class Service3 {
    public void process() {
        User user = UserContextHolder.holder.get();
        System.out.println("Service3:" + user.name);
    }
}
class UserContextHolder {  // 本類中定義的類變量都是線程內(nèi)部的，可以定義多個
    public static ThreadLocal<User> holder = new ThreadLocal<>();
}
class User {
    String name;
    public User(String name) {
        this.name = name;
    }
}

public class Thread implements Runnable {
    // ...
    /* ThreadLocal values pertaining to this thread. This map is maintained
     * by the ThreadLocal class. */
    ThreadLocal.ThreadLocalMap threadLocals = null;
    // ....
}

public class ThreadLocal<T> {
    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();
    }
}

public class ThreadLocal<T> {
    private T setInitialValue() {
        T value = initialValue();  // 用法一 重寫了該方法，由多態(tài)可知，返回重寫的該函數(shù)的返回值
        Thread t = Thread.currentThread();
        ThreadLocalMap map = getMap(t);  // 得到當前線程t的成員變量 threadLocals
        if (map != null)
            map.set(this, value);  // 向 threadLocals 中放入鍵值對, 關(guān)鍵!!!
        else
            createMap(t, value);
        return value;
    }
    public void set(T value) {  // 用法二調(diào)用了該方法
        Thread t = Thread.currentThread();
        ThreadLocalMap map = getMap(t);
        if (map != null)
            map.set(this, value);  // 向 threadLocals 中放入鍵值對, 關(guān)鍵!!!
        else
            createMap(t, value);
    }
    ThreadLocalMap getMap(Thread t) {
        return t.threadLocals;
    }
    void createMap(Thread t, T firstValue) {
        t.threadLocals = new ThreadLocalMap(this, firstValue);
    }
}

class Service3 {
    public void process() {
        User user = UserContextHolder.holder.get();
        System.out.println("Service3:" + user.name);
        UserContextHolder.holder.remove();  // 防止內(nèi)存泄露
    }
}

public class ThreadLocalNPE {
    ThreadLocal<Long> tl = new ThreadLocal<>();
//    public void set() {
//        tl.set(Thread.currentThread().getId());
//    }
    public long get() {  // 返回值改為 Long 就沒有NPE異常了
        return tl.get();  // tl.get() 為 null
    }
    public static void main(String[] args) {
        ThreadLocalNPE main = new ThreadLocalNPE();
        // 不進行set，直接get
        main.get();
    }
}