java线程本地存储使用

    防止任务在共享资源上发生冲突的一种方式是根除对变量的共享。线程本地存储可以为使用相同变量的每个不同线程都创建不同存储。ThreadLocal该类提供了线程局部 (thread-local) 变量。这些变量不同于它们的普通对应物，因为访问某个变量（通过其 get 或 set 方法）的每个线程都有自己的局部变量，它独立于变量的初始化副本。ThreadLocal 实例通常是类中的 private static 字段，它们希望将状态与某一个线程（例如，用户 ID 或事务 ID）相关联。
    例如，以下类生成对每个线程唯一的局部标识符。线程 ID 是在第一次调用 UniqueThreadIdGenerator.getCurrentThreadId() 时分配的，在后续调用中不会更改。

package concurrent;
import java.util.concurrent.atomic.AtomicInteger;
public class UniqueThreadIdGenerator {

	private static final AtomicInteger uniqueId = new AtomicInteger(0);

	private static final ThreadLocal<Integer> uniqueNum = new ThreadLocal<Integer>() {
		@Override
		protected Integer initialValue() {
			return uniqueId.getAndIncrement();
		}
	};

	public static int getCurrentThreadId() {
		return uniqueNum.get();
	}

	public static void main(String[] args) {
		for (int i = 0; i < 5; i++) {
			new Thread(new Runnable() {
				@Override
				public void run() {
				System.out.println(UniqueThreadIdGenerator
							.getCurrentThreadId());
				}
			}).start();
		}

	}
} // UniqueThreadIdGenerator

输出结果：
0
2
4
3
1
    每个线程都保持对其线程局部变量副本的隐式引用，只要线程是活动的并且 ThreadLocal 实例是可访问的；在线程消失之后，其线程局部实例的所有副本都会被垃圾回收（除非存在对这些副本的其他引用）。
    下面演示了创建和管理本地存储由ThreadLocal实现的一个简单实例。get返回与线程相关联的对象副本，set会将参数插入到为其线程存储的对象中，并返回原有的对象。

package concurrency;

//: concurrency/ThreadLocalVariableHolder.java
// Automatically giving each thread its own storage.
import java.util.concurrent.*;
import java.util.*;

class Accessor implements Runnable {
	private final int id;

	public Accessor(int idn) {
		id = idn;
	}

	public void run() {
		while (!Thread.currentThread().isInterrupted()) {
			ThreadLocalVariableHolder.increment();
			System.out.println(this);
			Thread.yield();
		}
	}

	public String toString() {
		return "#" + id + ": " + ThreadLocalVariableHolder.get();
	}
}

public class ThreadLocalVariableHolder {
	private static ThreadLocal<Integer> value = new ThreadLocal<Integer>() {
		private Random rand = new Random(47);

		// initialValue返回此线程局部变量的当前线程的“初始值”。线程第一//次使用 get()
		// 方法访问变量时将调用此方法，但如果线程之前调用了 set(T)
		// 方法，则不会对该线程再调用 initialValue 方法。通常，此方法对每//个线程最多调用一次，但如果在调用 get() 后又调用了
		// remove()，则可能再次调用此方法。
		// 该实现返回 null；如果程序员希望线程局部变量具有 null 以外的
//值，则必须为 ThreadLocal
		// 创建子类，并重写此方法。通常将使用匿名内部类完成此操作
		@Override
		protected synchronized Integer initialValue() {
			return rand.nextInt(10000);
		}
	};

	public static void increment() {
		value.set(value.get() + 1);
	}

	public static int get() {
		return value.get();
	}

	public static void main(String[] args) throws Exception {
		ExecutorService exec = Executors.newCachedThreadPool();
		for (int i = 0; i < 5; i++)
			exec.execute(new Accessor(i));
		TimeUnit.SECONDS.sleep(1); // Run for a while
		exec.shutdownNow(); // All Accessors will quit
	}
}

输出结果：
#1: 556
#3: 962
#0: 9259
#2: 1862
#4: 6694
欢迎交流。