1. /**
2. * 存放Cell的hash表，大小为2的幂。
3. */
4. transient volatile Cell[] cells;
5. /**
6. * 基础值，没有竞争时会使用(更新)这个值，同时做为初始化竞争失败的回退方案。
7. * 原子更新。
8. */
9. transient volatile long base;
10. /**
11. * 自旋锁，通过CAS操作加锁，用于保护创建或者扩展Cell表。
12. */
13. transient volatile int cellsBusy;

1. @sun.misc.Contended
2. static final class Cell {
3. volatile long value;
4. Cell(long x) { value = x; }
5. final boolean cas(long cmp, long val) {
6. return UNSAFE.compareAndSwapLong(this, valueOffset, cmp, val);
7. }
8. // Unsafe mechanics
9. private static final sun.misc.Unsafe UNSAFE;
10. private static final long valueOffset;
11. static {
12. try {
13. UNSAFE = sun.misc.Unsafe.getUnsafe();
14. Class<?> ak = Cell.class;
15. valueOffset = UNSAFE.objectFieldOffset
16. (ak.getDeclaredField("value"));
17. } catch (Exception e) {
18. throw new Error(e);
19. }
20. }
21. }

• Striped64主要提供了longAccumulate和doubleAccumulate方法来支持子类，先看下longAccumulate：

看下longAccumulate中使用到的一些方法：

1. final void doubleAccumulate(double x, DoubleBinaryOperator fn,
2. boolean wasUncontended) {
3. int h;
4. if ((h = getProbe()) == 0) {
5. ThreadLocalRandom.current(); // force initialization
6. h = getProbe();
7. wasUncontended = true;
8. }
9. boolean collide = false;                // True if last slot nonempty
10. for (;;) {
11. Cell[] as; Cell a; int n; long v;
12. if ((as = cells) != null && (n = as.length) > 0) {
13. if ((a = as[(n - 1) & h]) == null) {
14. if (cellsBusy == 0) {       // Try to attach new Cell
15. Cell r = new Cell(Double.doubleToRawLongBits(x));
16. if (cellsBusy == 0 && casCellsBusy()) {
17. boolean created = false;
18. try {               // Recheck under lock
19. Cell[] rs; int m, j;
20. if ((rs = cells) != null &&
21. (m = rs.length) > 0 &&
22. rs[j = (m - 1) & h] == null) {
23. rs[j] = r;
24. created = true;
25. }
26. } finally {
27. cellsBusy = 0;
28. }
29. if (created)
30. break;
31. continue;           // Slot is now non-empty
32. }
33. }
34. collide = false;
35. }
36. else if (!wasUncontended)       // CAS already known to fail
37. wasUncontended = true;      // Continue after rehash
38. else if (a.cas(v = a.value,
39. ((fn == null) ?
40. Double.doubleToRawLongBits
41. (Double.longBitsToDouble(v) + x) :
42. Double.doubleToRawLongBits
43. (fn.applyAsDouble
44. (Double.longBitsToDouble(v), x)))))
45. break;
46. else if (n >= NCPU || cells != as)
47. collide = false;            // At max size or stale
48. else if (!collide)
49. collide = true;
50. else if (cellsBusy == 0 && casCellsBusy()) {
51. try {
52. if (cells == as) {      // Expand table unless stale
53. Cell[] rs = new Cell[n << 1];
54. for (int i = 0; i < n; ++i)
55. rs[i] = as[i];
56. cells = rs;
57. }
58. } finally {
59. cellsBusy = 0;
60. }
61. collide = false;
62. continue;                   // Retry with expanded table
63. }
64. h = advanceProbe(h);
65. }
66. else if (cellsBusy == 0 && cells == as && casCellsBusy()) {
67. boolean init = false;
68. try {                           // Initialize table
69. if (cells == as) {
70. Cell[] rs = new Cell[2];
71. rs[h & 1] = new Cell(Double.doubleToRawLongBits(x));
72. cells = rs;
73. init = true;
74. }
75. } finally {
76. cellsBusy = 0;
77. }
78. if (init)
79. break;
80. }
81. else if (casBase(v = base,
82. ((fn == null) ?
83. Double.doubleToRawLongBits
84. (Double.longBitsToDouble(v) + x) :
85. Double.doubleToRawLongBits
86. (fn.applyAsDouble
87. (Double.longBitsToDouble(v), x)))))
88. break;                          // Fall back on using base
89. }
90. }