[java] Java의 ThreadLocal은 어떻게 구현됩니까?

을 구현한다고 가정 해 보겠습니다. ThreadLocal스레드별로 어떻게 만들까요? 물론 가장 간단한 방법은 Thread 클래스에 비 정적 필드를 만드는 것 threadLocals입니다. 각 스레드는 스레드 인스턴스로 표시되기 때문에 threadLocals모든 스레드에서도 다를 수 있습니다. 그리고 이것은 또한 Java가하는 일입니다.

/* ThreadLocal values pertaining to this thread. This map is maintained
* by the ThreadLocal class. */
ThreadLocal.ThreadLocalMap threadLocals = null;

여기는 무엇입니까 ThreadLocal.ThreadLocalMap? threadLocals스레드에 대한 만 있기 때문에 단순히 스레드 threadLocals로 간주 하면 ThreadLocal(예 : threadLocals를로 정의 Integer) ThreadLocal특정 스레드에 대해 하나만 갖게됩니다 . ThreadLocal스레드에 대해 여러 변수를 원하면 어떻게 합니까? 가장 간단한 방법은 만드는 것입니다 의를threadLocalsHashMapkey 각 항목의는의 이름입니다 ThreadLocal변수, 그리고 value각 항목의는의 값이 ThreadLocal변수입니다. 좀 헷갈 리나요? 두 개의 스레드 t1와 t2. 생성자 Runnable의 매개 변수 와 동일한 인스턴스를 취하고 Thread둘 다 및 ThreadLocal라는 두 개의 변수를 갖습니다 . 이게 어떤지.tlAtlb

t1.tlA

+-----+-------+
| Key | Value |
+-----+-------+
| tlA |     0 |
| tlB |     1 |
+-----+-------+

t2.tlB

+-----+-------+
| Key | Value |
+-----+-------+
| tlA |     2 |
| tlB |     3 |
+-----+-------+

값은 내가 구성한 것입니다.

이제 완벽 해 보입니다. 그러나 무엇입니까ThreadLocal.ThreadLocalMap 입니까? 왜 그냥 사용하지 않았 HashMap습니까? 문제를 해결하기 위해 클래스 의 set(T value)메소드를 통해 값을 설정하면 어떻게되는지 살펴 보겠습니다 ThreadLocal.

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

getMap(t) 단순히 반환 t.threadLocals . 때문에이 t.threadLocals에 initilized 된 null우리가 입력 할 수 있도록, createMap(t, value)첫째 :

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

그것은 새로운 창조 ThreadLocalMap현재 ThreadLocal인스턴스와 설정할 값을 사용하여 인스턴스를 . 의 어떤 보자 ThreadLocalMap는의 사실 부분에있어,처럼 ThreadLocal클래스

static class ThreadLocalMap {

    /**
     * The entries in this hash map extend WeakReference, using
     * its main ref field as the key (which is always a
     * ThreadLocal object).  Note that null keys (i.e. entry.get()
     * == null) mean that the key is no longer referenced, so the
     * entry can be expunged from table.  Such entries are referred to
     * as "stale entries" in the code that follows.
     */
    static class Entry extends WeakReference<ThreadLocal<?>> {
        /** The value associated with this ThreadLocal. */
        Object value;

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

    ...

    /**
     * Construct a new map initially containing (firstKey, firstValue).
     * ThreadLocalMaps are constructed lazily, so we only create
     * one when we have at least one entry to put in it.
     */
    ThreadLocalMap(ThreadLocal<?> firstKey, Object firstValue) {
        table = new Entry[INITIAL_CAPACITY];
        int i = firstKey.threadLocalHashCode & (INITIAL_CAPACITY - 1);
        table[i] = new Entry(firstKey, firstValue);
        size = 1;
        setThreshold(INITIAL_CAPACITY);
    }

    ...

}

ThreadLocalMap클래스 의 핵심 부분 Entry class은 WeakReference. 현재 스레드가 종료되면 자동으로 가비지 수집됩니다. 이것이 ThreadLocalMap단순한 HashMap. 그것은 현재를 통과ThreadLocal 값과 해당 값을 Entry클래스 의 매개 변수로 하므로 값을 얻으려면 클래스 table의 인스턴스 인 에서 가져올 수 있습니다 Entry.

public T get() {
    Thread t = Thread.currentThread();
    ThreadLocalMap map = getMap(t);
    if (map != null) {
        ThreadLocalMap.Entry e = map.getEntry(this);
        if (e != null) {
            @SuppressWarnings("unchecked")
            T result = (T)e.value;
            return result;
        }
    }
    return setInitialValue();
}

이것은 전체 그림에서와 같습니다.