精品欧美一区二区三区在线观看 _久久久久国色av免费观看性色_国产精品久久在线观看_亚洲第一综合网站_91精品又粗又猛又爽_小泽玛利亚一区二区免费_91亚洲精品国偷拍自产在线观看 _久久精品视频在线播放_美女精品久久久_欧美日韩国产成人在线

并發編程 ThreadLocal 必知必會

開發
ThreadLocal? 是 Java 提供的一種簡單而強大的機制,用于實現線程局部變量,即每個線程都有自己的獨立副本,互不干擾。

在多線程編程中,共享資源的管理和同步一直是開發人員面臨的挑戰之一。ThreadLocal 是 Java 提供的一種簡單而強大的機制,用于實現線程局部變量,即每個線程都有自己的獨立副本,互不干擾。這種機制不僅簡化了并發編程中的數據管理,還提高了代碼的可讀性和可維護性。

一、詳解ThreadLocal

1. 什么是ThreadLocal?它有什么用?

為了保證特定變量對當前線程可見,我們就可以使用ThreadLocal關鍵字,ThreadLocal可以為每個線程創建這個變量的副本并存到每個線程的存儲空間中(關于這個存儲空間后文會展開講述),從而確保共享變量對每個線程隔離:

2. ThreadLocal基礎使用示例

如上文所說ThreadLocal最典型的用法就是維護各個線程各自需要獨享變量,基于ThreadLocal為每個將每個線程的id存到線程內部,彼此之間互不影響。

ThreadLocal<String> THREAD_LOCAL = new ThreadLocal<>();

        Thread t1 = new Thread(() -> {
            THREAD_LOCAL.set("thread-0");
            Console.log("thread-0獲取線程內部緩存值:{}", THREAD_LOCAL.get());
        }, "t0");


        Thread t2 = new Thread(() -> {
            THREAD_LOCAL.set("thread-1");
            Console.log("thread-1獲取線程內部緩存值:{}", THREAD_LOCAL.get());
        }, "t1");

        t1.start();
        t2.start();

從輸出結果可以看出,兩個線程都用THREAD_LOCAL 在自己的內存空間中存儲了變量的副本,彼此互相隔離的使用。

thread-1獲取線程內部緩存值:thread-1
thread-0獲取線程內部緩存值:thread-0

二、ThreadLocal兩種應用場景

1. 日期格式化

我們經常會使用SimpleDateFormat執行日期格式化輸出,為了避免頻繁的創建SimpleDateFormat的繁瑣和開銷,我們可能會編寫出下面這樣一段代碼:

private static SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss:SS");

    /**
     * 將傳入的秒轉為時間字符串
     * @param second
     * @return
     */
    public static String convert2DateStr(int second) {
        Date date = new Date(second);
        return dateFormat.format(date);
    }

對應我們也給出相應的使用示例:

//跑兩次傳入1970-01-01 08:00:00:00和1970-01-01 08:00:01:00的數據
        for (int i = 0; i < 2; i++) {
            int finalI = i;
            new Thread(() -> {
                String str = convert2DateStr(1000 * finalI);
                Console.log("轉換結果:{}", str);
            }).start();
        }

輸出結果如下,可以發現不同的時間卻輸出相同的結果:

原因也很簡單,SimpleDateFormat進行format時會通過calendar存儲當前轉換的日期,并發情況下,很可能其他線程會將當前calendar的值覆蓋,這也就是為什么我們線程0輸出了和線程1一樣的結果:

對應我們也給出SimpleDateFormat的format函數底層實現,可以看到其底層在轉換前會通過calendar存儲當前需要轉換的日期的值:

@Override
    public StringBuffer format(Date date, StringBuffer toAppendTo,
                               FieldPosition pos)
    {
        //......
      //調用format完成日期格式化字符串轉換
        return format(date, toAppendTo, pos.getFieldDelegate());
    }

    // Called from Format after creating a FieldDelegate
    private StringBuffer format(Date date, StringBuffer toAppendTo,
                                FieldDelegate delegate) {
        // 將calendar設置為需要格式化的日期
        calendar.setTime(date);
      
     //...... 
    }

基于該問題我們使用ThreadLocal為線程分配SimpleDateFormat,本質上就是針對每個線程分配一個專門的SimpleDateFormat:

private static ThreadLocal<SimpleDateFormat> THREAD_LOCAL = ThreadLocal.withInitial(() -> new SimpleDateFormat("yyyy-MM-dd HH:mm:ss:SS"));

    /**
     * 將傳入的秒轉為時間字符串
     *
     * @param second
     * @return
     */
    public static String convert2DateStr(int second) {
        Date date = new Date(second);
        return THREAD_LOCAL.get().format(date);
    }

2. 服務間調用的線程變量共享

我們日常web開發都會涉及到各種service的調用,例如某個controller需要調用完service1之后再調用service2。因為我們的controller和service都是單例的,所以如果我們希望多線程調用這些controller和service保證共享變量的隔離,也可以用到ThreadLocal。

為了實現這個示例,我們編寫了線程獲取共享變量的工具類:

public class MyUserContextHolder {
    private static ThreadLocal<User> holder = new ThreadLocal<>();

    public static ThreadLocal<User> getHolder() {
        return holder;
    }
}

service調用鏈示例如下,筆者創建service1之后,所有線程復用這個service完成了調用,并且在服務間調用直接通過ThreadLocal完成了線程副本共享:

public class MyThreadLocalGetUserId {

    private static Logger logger = LoggerFactory.getLogger(MyThreadLocalGetUserId.class);

    private static ExecutorService threadPool = Executors.newFixedThreadPool(10);

    public static void main(String[] args) {
        for (int i = 0; i < 10; i++) {
            int finalI = i;
            MyService1 service1 = new MyService1();
            threadPool.submit(() -> {

                service1.doWork1("username" + (finalI+1));
            });

        }


    }
}


class MyService1 {

    private static Logger logger = LoggerFactory.getLogger(MyThreadLocalGetUserId.class);

    public void doWork1(String name) {

        logger.info("service1 存儲userName:" + name);
        ThreadLocal<String> holder = MyUserContextHolder.getHolder();
        holder.set(name);
        MyService2 service2 = new MyService2();
        service2.doWork2();
    }

}

class MyService2 {
    private static Logger logger = LoggerFactory.getLogger(MyThreadLocalGetUserId.class);

    public void doWork2() {
        ThreadLocal<String> holder = MyUserContextHolder.getHolder();

        logger.info("service2 獲取userName:" + holder.get());
        MyService3 service3 = new MyService3();
        service3.doWork3();
    }
}


class MyService3 {
    private static Logger logger = LoggerFactory.getLogger(MyThreadLocalGetUserId.class);

    public void doWork3() {
        ThreadLocal<String> holder = MyUserContextHolder.getHolder();

        logger.info("service3獲取 userName:" + holder.get());

// 避免oom問題
        holder.remove();
    }
}

從輸出結果來看,在單例對象情況下,既保證了同一個線程間變量共享。

也保證了不同線程之間變量的隔離。

三、ThreadLocal使用注意事項

1. 內存泄漏問題

我們有下面這樣一段web代碼,每次請求test0就會像線程池中的線程存一個4M的byte數組:

RestController
public class TestController {
    final static ThreadPoolExecutor poolExecutor = new ThreadPoolExecutor(100, 100, 1, TimeUnit.MINUTES,
            new LinkedBlockingQueue<>());// 創建線程池,通過線程池,保證創建的線程存活

    final static ThreadLocal<Byte[]> localVariable = new ThreadLocal<Byte[]>();// 聲明本地變量

    @RequestMapping(value = "/test0")
    public String test0(HttpServletRequest request) {
        poolExecutor.execute(() -> {
            Byte[] c = new Byte[4* 1024* 1024];
            localVariable.set(c);// 為線程添加變量

        });
        return "success";
    }

   
}

我們將這個代碼打成jar包部署到服務器上并啟動。

java -jar -Xms100m -Xmx100m # 調整堆內存大小
-XX:+HeapDumpOnOutOfMemoryError -XX:HeapDumpPath=/tmp/heapdump.hprof  # 表示發生OOM時輸出日志文件,指定path為/tmp/heapdump.hprof
-XX:+PrintGCTimeStamps -XX:+PrintGCDetails -Xloggc:/tmp/heapTest.log # 打印日志、gc時間以及指定gc日志的路徑
demo-0.0.1-SNAPSHOT.jar

只需頻繁調用幾次,就會輸出OutOfMemoryError。

Exception in thread "pool-1-thread-5" java.lang.OutOfMemoryError: Java heap space
        at com.example.jstackTest.TestController.lambda$test0$0(TestController.java:25)
        at com.example.jstackTest.TestController$$Lambda$582/394910033.run(Unknown Source)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
        at java.lang.Thread.run(Thread.java:748)

問題的根本原因是我們沒有及時回收Thread從ThreadLocal中得到的變量副本。因為我們的使用的線程是來自線程池中,所以線程使用結束后并不會被銷毀,這就使得ThreadLocal中的變量副本會一直存儲與線程池中的線程中,導致OOM。

可能你會問了,不是說Java有GC回收機制嘛?為什么還會出現Thread中的ThreadLocalMap的value不會被回收呢?

我們上文提到ThreadLocal得到值,都會以ThreadLocal為key,ThreadLocal的initialValue方法得到的value作為值生成一個entry對象,存到當前線程的ThreadLocalMap中。 而我們的Entry的key是一個弱引用,一旦我們使用的threadLocal臨時變量用完被垃圾回收之后,這個key就會因為弱引用(只要垃圾回收器啟動就會被回收)的原因被回收,而我們這個key所對應的value仍然被線程池中的線程的強引用引用著,所以就遲遲無法回收,隨著時間推移每個線程都出現這種情況導致OOM。

所以我們每個線程使用完ThreadLocal之后,一定要使用remove方法清楚ThreadLocalMap中的value:

localVariable.remove()

從源碼中可以看到remove方法會遍歷當前線程map然后將強引用之間的聯系切斷,確保下次GC可以回收掉可以無用對象。

private void remove(ThreadLocal<?> key) {
            Entry[] tab = table;
            int len = tab.length;
            int i = key.threadLocalHashCode & (len-1);
            //定位,并將entry清除
            for (Entry e = tab[i];
                 e != null;
                 e = tab[i = nextIndex(i, len)]) {
                if (e.get() == key) {
                    e.clear();
                    expungeStaleEntry(i);
                    return;
                }
            }
        }

2. 空指針問題

使用ThreadLocal存放包裝類的時候也需要注意添加初始化方法,否則在拆箱時可能會出現空指針問題。

private  static ThreadLocal<Long> threadLocal = new ThreadLocal<>();


    public static void main(String[] args) {
        Long num = threadLocal.get();
        long sum=1+num;

    }

輸出錯誤:

Exception in thread "main" java.lang.NullPointerException
 at com.guide.base.MyThreadLocalNpe.main(MyThreadLocalNpe.java:11)

解決方式:

private  static ThreadLocal<Long> threadLocal = ThreadLocal.withInitial(()->new Long(0));

3. 線程重用問題

這個問題和OOM問題類似,在線程池中服用同一個線程未及時清理,導致下一次HTTP請求時得到上一次ThreadLocal存儲的結果。

ThreadLocal<String> threadLocal = ThreadLocal.withInitial(() -> null);


 * 線程池中使用threadLocal示例
     *
     * @param accountCode
     * @return
     */
    @GetMapping("/account/getAccountByCode/{accountCode}")
    @SentinelResource(value = "getAccountByCode")
    ResultData<Map<String, Object>> getAccountByCode(@PathVariable(value = "accountCode") String accountCode) throws InterruptedException {
        Map<String, Object> result = new HashMap<>();
        
        CountDownLatch countDownLatch = new CountDownLatch(1);
        
        
        threadPool.submit(() -> {

            String before = Thread.currentThread().getName() + ":" + threadLocal.get();
            log.info("before:" + before);
            result.put("before", before);

            log.info("調用getByCode,請求參數:{}", accountCode);
            QueryWrapper<Account> queryWrapper = new QueryWrapper<>();
            queryWrapper.eq("account_code", accountCode);
            Account account = accountService.getOne(queryWrapper);

            String after = Thread.currentThread().getName() + ":" + account.getAccountName();
            result.put("after", account.getAccountName());
            log.info("after:" + after);

            threadLocal.set(account.getAccountName());
            
            //完成計算后,使用countDown按下倒計時門閂,通知主線程可以執行后續步驟
            countDownLatch.countDown();

        });

        //等待上述線程池完成
        countDownLatch.await();

        return ResultData.success(result);
    }

從輸出結果可以看出,我們第二次進行HTTP請求時,threadLocal第一get獲得了上一次請求的值,出現臟數據。

C:\Users\xxx>curl http://localhost:9000/account/getAccountByCode/demoData
{"status":100,"message":"操作成功","data":{"before":"pool-2-thread-1:null","after":"pool-2-thread-1:demoData"},"success":true,"timestamp":1678410699943}
C:\Users\xxx>curl http://localhost:9000/account/getAccountByCode/Zsy
{"status":100,"message":"操作成功","data":{"before":"pool-2-thread-1:demoData","after":"pool-2-thread-1:zsy"},"success":true,"timestamp":1678410707473}

解決方法也很簡單,手動添加一個threadLocal的remove方法即可:

@GetMapping("/account/getAccountByCode/{accountCode}")
    @SentinelResource(value = "getAccountByCode")
    ResultData<Map<String, Object>> getAccountByCode(@PathVariable(value = "accountCode") String accountCode) throws InterruptedException {
        Map<String, Object> result = new HashMap<>();

        CountDownLatch countDownLatch = new CountDownLatch(1);

        try {
            threadPool.submit(() -> {

                String before = Thread.currentThread().getName() + ":" + threadLocal.get();
                log.info("before:" + before);
                result.put("before", before);

                log.info("調用getByCode,請求參數:{}", accountCode);
                QueryWrapper<Account> queryWrapper = new QueryWrapper<>();
                queryWrapper.eq("account_code", accountCode);
                Account account = accountService.getOne(queryWrapper);

                String after = Thread.currentThread().getName() + ":" + account.getAccountName();
                result.put("after", after);
                log.info("after:" + after);

                threadLocal.set(account.getAccountName());

                //完成計算后,使用countDown按下倒計時門閂,通知主線程可以執行后續步驟
                countDownLatch.countDown();

            });
        } finally {
            threadLocal.remove();
        }


        //等待上述線程池完成
        countDownLatch.await();

        return ResultData.success(result);
    }

四、基于源碼了解ThreadlLocal工作原理

1. ThreadlLocal如何做到線程隔離的?

我們下面這段代碼為例進行分析,通過withInitial聲明每個線程創建后續創建線程私有變量的SimpleDateFormat模板:

ThreadLocal<SimpleDateFormat> threadLocal = ThreadLocal.withInitial(() -> new SimpleDateFormat("yyyy-MM-dd HH:mm:ss:SS"));

當我們執行get操作時,threadLocal 就會為當前線程完成內部map的初始化,然后通過initialValue獲取上一步聲明的SimpleDateFormat實例,由此保證每個線程內部都有一個獨有的SimpleDateFormat:

對應的我們給出ThreadlLocal的get的源碼,整體邏輯與上述差不多,即初始化線程內部的map,然后通過setInitialValue調用initialValue創建初始值存到線程的map中:

public T get() {
    //獲取當前線程
        Thread t = Thread.currentThread();
        //拿到當前線程中的map
        ThreadLocalMap map = getMap(t);
        //如果map不為空則取用當前這個ThreadLocal作為key取出值,否則通過setInitialValue完成ThreadLocal初始化
        if (map != null) {
            ThreadLocalMap.Entry e = map.getEntry(this);
            if (e != null) {
                @SuppressWarnings("unchecked")
                T result = (T)e.value;
                return result;
            }
        }
        return setInitialValue();
    }


private T setInitialValue() {
    //執行initialValue為當前線程創建變量value,在這里也就是我們要用的SimpleDateFormat 
        T value = initialValue();
        //獲取當前線程map,有則直接以ThreadLocal為key將SimpleDateFormat 設置進去,若沒有先創建再設置
        Thread t = Thread.currentThread();
        ThreadLocalMap map = getMap(t);
        if (map != null)
            map.set(this, value);
        else
            createMap(t, value);
//返回SimpleDateFormat 
        return value;
    }

2. ThreadLocalMap有什么特點?和HashMap有什么區別

我們通過源碼查看到這個map為ThreadLocalMap,它是由一個個Entry 構成的數組:

private Entry[] table;

并且每個Entry 的key是弱引用,這就意味著當觸發GC時,Entry 的key也就是ThreadLocal就會被回收。

static class Entry extends WeakReference<ThreadLocal<?>> {
            /** The value associated with this ThreadLocal. */
            Object value;

            Entry(ThreadLocal<?> k, Object v) {
                super(k);
                value = v;
            }
        }

除上面所說,thread中的map和hashmap還有一個不同點就是數據結構,因為threadLocal的適用場景特殊,所以大部分情況下其內部存儲空間不會存儲太多元素,所以出于簡單的考慮,線程中的map本質上就是一個數組,一旦發生沖突則直接通過線性探測法找到數組中空閑的位置將值存入:

private void set(ThreadLocal<?> key, Object value) {

           //......

            Entry[] tab = table;
            int len = tab.length;
            //定位鍵值對存儲的索引位置
            int i = key.threadLocalHashCode & (len-1);
      //通過線性探測法循環找到空閑位置存入元素
            for (Entry e = tab[i];
                 e != null;
                 e = tab[i = nextIndex(i, len)]) {
                ThreadLocal<?> k = e.get();

               //......
            }
      //找到合適的位置將元素存入
            tab[i] = new Entry(key, value);
            //更新一下容量信息
            int sz = ++size;
            //......
        }

3. ThreadLocal探測式清理和啟發式清理

上文中我們介紹了ThreadLocal使用不當所導致的內存泄漏問題,實際上Josh Bloch and Doug Lea也考慮過該問題,并在實現中也有對這些問題做一定的考慮,即探測式清理和啟發式清理。

我們先來說說探測式清理,它一般會在如下幾個時機觸發:

  • 調用get方法未找到元素時,調用getEntryAfterMiss觸發探測式清理
  • 調用remove方法時,完成對應的元素清理后
  • 底層map容量達到閾值時,觸發rehash
private int expungeStaleEntry(int staleSlot) {
            Entry[] tab = table;
            int len = tab.length;

            // expunge entry at staleSlot
            tab[staleSlot].value = null;
            tab[staleSlot] = null;
            size--;

            // Rehash until we encounter null
            Entry e;
            int i;
       //遍歷threadLocal 底層的map
            for (i = nextIndex(staleSlot, len);
                 (e = tab[i]) != null;
                 i = nextIndex(i, len)) {
                ThreadLocal<?> k = e.get();
              //如果ket為空,就說明該key對應value沒有被使用,可直接設置為null等待gc
                if (k == null) {
                    e.value = null;
                    tab[i] = null;
                    size--;
                } else {
                   //......
                }
            }
            return i;
        }

另一種則是探測式清理,它一般時跟隨著threadLocal寫入新元素或者覆蓋新元素時觸發的set和replaceStaleEntry,它會從操作的索引i開始遍歷并清理value:

private boolean cleanSomeSlots(int i, int n) {
            boolean removed = false;
            Entry[] tab = table;
            int len = tab.length;
            do {
                i = nextIndex(i, len);
                Entry e = tab[i];
               //調用e的get方法為空,說明這個key即對應的線程的threadLocal被回收
                if (e != null && e.get() == null) {
                    n = len;
                    removed = true;
                    i = expungeStaleEntry(i);
                }
            } while ( (n >>>= 1) != 0);
            return removed;
        }

需要強調的是,這兩種清理方式都有一定的局限性,使得thread map中key為空只會在觸發如下3個條件:

  • threadLocal被垃圾回收
  • key作為弱引用被回收
  • 觸發探測式或者啟動式清理

這也就意味著如果我們的threadLocal采用static修飾后,對應的元空間threadLocal引用就會強引用著堆區的threadlocal實例,也就說theadlocal就會跟隨類對象存在于GC堆中,即與類對象生命周期相同,除非threadLocal對應類被卸載,否則這個threadLocal變量就不可能被GC即每個線程內部的value都無法被探測式或者啟發式清理掉,如果沒有顯示remove每個線程中threadLocal的map的話,還是存在內存溢出的風險:

五、ThreadLocal的不可繼承性

1. 通過代碼證明ThreadLocal的不可繼承性

如下代碼所示,ThreadLocal子線程無法拿到主線程維護的內部變量:

/**
 * ThreadLocal 不具備可繼承性
 */
public class ThreadLocalInheritTest {
    private static ThreadLocal<String> THREAD_LOCAL = new ThreadLocal<>();

    private static Logger logger = LoggerFactory.getLogger(ThreadLocalInheritTest.class);

    public static void main(String[] args) {
        THREAD_LOCAL.set("mainVal");
        logger.info("主線程的值為: " + THREAD_LOCAL.get());

        new Thread(() -> {
            try {
                //睡眠3s確保上述邏輯運行
                Thread.sleep(3000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            logger.info("子線程獲取THREAD_LOCAL的值為:[{}]", THREAD_LOCAL.get());
        }).start();
    }

}

2. 使用InheritableThreadLocal實現主線程內部變量繼承

如下所示,我們將THREAD_LOCAL 改為InheritableThreadLocal類即可解決問題。

/**
 * ThreadLocal 不具備可繼承性
 */
public class ThreadLocalInheritTest {

    private static ThreadLocal<String> THREAD_LOCAL = new InheritableThreadLocal<>();

    private static Logger logger = LoggerFactory.getLogger(ThreadLocalInheritTest.class);

    public static void main(String[] args) {
        THREAD_LOCAL.set("mainVal");
        logger.info("主線程的值為: " + THREAD_LOCAL.get());

        new Thread(() -> {
            try {
                //睡眠3s確保上述邏輯運行
                Thread.sleep(3000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            logger.info("子線程獲取THREAD_LOCAL的值為:[{}]", THREAD_LOCAL.get());
        }).start();
    }

}

3. 基于源碼剖析原因

因為 ThreadLocal會將變量存儲在線程的 ThreadLocalMap中,所以我們先看看InheritableThreadLocal的getMap方法,從而定位到了inheritableThreadLocals:

ThreadLocalMap getMap(Thread t) {
       return t.inheritableThreadLocals;
    }

然后我們到Thread類去定位這個變量的使用之處,所以我們在創建線程的地方打了個斷點:

從而定位到這段初始化,它會獲取主線程的ThreadLocalMap并將主線程ThreadLocalMap中的值存到子線程的ThreadLocalMap中。

private void init(ThreadGroup g, Runnable target, String name,
                      long stackSize, AccessControlContext acc,
                      boolean inheritThreadLocals) {
        if (name == null) {
            throw new NullPointerException("name cannot be null");
        }

        this.name = name;

  //獲取當前線程的主線程
        Thread parent = currentThread();
       
        if (inheritThreadLocals && parent.inheritableThreadLocals != null)
            this.inheritableThreadLocals =
            //將主線程的map的值存到子線程中
                ThreadLocal.createInheritedMap(parent.inheritableThreadLocals);
        //......
    }

createInheritedMap內部就會調用ThreadLocalMap方法將主線程的ThreadLocalMap的值存到子線程的ThreadLocalMap中。

private ThreadLocalMap(ThreadLocalMap parentMap) {
            Entry[] parentTable = parentMap.table;
            int len = parentTable.length;
            setThreshold(len);
            table = new Entry[len];
   //遍歷父線程數據復制到子線程map中
            for (int j = 0; j < len; j++) {
                Entry e = parentTable[j];
                if (e != null) {
                    @SuppressWarnings("unchecked")
                    ThreadLocal<Object> key = (ThreadLocal<Object>) e.get();
                    if (key != null) {
                     //......
                     //定位當前子線程bucket位置將value存入
                        while (table[h] != null)
                            h = nextIndex(h, len);
                        table[h] = c;
                        size++;
                    }
                }
            }
        }

4. ThreadLocal在Spring中的運用

其實針對日期格式化問題,Spring已經為我們內置好了相應的工具類即DateTimeContextHolder:

private static final ThreadLocal<DateTimeContext> dateTimeContextHolder =
   new NamedThreadLocal<>("DateTimeContext");

該工具類和simpledateformate差不多,使用示例如下所示,是spring封裝的,使用起來也很方便:

public class DateTimeContextHolderTest {


    protected static final Logger logger = LoggerFactory.getLogger(DateTimeContextHolderTest.class);

    private final static DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");

    private Set<String> set = new ConcurrentHashSet<String>();

    @Test
    public void test_withLocale_same() throws Exception {
        ExecutorService threadPool = Executors.newFixedThreadPool(30);

        for (int i = 0; i < 30; i++) {
            int finalI = i;
            threadPool.execute(() -> {
                LocalDate currentdate = LocalDate.now();
                int year = currentdate.getYear();
                int month = currentdate.getMonthValue();
                int day = 1 + finalI;
                LocalDate date = LocalDate.of(year, month, day);

                DateTimeFormatter fmt = DateTimeContextHolder.getFormatter(formatter, null);
                String text = date.format(fmt);
                set.add(text);
                logger.info("轉換后的時間為" + text);
            });
        }

        threadPool.shutdown();
        while (!threadPool.isTerminated()) {

        }

        logger.info("查看去重后的數量"+set.size());


    }
}

5. 為什么JDK建議將ThreadLocal設置為static

我們都知道使用static是屬于類,存在于方法區中,即修飾的變量是全局共享的,這意味著當前ThreadLocal在通過static之后,即所有的實例對象都共享一個ThreadLocal。從而避免重復創建TSO(Thread Specific Object)即ThreadLocal所關聯的對象的創建的開銷, 以及這種方案使得即使出現內存泄漏也是O(1)級別的內存泄露。對應的實例變量的ThreadLocal的O(n)內存泄漏,這就不必多說。

六、小結

  • ThreadLocal通過在將共享變量拷貝一份到每個線程內部的ThreadLocalMap保證線程安全。
  • ThreadLocal使用完成后記得使用remove方法手動清理線程中的ThreadLocalMap過期對象,避免OOM和一些業務上的錯誤。
  • ThreadLocal是不可被繼承了,如果想使用主線的的ThreadLocal,就必須使用InheritableThreadLocal。
責任編輯:趙寧寧 來源: 寫代碼的SharkChili
相關推薦

2024-06-19 10:08:34

GoChannel工具

2015-08-17 16:05:35

javascript對象編程

2020-07-10 07:58:14

Linux

2024-11-15 11:11:48

2024-01-03 07:56:50

2022-05-18 09:01:19

JSONJavaScript

2023-10-09 18:52:14

SOLIDJava

2022-08-19 10:31:32

Kafka大數據

2024-09-02 09:00:59

2024-01-10 18:01:22

編程技巧Java 12

2019-01-30 14:14:16

LinuxUNIX操作系統

2015-10-20 09:46:33

HTTP網絡協議

2018-10-26 14:10:21

2023-05-08 15:25:19

Python編程語言編碼技巧

2023-04-20 14:31:20

Python開發教程

2024-06-13 09:10:22

2024-01-09 13:58:22

PandasPython數據分析

2023-12-26 12:10:13

2022-08-26 14:46:31

機器學習算法線性回歸

2019-11-06 10:56:59

Python數據分析TGI
點贊
收藏

51CTO技術棧公眾號

欧美国产高清| 日韩特级毛片| 奇米一区二区三区av| 深夜福利国产精品| 99热这里只有精品2| 香蕉成人app免费看片| jiyouzz国产精品久久| 日韩免费在线播放| 午夜三级在线观看| 电影一区二区在线观看| 欧美午夜激情在线| 亚洲视频电影| 无码精品黑人一区二区三区| 日韩av不卡在线观看| 欧美国产极速在线| 欧美黄色一级生活片| 日韩一级淫片| 欧美在线free| www插插插无码视频网站| www.在线播放| 99久久伊人久久99| 91久久久在线| 福利网址在线观看| 狠狠干综合网| www亚洲欧美| 一本加勒比北条麻妃| 亚洲高清999| 欧美日韩精品一区二区三区| 午夜免费福利小电影| 日本黄色片在线观看| 成人av电影在线观看| 国产日本欧美一区二区三区在线| 日韩男人的天堂| 亚洲一区二区三区| 一区二区三欧美| 香港三级日本三级| 在线精品视频一区| 欧美老年两性高潮| 午夜激情福利在线| 91av亚洲| 精品久久久久久久久中文字幕| 日本一区二区免费高清视频| 韩国三级在线观看久| 99精品视频在线免费观看| 亚洲va久久久噜噜噜久久天堂| 波多野结衣在线观看视频| 国产精品嫩草99av在线| 欧美大片第1页| 国产黄在线免费观看| 青青草成人影院| 亚洲国产精品va在线看黑人动漫| 国产裸体视频网站| 亚洲伊人伊成久久人综合网| 色菇凉天天综合网| 免费日韩中文字幕| 裤袜国产欧美精品一区| 欧美视频一区二区三区…| 久久精品国产sm调教网站演员| 影音先锋中文在线视频| 亚洲精品大片www| 中国一级黄色录像| 成人免费网址| 亚洲精品国产无天堂网2021| 超薄肉色丝袜足j调教99| 黄网站视频在线观看| 一区精品在线播放| 桥本有菜av在线| www免费视频观看在线| 樱花草国产18久久久久| 日韩免费在线观看av| 美女精品导航| 欧美日韩午夜视频在线观看| 欧美丰满熟妇bbbbbb百度| 波多野结衣亚洲| 在线免费观看一区| 日韩精品视频一二三| 国产aa精品| 日韩精品专区在线影院重磅| 免费黄色三级网站| 综合亚洲自拍| 日韩视频免费看| 欧美在线视频第一页| 亚洲午夜视频| 欧美怡春院一区二区三区| 久久免费的精品国产v∧| 51国产成人精品午夜福中文下载| 亚洲AV无码成人片在线观看| 不卡一区二区三区四区| 欧美1o一11sex性hdhd| 韩国福利在线| 亚洲天堂2014| 国产二区视频在线| 色综合一本到久久亚洲91| 精品久久久久久最新网址| 国产97在线|日韩| 亚洲字幕av一区二区三区四区| 麻豆成人综合网| 91在线在线观看| 三区在线观看| 国产精品的网站| www.射射射| 九七电影院97理论片久久tvb| 91精品国产品国语在线不卡| 在线免费观看a级片| 欧美午夜精品一区二区三区电影| 久久国产精品影视| 久久久精品福利| 国产一区欧美二区| 国产亚洲欧美另类一区二区三区| 黄色小视频在线免费观看| 亚洲美女偷拍久久| 久久久久久久久久久久久久国产| www.成人在线.com| 亚洲人成免费电影| 国产精品999久久久| 麻豆国产精品777777在线| 久久av一区二区三区漫画| 欧美三级电影一区二区三区| 欧美日韩一区二区在线播放| 制服下的诱惑暮生| 日韩欧美不卡| 5252色成人免费视频| www.精品视频| 中文字幕一区二| 97在线免费公开视频| 一区二区三区在线资源| 色噜噜亚洲精品中文字幕| 欧美啪啪小视频| 成人黄页毛片网站| 免费看污污视频| 欧洲精品久久久久毛片完整版| 精品在线观看国产| 精品少妇theporn| 久久电影网站中文字幕| 日本一区二区在线视频| 福利影院在线看| 欧美成人精品福利| 欧美88888| 久久一二三四| 精品国产一区二区三区久久久久久| 欧美精品电影| 欧美一a一片一级一片| 青青草视频播放| 欧美另类女人| 欧美亚洲国产视频| 日韩中文字幕免费观看| 亚洲视频免费看| 狠狠躁狠狠躁视频专区| 窝窝社区一区二区| 久久久久久国产精品久久| 97精品人妻一区二区三区在线| 99久久精品免费观看| av片在线免费| 日本精品视频| 久久精品国产亚洲精品2020| 国产日韩在线免费观看| 26uuu久久天堂性欧美| 亚洲欧洲日产国码无码久久99| 在线综合色站| 欧美激情一区二区三区在线视频观看 | 亚洲精品欧美日韩| av电影在线观看| 色呦呦日韩精品| 国产肉体xxxx裸体784大胆| 136国产福利精品导航网址| 99国产精品久久久久老师| av在线免费网站| 69p69国产精品| 欧美精品一级片| 国产精品一区二区在线播放| 先锋影音男人资源| 亚洲国产一区二区三区网站| 九九精品视频在线| 亚洲视频在线观看免费视频| 亚洲欧美偷拍另类a∨色屁股| www.午夜av| 午夜久久黄色| 国产精品一区二区在线观看| 超清av在线| 日韩成人久久久| 91蜜桃视频在线观看| 国产网红主播福利一区二区| 日本在线观看a| av一区二区高清| 国产精品直播网红| 黄色片免费在线观看| 亚洲国产精品资源| youjizz在线视频| 亚洲国产电影在线观看| www午夜视频| 欧美日韩亚洲一区二区三区在线| 久久av一区二区三区亚洲| 春暖花开亚洲一区二区三区| 这里只有精品在线观看| 国产精品无码久久av| 亚洲国产日韩a在线播放性色| 新91视频在线观看| 狠狠色综合播放一区二区| 日本大胆人体视频| 久久综合五月婷婷| 国产成人啪精品视频免费网| 制服丝袜中文字幕在线| 日韩av中文字幕在线播放| 波多野结衣视频在线看| 依依成人综合视频| 99久久久无码国产精品性| 国产精品一区免费在线观看| 国产免费黄视频| 欧美第一精品| 91黄色在线看| 日韩黄色a级片| 91免费版在线| 中文字幕一区二区三区四| 极品少妇一区二区三区| 精品成人av一区| 怡红院一区二区| 天堂久久久久va久久久久| 玖玖精品在线视频| 国产精品入口久久| 国模精品娜娜一二三区| 黄色成人小视频| 97在线视频精品| 秋霞a级毛片在线看| 精品久久五月天| 中文字幕人妻精品一区| 亚洲va欧美va国产va天堂影院| 免费成人深夜天涯网站| 成人一区二区视频| 天天久久综合网| 日韩av午夜在线观看| www.av91| 五月开心六月丁香综合色啪| 欧美动漫一区二区| 国内露脸中年夫妇交换精品| 国产视频福利一区| 精品91久久| 久久人人爽人人| 国产一级免费在线观看| 日韩精品欧美国产精品忘忧草| 国产精品丝袜黑色高跟鞋| 在线亚洲一区二区| 国产成人愉拍精品久久| 亚洲高清久久久| 私库av在线播放| 国产精品国产三级国产aⅴ无密码| 成年人在线观看av| 成人av免费网站| 亚洲一区二区三区黄色| 国产精品911| 中文字幕色网站| 麻豆成人久久精品二区三区小说| 日韩av黄色网址| 日韩视频一区| 国产精品国产对白熟妇| 午夜精品久久| 亚洲精品人成| 日韩在线视频精品| 亚洲欧美日产图| 日韩免费久久| 四虎影院一区二区三区 | 性高潮久久久久久| 极品少妇一区二区三区精品视频| 国产区二区三区| 免费一区二区视频| 亚洲欧美日韩一级| 国产一区美女在线| 国产在线a视频| 国产福利精品导航| 国产情侣久久久久aⅴ免费| 99久久99久久久精品齐齐| 亚洲啪av永久无码精品放毛片 | 国产sm在线观看| 国产精品99久久久久久宅男| 国产成人av片| 白白色亚洲国产精品| 国产一级二级视频| 99精品一区二区| 国产一区二区三区精品在线| 国产女主播视频一区二区| 国产123在线| 国产精品欧美久久久久无广告| 自拍偷拍中文字幕| 国产欧美日韩久久| 久久精品亚洲a| 一区二区三区在线不卡| 国产精品第72页| 在线观看成人免费视频| 亚洲香蕉在线视频| 日韩欧美久久一区| 天天干天天摸天天操| 在线精品播放av| www在线免费观看视频| 欧美黑人国产人伦爽爽爽| 国产在线看片免费视频在线观看| 5566成人精品视频免费| 中文字幕在线高清| 国产精品一区二区三区毛片淫片| 99久久999| 免费中文日韩| 婷婷伊人综合| 亚洲中文字幕无码av永久| 久久综合图片| 69亚洲乱人伦| 国产女人aaa级久久久级| 强制高潮抽搐sm调教高h| 亚洲图片有声小说| 一区二区视频免费| 亚洲第一区第一页| 午夜视频在线| 97热精品视频官网| 蜜桃精品视频| 久久久神马电影| 91精品二区| 欧美成人高潮一二区在线看| 精品一区二区综合| 野花社区视频在线观看| 亚洲男人的天堂在线观看| 久久久综合久久| 欧美亚洲动漫精品| 人妻精品无码一区二区| 日韩在线观看免费全集电视剧网站| 国产无遮挡裸体视频在线观看| 国产欧美一区二区| 亚洲成a人片77777在线播放| 午夜视频久久久| 视频一区欧美精品| 五月天丁香社区| 亚洲私人黄色宅男| 成人h动漫精品一区二区下载| 精品国产免费人成在线观看| 2019中文字幕在线视频| 欧洲一区二区视频| 欧美亚洲国产日韩| 国产精品igao激情视频| 欧美激情亚洲一区| 人妻熟女aⅴ一区二区三区汇编| 免费不卡av| 久久乐国产精品| 日韩在线电影| 欧洲精品一区二区三区在线观看| 亚洲爱爱综合网| www.xxxx精品| 亚洲精品一区av| 色播亚洲视频在线观看| 在线一区免费观看| 高潮一区二区三区| 国产精品久久久久久久蜜臀| 国产污污视频在线观看| 亚洲成年人在线| 日本不卡影院| 国产在线观看一区二区三区| 你懂的一区二区三区| 国产一区二区网| 91色乱码一区二区三区| 黄网在线观看视频| 亚洲电影免费观看高清完整版在线观看| 国产精品剧情一区二区在线观看 | av网在线播放| 狠狠躁夜夜躁人人躁婷婷91 | 亚洲成人看片| 久久av免费观看| 日韩av中文字幕一区二区三区 | 97久久精品人人做人人爽50路| 久久久国产精华液| 亚洲白拍色综合图区| 白白色在线观看| 国产区一区二区三区| 在线观看日韩av电影| 国产三级国产精品| 色屁屁一区二区| 成人在线视频成人| 成人写真福利网| 欧美区一区二| 国产大尺度视频| 欧美日韩加勒比精品一区| 欧美精品a∨在线观看不卡| 2019亚洲日韩新视频| 久久不见久久见中文字幕免费 | 亚洲夜夜综合| 精品麻豆av| 日韩精品三区四区| 久久嫩草捆绑紧缚| 日韩一区二区电影| 麻豆免费在线| 日韩av高清| 久久成人免费电影| 日韩欧美国产亚洲| 亚洲欧美在线播放| 成人1区2区| 中文字幕在线乱| 91免费版在线| 91亚洲国产成人精品一区| 欧美高清自拍一区| 国产精品探花在线观看| 欧美特黄aaa| 亚洲无人区一区| 国产最新在线| 国产一区二区三区四区五区在线| 老司机精品视频网站| 国产99在线 | 亚洲|