Java多線程編程之ThreadLocal線程規模內的同享變量

Java多線程編程之ThreadLocal線程規模內的同享變量。本站提示廣大學習愛好者：（Java多線程編程之ThreadLocal線程規模內的同享變量）文章只能為提供參考，不一定能成為您想要的結果。以下是Java多線程編程之ThreadLocal線程規模內的同享變量正文

模仿ThreadLocal類完成：線程規模內的同享變量，每一個線程只能拜訪他本身的，不克不及拜訪其余線程。

package com.ljq.test.thread;

import java.util.HashMap;
import java.util.Map;
import java.util.Random;

/**
 * 線程規模內的同享變量
 * 
 * 三個模塊同享數據，主線程模塊和AB模塊
 * 
 * @author Administrator
 * 
 */
public class ThreadScopeShareData {
  // 預備同享的數據
  private static int data = 0;
  // 寄存各個線程對應的數據
  private static Map<Thread, Integer> threadData = new HashMap<Thread, Integer>();

  public static void main(String[] args) {
    // 啟動兩個線程
    for (int i = 0; i < 2; i++) {
      new Thread(new Runnable() {
        @Override
        public void run() {
          // 如今以後線程中修正一下數據,給出修正信息
          int data = new Random().nextInt();
          // 將線程信息和對應數據存儲起來
          threadData.put(Thread.currentThread(), data);
          System.out.println(Thread.currentThread().getName() + " has put data :" + data);
          new A().get();
          new B().get();
        }
      }).start();
    }
  }

  static class A {
    public void get() {
      int data = threadData.get(Thread.currentThread());
      System.out.println("A from " + Thread.currentThread().getName()
          + " get data :" + data);
    }
  }

  static class B {
    public void get() {
      int data = threadData.get(Thread.currentThread());
      System.out.println("B from " + Thread.currentThread().getName()
          + " get data :" + data);
    }
  }
}

運轉成果：

ThreadLocal的感化和目標：
用於完成線程內的數據同享，即關於雷同的法式代碼，多個模塊在統一個線程中運轉時要同享一份數據，而在別的線程中運轉時又同享別的一份數據。

每一個線程挪用全局ThreadLocal對象的set辦法，就相當於往其外部的map中增長一筆記錄，key分離是各自的線程，value是各自的set辦法傳出來的值。在線程停止時可以挪用ThreadLocal.clear()辦法，如許會更快釋放內存，不挪用也能夠，由於線程停止後也能夠主動釋放相干的ThreadLocal變量。

ThreadLocal的運用場景：
定單處置包括一系列操作：削減庫存量、增長一條流水台賬、修正總賬，這幾個操作要在統一個事務中完成，平日也即統一個線程中停止處置，假如累加公司應收款的操作掉敗了，則應當把後面的操作回滾，不然，提交一切操作，這請求這些操作應用雷同的數據庫銜接對象，而這些操作的代碼分離位於分歧的模塊類中。

銀行轉賬包括一系列操作： 把轉出帳戶的余額削減，把轉入帳戶的余額增長，這兩個操作要在統一個事務中完成，它們必需應用雷同的數據庫銜接對象，轉入和轉出操作的代碼分離是兩個分歧的帳戶對象的辦法。

例如Strut2的ActionContext，統一段代碼被分歧的線程挪用運轉時，該代碼操作的數據是每一個線程各自的狀況和數據，關於分歧的線程來講，getContext辦法拿到的對象都不雷同，對統一個線程來講，不論挪用getContext辦法若干次和在哪一個模塊中getContext辦法，拿到的都是統一個。

試驗案例：界說一個全局同享的ThreadLocal變量，然後啟動多個線程向該ThreadLocal變量中存儲一個隨機值，接著各個線程挪用別的其他多個類的辦法，這多個類的辦法中讀取這個ThreadLocal變量的值，便可以看到多個類在統一個線程中同享統一份數據。

完成對ThreadLocal變量的封裝，讓外界不要直接操作ThreadLocal變量。
對根本類型的數據的封裝，這類運用絕對很少見。
對對象類型的數據的封裝，比擬罕見，即讓某個類針對分歧線程分離創立一個自力的實例對象。

package com.ljq.test.thread;
 
import java.util.Random;
 
/**
 * ThreadLocal類及運用技能
 *
 * 將線程規模內同享數據停止封裝，封裝到一個零丁的數據類中，供給設置獲得辦法
 * 將該類單例化，供給獲得實例對象的辦法，獲得到的實例對象是曾經封裝好確當前哨程規模內的對象
 */
public class ThreadLocalTest {
 
  private static ThreadLocal<Integer> x = new ThreadLocal<Integer>();
  //private static ThreadLocal<MyThreadScopeData> myThreadScopeData = new ThreadLocal<MyThreadScopeData>();
  public static void main(String[] args) {
    for(int i=0;i<2;i++){
      new Thread(new Runnable(){
        @Override
        public void run() {
          int data = new Random().nextInt();
          System.out.println(Thread.currentThread().getName() + " has put data :" + data);
          x.set(data);
           
          /*         
          MyThreadScopeData myData = new MyThreadScopeData();
          myData.setName("name" + data);
          myData.setAge(data);
          myThreadScopeData.set(myData);
          */
          MyThreadScopeData.getThreadInstance().setName("name" + data);
          MyThreadScopeData.getThreadInstance().setAge(data);
          new A().get();
          new B().get();
        }
      }).start();
    }
  }
   
  //應用獲得到的線程規模內的對象實例挪用響應辦法
  static class A{
    public void get(){
      int data = x.get();
      System.out.println("A from " + Thread.currentThread().getName() + " get data :" + data);
       
      /*     
      MyThreadScopeData myData = myThreadScopeData.get();
      System.out.println("A from " + Thread.currentThread().getName()
          + " getMyData: " + myData.getName() + "," + myData.getAge());
      */
      MyThreadScopeData myData = MyThreadScopeData.getThreadInstance();
      System.out.println("A from " + Thread.currentThread().getName()
          + " getMyData: " + myData.getName() + "," + myData.getAge());
    }
  }
   
  //應用獲得到的線程規模內的對象實例挪用響應辦法
  static class B{
    public void get(){
      int data = x.get();    
      System.out.println("B from " + Thread.currentThread().getName() + " get data :" + data);
       
      MyThreadScopeData myData = MyThreadScopeData.getThreadInstance();
      System.out.println("B from " + Thread.currentThread().getName()
          + " getMyData: " + myData.getName() + "," + myData.getAge());     
    }   
  }
}
 
 
class MyThreadScopeData {
 
  // 單例
  private MyThreadScopeData() {
  }
 
  // 供給獲得實例辦法，不加synchronized症結字表現線程各拿各自的數據，互不攪擾
  public static/* synchronized */MyThreadScopeData getThreadInstance() {
    // 從以後線程規模內數據集中獲得實例對象
    MyThreadScopeData instance = map.get();
    if (instance == null) {
      instance = new MyThreadScopeData();
      map.set(instance);
    }
    return instance;
  }
 
  // 將實例對象存入以後線程規模內數據集中
  private static ThreadLocal<MyThreadScopeData> map = new ThreadLocal<MyThreadScopeData>();
 
  private String name;
  private int age;
 
  public String getName() {
    return name;
  }
 
  public void setName(String name) {
    this.name = name;
  }
 
  public int getAge() {
    return age;
  }
 
  public void setAge(int age) {
    this.age = age;
  }
}