Java 中ThreadLocal類(lèi)詳解

更新時(shí)間：2016年03月26日 11:48:51 作者：趙杰A-124

什么是ThreadLocal？顧名思義它是local variable（線程局部變量）。它的功用非常簡(jiǎn)單，就是為每一個(gè)使用該變量的線程都提供一個(gè)變量值的副本，是每一個(gè)線程都可以獨(dú)立地改變自己的副本，而不會(huì)和其它線程的副本沖突。從線程的角度看，就好像每一個(gè)線程都完全擁有該變量。

ThreadLocal類(lèi)，代表一個(gè)線程局部變量，通過(guò)把數(shù)據(jù)放在ThreadLocal中，可以讓每個(gè)線程創(chuàng)建一個(gè)該變量的副本。也可以看成是線程同步的另一種方式吧，通過(guò)為每個(gè)線程創(chuàng)建一個(gè)變量的線程本地副本，從而避免并發(fā)線程同時(shí)讀寫(xiě)同一個(gè)變量資源時(shí)的沖突。

示例如下：

import java.util.Random;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

import com.sun.javafx.webkit.Accessor;

public class ThreadLocalTest {
 static class ThreadLocalVariableHolder {
  private static ThreadLocal<Integer> value = new ThreadLocal<Integer>() {
   private Random random = new Random();
   
   protected synchronized Integer initialValue() {
    return random.nextInt(10000);
   }
  };
  
  public static void increment() {
   value.set(value.get() + 1);
  }
  
  public static int get() {
   return value.get();
  }
 }
 
 static class Accessor implements Runnable{
  private final int id;
  
  public Accessor(int id) {
   this.id = id;
  }
  
  @Override
  public void run() {
   while (!Thread.currentThread().isInterrupted()) {
    ThreadLocalVariableHolder.increment();
    System.out.println(this);
    Thread.yield();
   }
  }
  
  @Override
  public String toString() {
   return "#" + id + ": " + ThreadLocalVariableHolder.get();
  }
  
 }
 
 public static void main(String[] args) {
  ExecutorService executorService = Executors.newCachedThreadPool();
  for (int i = 0; i < 5; i++) {
   executorService.execute(new Accessor(i));
  }
  try {
   TimeUnit.MICROSECONDS.sleep(1);
  } catch (InterruptedException e) {
   e.printStackTrace();
  }
  executorService.shutdownNow();
 }

}

運(yùn)行結(jié)果：

#1: 9685
#1: 9686
#2: 138
#2: 139
#2: 140
#2: 141
#0: 5255
。。。

由運(yùn)行結(jié)果可知，各線程都用于各自的Local變量，并各自讀寫(xiě)互不干擾。

ThreadLocal共提供了三個(gè)方法來(lái)操作，set,get和remove。

在Android 中的Looper，即使用了ThreadLocal來(lái)為每個(gè)線程都創(chuàng)建各自獨(dú)立的Looper對(duì)象。

public final class Looper {
 private static final String TAG = "Looper";

 // sThreadLocal.get() will return null unless you've called prepare().
 static final ThreadLocal<Looper> sThreadLocal = new ThreadLocal<Looper>();

 private static void prepare(boolean quitAllowed) {
  if (sThreadLocal.get() != null) {
   throw new RuntimeException("Only one Looper may be created per thread");
  }
  sThreadLocal.set(new Looper(quitAllowed));
 }
 
 。。。
}

當(dāng)某個(gè)線程需要自己的Looper及消息隊(duì)列時(shí)，就調(diào)用Looper.prepare()，它會(huì)為線程創(chuàng)建屬于線程的Looper對(duì)象及MessageQueue，并將Looper對(duì)象保存在ThreadLocal中。

您可能感興趣的文章: