欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

java  中ThreadLocal實例分析

 更新時間:2017年06月15日 08:38:53   投稿:lqh  
這篇文章主要介紹了java 中ThreadLocal實例分析的相關(guān)資料,需要的朋友可以參考下

java  中ThreadLocal實例分析

從概念上理解,threadlocal使變量在多個線程中相互隔離實現(xiàn)線程安全,threadlocal包裝的變量最終都專屬于對應(yīng)的每個線程,線程之間相互獨立,用一個具體實現(xiàn)來說明:

public interface Consumer {
  int consume();
}
public class ComsumeThread implements Runnable {

  private Consumer consumer;

  public ComsumeThread(Consumer consumer) {
    this.consumer = consumer;
  }

  @Override
  public void run() {
    for(int i=0;i<10;i++){
      System.out.println(Thread.currentThread().getName()+" After Consume left:"+consumer.consume());
    }

  }
}
public class ConsumeClientA implements Consumer {

  private static int leftNum = 30;

  @Override
  public int consume() {
    int orgLeftNum = leftNum;
    Random random = new Random(System.currentTimeMillis());
    try {
      Thread.sleep(random.nextInt(3));
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
    orgLeftNum = orgLeftNum -1;
    leftNum = orgLeftNum;
    return leftNum;
  }

  public static void main(String[] args){
    Consumer consumer = new ConsumeClientA();
    Thread thread1 = new Thread(new ComsumeThread(consumer));
    Thread thread2 = new Thread(new ComsumeThread(consumer));
    Thread thread3 = new Thread(new ComsumeThread(consumer));

    thread1.start();
    thread2.start();
    thread3.start();
  }
}

ConsumeClientA是在沒有做任何線程安全處理,結(jié)果如下:

Thread-2 After Consume left:29
Thread-1 After Consume left:29
Thread-3 After Consume left:29
Thread-2 After Consume left:28
Thread-1 After Consume left:28
Thread-3 After Consume left:28
Thread-2 After Consume left:27
Thread-1 After Consume left:27
Thread-2 After Consume left:26
Thread-3 After Consume left:27
Thread-1 After Consume left:25
Thread-2 After Consume left:25
Thread-3 After Consume left:25
Thread-1 After Consume left:24
Thread-2 After Consume left:24
Thread-3 After Consume left:24
Thread-1 After Consume left:23
Thread-2 After Consume left:23
Thread-3 After Consume left:23
Thread-1 After Consume left:22
Thread-2 After Consume left:22
Thread-3 After Consume left:22
Thread-1 After Consume left:21
Thread-2 After Consume left:21
Thread-3 After Consume left:21
Thread-1 After Consume left:20
Thread-2 After Consume left:20
Thread-3 After Consume left:20
Thread-1 After Consume left:19
Thread-3 After Consume left:18

增加threadlocal處理,每個線程相互獨立,實現(xiàn)如下:

public class ConsumeClientB implements Consumer {
  private ThreadLocal<Integer> leftNumThreadLocal = new ThreadLocal<Integer>(){
    @Override
    protected Integer initialValue() {
      return 30;
    }
  };

  @Override
  public int consume() {
    int orgLeftNum = leftNumThreadLocal.get();
    Random random = new Random(System.currentTimeMillis());
    try {
      Thread.sleep(random.nextInt(3));
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
    orgLeftNum = orgLeftNum -1;
    leftNumThreadLocal.set(orgLeftNum);
    return leftNumThreadLocal.get();
  }

  public static void main(String[] args){
    Consumer consumer = new ConsumeClientB();
    Thread thread1 = new Thread(new ComsumeThread(consumer));
    Thread thread2 = new Thread(new ComsumeThread(consumer));
    Thread thread3 = new Thread(new ComsumeThread(consumer));

    thread1.start();
    thread2.start();
    thread3.start();
  }
}

運行的結(jié)果如下:

Thread-1 After Consume left:29
Thread-3 After Consume left:29
Thread-2 After Consume left:29
Thread-1 After Consume left:28
Thread-3 After Consume left:28
Thread-2 After Consume left:28
Thread-1 After Consume left:27
Thread-3 After Consume left:27
Thread-2 After Consume left:27
Thread-1 After Consume left:26
Thread-3 After Consume left:26
Thread-2 After Consume left:26
Thread-1 After Consume left:25
Thread-3 After Consume left:25
Thread-2 After Consume left:25
Thread-1 After Consume left:24
Thread-3 After Consume left:24
Thread-2 After Consume left:24
Thread-1 After Consume left:23
Thread-3 After Consume left:23
Thread-2 After Consume left:23
Thread-1 After Consume left:22
Thread-3 After Consume left:22
Thread-2 After Consume left:22
Thread-1 After Consume left:21
Thread-3 After Consume left:21
Thread-2 After Consume left:21
Thread-1 After Consume left:20
Thread-3 After Consume left:20
Thread-2 After Consume left:20

每個線程擁有自己的獨立變量,相互隔離實現(xiàn)線程安全。

那ThreadLocal是怎樣實現(xiàn)這種線程隔離的線程安全的呢?

從ThreadLocal源碼可以看到,真正實現(xiàn)線程隔離,與線程掛鉤的,其實是ThreadLocal.ThreadLocalMap這個實現(xiàn)類,最明顯的體現(xiàn)就在于Thread類源碼的這樣一個變量申明說明了ThreadLocal.ThreadLocalMap與Thread的關(guān)系:

ThreadLocal.ThreadLocalMap threadLocals, inheritableThreadLocals;

Thread類是包含threadLocals對象的,ThreadLocal的具體實現(xiàn)就是根據(jù)提供的get,set等接口,對當前thread的threadLocals變量進行相關(guān)操作的,如get操作代碼如下:

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

  ThreadLocal.ThreadLocalMap getMap(Thread t) {
    return t.threadLocals;
  }

可以看到,getMap()方法就是從當前thread獲取對應(yīng)的threadLocals變量,然后從這個ThreadLocal.ThreadLocalMap類型的threadLocals變量中獲取對應(yīng)線程中該ThreadLocal對象對應(yīng)的變量值。

set方法的操作也是一樣:

  public void set(T value) {
    Thread t = Thread.currentThread();
    ThreadLocal.ThreadLocalMap map = getMap(t);
    if(map != null) {
      map.set(this, value);
    } else {
      this.createMap(t, value);
    }

  }

  void createMap(Thread t, T firstValue) {
    t.threadLocals = new ThreadLocalMap(this, firstValue);
  }

static class Entry extends WeakReference<ThreadLocal> {
      Object value;

      Entry(ThreadLocal var1, Object var2) {
        super(var1);
        this.value = var2;
      }
    }

ThreadLocalMap中存的是內(nèi)部類Entry的數(shù)組,Entry是繼承WeakReference實現(xiàn),WeakReference的好處是保存對象引用,而又不干擾該對象被GC回收,線程執(zhí)行完回收threadLocals變量時不會受到Entry封裝的變量的干擾。

而且ThreadLocalMap中的key是ThreadLocal,所以一個ThreadLocal對象只能在一個Thread對象中保存一個ThreadLocal的value。

綜上,很多人說ThreadLocal的實現(xiàn)是ThreadLocalMap中存Thread對象為key,變量為value的map結(jié)構(gòu),其實是錯誤的。

感謝閱讀,希望能幫助到大家,謝謝大家對本站的支持!

相關(guān)文章

  • Java讀取properties配置文件時,出現(xiàn)中文亂碼的解決方法

    Java讀取properties配置文件時,出現(xiàn)中文亂碼的解決方法

    下面小編就為大家?guī)硪黄狫ava讀取properties配置文件時,出現(xiàn)中文亂碼的解決方法。小編覺得挺不錯的,現(xiàn)在就分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2016-11-11
  • Java利用遞歸算法實現(xiàn)查詢斐波那契數(shù)

    Java利用遞歸算法實現(xiàn)查詢斐波那契數(shù)

    今天小編就為大家分享一篇關(guān)于Java利用遞歸算法實現(xiàn)查詢斐波那契數(shù),小編覺得內(nèi)容挺不錯的,現(xiàn)在分享給大家,具有很好的參考價值,需要的朋友一起跟隨小編來看看吧
    2018-12-12
  • Java實現(xiàn)微信發(fā)紅包

    Java實現(xiàn)微信發(fā)紅包

    這篇文章主要為大家詳細介紹了Java實現(xiàn)微信發(fā)紅包,文中示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2019-12-12
  • Java用itextpdf導出PDF方法(通俗易懂)

    Java用itextpdf導出PDF方法(通俗易懂)

    因為項目需要導出PDF文件,所以去找了一下能夠生成PDF的java工具,這篇文章主要給大家介紹了關(guān)于Java用itextpdf導出PDF的相關(guān)資料,文中介紹的方法通俗易懂,需要的朋友可以參考下
    2023-07-07
  • SpringBoot異步調(diào)用方法并接收返回值

    SpringBoot異步調(diào)用方法并接收返回值

    這篇文章主要為大家詳細介紹了SpringBoot異步調(diào)用方法并接收返回值,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2019-09-09
  • Java實現(xiàn)簡單的酒店管理系統(tǒng)

    Java實現(xiàn)簡單的酒店管理系統(tǒng)

    這篇文章主要為大家詳細介紹了java實現(xiàn)酒店管理系統(tǒng),文中示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2020-07-07
  • JavaIO字符操作和對象操作示例詳解

    JavaIO字符操作和對象操作示例詳解

    這篇文章主要為大家介紹了JavaIO字符操作和對象操作示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
    2023-02-02
  • Spring Boot與Spark、Cassandra系統(tǒng)集成開發(fā)示例

    Spring Boot與Spark、Cassandra系統(tǒng)集成開發(fā)示例

    本文演示以Spark作為分析引擎,Cassandra作為數(shù)據(jù)存儲,而使用Spring Boot來開發(fā)驅(qū)動程序的示例。對spring boot 與spark cassandra集成開發(fā)示例代碼感興趣的朋友跟著腳本之家小編一起學習吧
    2018-02-02
  • Spring Boot之過濾器 Filter注入的方式解析

    Spring Boot之過濾器 Filter注入的方式解析

    這篇文章主要介紹了Spring Boot之過濾器 Filter注入的方式解析,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教
    2021-11-11
  • Java日常練習題,每天進步一點點(57)

    Java日常練習題,每天進步一點點(57)

    下面小編就為大家?guī)硪黄狫ava基礎(chǔ)的幾道練習題(分享)。小編覺得挺不錯的,現(xiàn)在就分享給大家,也給大家做個參考。一起跟隨小編過來看看吧,希望可以幫到你
    2021-08-08

最新評論