ConcurrentHashMap 在累加鍵值對(duì)個(gè)數(shù)的 addCount 函數(shù)中，使用 ThreadLocalRandom.getProbe() 得到線程的探針哈希值。

在這里，這個(gè)探針哈希值的作用是哈希線程，盡量避免線程爭(zhēng)用同一數(shù)組元素。探針哈希值和 map 里使用的哈希值的區(qū)別是，當(dāng)線程發(fā)生數(shù)組元素爭(zhēng)用后，可以改變線程的探針哈希值，讓線程去使用另一個(gè)數(shù)組元素，而 map 中 key 對(duì)象的哈希值，由于有定位 value 的需求，所以它是一定不能變的。

那么這個(gè)探針哈希值是在哪計(jì)算的呢？帶著這個(gè)問題我們繼續(xù)往下看。
ThreadLocalRandom.getProbe() 方法如下：

/*** Returns the probe value for the current thread without forcing* initialization. Note that invoking ThreadLocalRandom.current()* can be used to force initialization on zero return.*/static final int getProbe() {return UNSAFE.getInt(Thread.currentThread(), PROBE);}

PROBE 是什么？

// Unsafe mechanicsprivate static final sun.misc.Unsafe UNSAFE;...private static final long PROBE;...static {try {UNSAFE = sun.misc.Unsafe.getUnsafe();Class<?> tk = Thread.class;...PROBE = UNSAFE.objectFieldOffset(tk.getDeclaredField("threadLocalRandomProbe"));...} catch (Exception e) {throw new Error(e);}}

可以看到 PROBE 表示的是 Thread 類 threadLocalRandomProbe 字段的偏移量。
所以 getProbe 方法的功能就是簡(jiǎn)單的返回當(dāng)前線程 threadLocalRandomProbe 字段的值。

接著去 Thread 類看看這個(gè) threadLocalRandomProbe 字段，

/** Probe hash value; nonzero if threadLocalRandomSeed initialized */@sun.misc.Contended("tlr")int threadLocalRandomProbe;

Thread 類僅僅是定義了這個(gè)字段，并沒有將其初始化，其初始化工作由 ThreadLocalRandom 類來做。
ThreadLocalRandom 類的 localInit 方法完成初始化工作，

/*** Initialize Thread fields for the current thread. Called only* when Thread.threadLocalRandomProbe is zero, indicating that a* thread local seed value needs to be generated. Note that even* though the initialization is purely thread-local, we need to* rely on (static) atomic generators to initialize the values.*/static final void localInit() {// probeGenerator 是一個(gè) AtomicInteger 類型// PROBE_INCREMENT 是一個(gè)靜態(tài)常量，值為 0x9e3779b9int p = probeGenerator.addAndGet(PROBE_INCREMENT);int probe = (p == 0) ? 1 : p; // skip 0long seed = mix64(seeder.getAndAdd(SEEDER_INCREMENT));Thread t = Thread.currentThread(); // 獲取當(dāng)前線程// 通過 Unsafe 對(duì)象初始化當(dāng)前線程的 threadLocalRandomSeed 字段UNSAFE.putLong(t, SEED, seed);// 通過 Unsafe 對(duì)象初始化當(dāng)前線程的 threadLocalRandomProbe 字段UNSAFE.putInt(t, PROBE, probe);}

SEED 和 PROBE 類似，它表示的是 Thread 類 threadLocalRandomSeed 字段的偏移量。

在 ThreadLocalRandom 類的這個(gè) localInit 方法里，同時(shí)初始化了當(dāng)前線程的 threadLocalRandomSeed 字段和 threadLocalRandomProbe 字段。

所以在 Thread 類 threadLocalRandomProbe 字段上的注釋中說：nonzero if threadLocalRandomSeed initialized。就是說如果 threadLocalRandomSeed 字段被初始化了，threadLocalRandomProbe 字段就非零。因?yàn)樗鼈z是同時(shí)被初始化的。

除此之外，也可以通過 ThreadLocalRandom 類的 advanceProbe 方法更改當(dāng)前線程 threadLocalRandomProbe 的值。

/*** Pseudo-randomly advances and records the given probe value for the* given thread.*/static final int advanceProbe(int probe) {probe ^= probe << 13; // xorshiftprobe ^= probe >>> 17;probe ^= probe << 5;UNSAFE.putInt(Thread.currentThread(), PROBE, probe);return probe;}

ConcurrentHashMap 里的 fullAddCount 方法會(huì)調(diào)用 ThreadLocalRandom.localInit() 初始化當(dāng)前線程的探針哈希值；當(dāng)發(fā)生線程爭(zhēng)用后，也會(huì)調(diào)用 ThreadLocalRandom.advanceProbe(h) 更改當(dāng)前線程的探針哈希值，

private final void fullAddCount(long x, boolean wasUncontended) {int h;if ((h = ThreadLocalRandom.getProbe()) == 0) {ThreadLocalRandom.localInit(); // force initializationh = ThreadLocalRandom.getProbe();wasUncontended = true;}...h = ThreadLocalRandom.advanceProbe(h);...}

總結(jié)

以上是生活随笔為你收集整理的关于 ConcurrentHashMap 1.8 中的线程探针哈希的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。