ViewVC Help

View File | Revision Log | Show Annotations | Download File | Root Listing

root/jsr166/jsr166/src/extra166y/CustomConcurrentHashMap.java

Comparing jsr166/src/extra166y/CustomConcurrentHashMap.java (file contents):
Revision 1.7 by dl, Mon Nov 2 11:47:36 2009 UTC vs.
Revision 1.12 by jsr166, Thu Sep 16 03:57:13 2010 UTC

#	Line 53 | Line 53 | import sun.misc.Unsafe;
53		*     (STRONG,
54		*      new Equivalence<Person>() {
55		*          public boolean equal(Person k, Object x) {
56	<	*            return x instanceOf Person && k.name.equals(((Person)x).name);
56	>	*            return x instanceof Person && k.name.equals(((Person)x).name);
57		*          }
58		*          public int hash(Object x) {
59	<	*             return (x instanceOf Person)? ((Person)x).name.hashCode() : 0;
59	>	*             return (x instanceof Person)? ((Person)x).name.hashCode() : 0;
60		*          }
61		*        },
62		*      STRONG, EQUALS, 0);
#	Line 537 | Line 537 | public class CustomConcurrentHashMap<K,
537		while (capacity < sc)
538		capacity <<= 1;
539		if (capacity > MAX_SEGMENT_CAPACITY)
540	<	capacity = MAX_SEGMENT_CAPACITY;
540	>	capacity = MAX_SEGMENT_CAPACITY;
541		this.initialSegmentCapacity = capacity;
542		}
543		this.segments = (Segment[])new Segment[NSEGMENTS];
#	Line 642 | Line 642 | public class CustomConcurrentHashMap<K,
642		int index = (hash >>> SEGMENT_SHIFT) & SEGMENT_MASK;
643		Segment seg = segs[index];
644		if (seg == null) {
645	<	synchronized(segs) {
645	>	synchronized (segs) {
646		seg = segs[index];
647		if (seg == null) {
648		seg = new Segment();
#	Line 2101 | Line 2101 | public class CustomConcurrentHashMap<K,
2101		final int locator;
2102		final CustomConcurrentHashMap cchm;
2103		WeakKeyNode(int locator, Object key, CustomConcurrentHashMap cchm) {
2104	<	super(key);
2104	>	super(key, getReclamationQueue());
2105		this.locator = locator;
2106		this.cchm = cchm;
2107		}
#	Line 2396 | Line 2396 | public class CustomConcurrentHashMap<K,
2396		final int locator;
2397		final CustomConcurrentHashMap cchm;
2398		SoftKeyNode(int locator, Object key, CustomConcurrentHashMap cchm) {
2399	<	super(key);
2399	>	super(key, getReclamationQueue());
2400		this.locator = locator;
2401		this.cchm = cchm;
2402		}
#	Line 2984 | Line 2984 | public class CustomConcurrentHashMap<K,
2984
2985		// Temporary Unsafe mechanics for preliminary release
2986
2987	<	static final Unsafe _unsafe;
2987	>	static final Unsafe UNSAFE;
2988		static final long tableBase;
2989		static final int tableShift;
2990		static final long segmentsBase;
#	Line 3015 | Line 3015 | public class CustomConcurrentHashMap<K,
3015
3016		static {
3017		try {
3018	<	_unsafe = getUnsafe();
3019	<	tableBase = _unsafe.arrayBaseOffset(Node[].class);
3020	<	int s = _unsafe.arrayIndexScale(Node[].class);
3018	>	UNSAFE = getUnsafe();
3019	>	tableBase = UNSAFE.arrayBaseOffset(Node[].class);
3020	>	int s = UNSAFE.arrayIndexScale(Node[].class);
3021		if ((s & (s-1)) != 0)
3022		throw new Error("data type scale not a power of two");
3023		tableShift = 31 - Integer.numberOfLeadingZeros(s);
3024	<	segmentsBase = _unsafe.arrayBaseOffset(Segment[].class);
3025	<	s = _unsafe.arrayIndexScale(Segment[].class);
3024	>	segmentsBase = UNSAFE.arrayBaseOffset(Segment[].class);
3025	>	s = UNSAFE.arrayIndexScale(Segment[].class);
3026		if ((s & (s-1)) != 0)
3027		throw new Error("data type scale not a power of two");
3028		segmentsShift = 31 - Integer.numberOfLeadingZeros(s);
#	Line 3035 | Line 3035 | public class CustomConcurrentHashMap<K,
3035		static final  void storeNode(Node[] table,
3036		int i, Node r) {
3037		long nodeOffset = ((long) i << tableShift) + tableBase;
3038	<	_unsafe.putOrderedObject(table, nodeOffset, r);
3038	>	UNSAFE.putOrderedObject(table, nodeOffset, r);
3039		}
3040
3041		static final  void storeSegment(Segment[] segs,
3042		int i, Segment s) {
3043		long segmentOffset = ((long) i << segmentsShift) + segmentsBase;
3044	<	_unsafe.putOrderedObject(segs, segmentOffset, s);
3044	>	UNSAFE.putOrderedObject(segs, segmentOffset, s);
3045		}
3046
3047

Diff Legend

–	Removed lines
+	Added lines
<	Changed lines
>	Changed lines