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.11 by jsr166, Wed Sep 1 23:26:57 2010 UTC vs.
Revision 1.32 by jsr166, Tue Feb 5 19:54:06 2013 UTC

#	Line 1 | Line 1
1		/*
2		* Written by Doug Lea with assistance from members of JCP JSR-166
3		* Expert Group and released to the public domain, as explained at
4	<	* http://creativecommons.org/licenses/publicdomain
4	>	* http://creativecommons.org/publicdomain/zero/1.0/
5		*/
6
7		package extra166y;
#	Line 25 | Line 25 | import sun.misc.Unsafe;
25		*   <li> {@linkplain SoftReference Soft}, {@linkplain
26		*        WeakReference weak} or strong (regular) keys and values.
27		*
28	<	*   <li> User-definable <code>MappingFunctions</code> that may be
28	>	*   <li> User-definable {@code MappingFunctions} that may be
29		*        used in method {@link
30		*        CustomConcurrentHashMap#computeIfAbsent} to atomically
31		*        establish a computed value, along with
32	<	*        <code>RemappingFunctions</code> that can be used in method
32	>	*        {@code RemappingFunctions} that can be used in method
33		*        {@link CustomConcurrentHashMap#compute} to atomically
34		*        replace values.
35		*
36	<	*    <li>Factory methods returning specialized forms for <tt>int</tt>
36	>	*    <li>Factory methods returning specialized forms for {@code int}
37		*        keys and/or values, that may be more space-efficient
38		*
39		* </ul>
#	Line 56 | Line 56 | import sun.misc.Unsafe;
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 72 | Line 72 | import sun.misc.Unsafe;
72		*
73		* <p>This class also includes nested class {@link KeySet}
74		* that provides space-efficient Set views of maps, also supporting
75	<	* method <code>intern</code>, which may be of use in canonicalizing
75	>	* method {@code intern}, which may be of use in canonicalizing
76		* elements.
77		*
78		* <p>When used with (Weak or Soft) Reference keys and/or values,
79	<	* elements that have asynchronously become <code>null</code> are
79	>	* elements that have asynchronously become {@code null} are
80		* treated as absent from the map and (eventually) removed from maps
81		* via a background thread common across all maps. Because of the
82		* potential for asynchronous clearing of References, methods such as
83	<	* <code>containsValue</code> have weaker guarantees than you might
83	>	* {@code containsValue} have weaker guarantees than you might
84		* expect even in the absence of other explicitly concurrent
85	<	* operations. For example <code>containsValue(value)</code> may
86	<	* return true even if <code>value</code> is no longer available upon
85	>	* operations. For example {@code containsValue(value)} may
86	>	* return true even if {@code value} is no longer available upon
87		* return from the method.
88		*
89		* <p>When Equivalences other than equality are used, the returned
90	<	* collections may violate the specifications of <tt>Map</tt> and/or
91	<	* <tt>Set</tt> interfaces, which mandate the use of the
92	<	* <tt>equals</tt> method when comparing objects.  The methods of this
90	>	* collections may violate the specifications of {@code Map} and/or
91	>	* {@code Set} interfaces, which mandate the use of the
92	>	* {@code equals} method when comparing objects.  The methods of this
93		* class otherwise have properties similar to those of {@link
94		* java.util.ConcurrentHashMap} under its default settings.  To
95		* adaptively maintain semantics and performance under varying
#	Line 165 | Line 165 | public class CustomConcurrentHashMap<K,
165		* An object performing equality comparisons, along with a hash
166		* function consistent with this comparison.  The type signatures
167		* of the methods of this interface reflect those of {@link
168	<	* java.util.Map}: While only elements of <code>K</code> may be
169	<	* entered into a Map, any <code>Object</code> may be tested for
168	>	* java.util.Map}: While only elements of {@code K} may be
169	>	* entered into a Map, any {@code Object} may be tested for
170		* membership. Note that the performance of hash maps is heavily
171		* dependent on the quality of hash functions.
172		*/
#	Line 224 | Line 224 | public class CustomConcurrentHashMap<K,
224
225		/**
226		* A function computing a mapping from the given key to a value,
227	<	*  or <code>null</code> if there is no mapping.
227	>	* or {@code null} if there is no mapping.
228		*/
229		public static interface MappingFunction<K, V> {
230		/**
#	Line 236 | Line 236 | public class CustomConcurrentHashMap<K,
236		* simple. The most common usage is to construct a new object
237		* serving as an initial mapped value.
238		*
239	<	* @param key the (nonnull) key
239	>	* @param key the (non-null) key
240		* @return a value, or null if none
241		*/
242		V map(K key);
#	Line 244 | Line 244 | public class CustomConcurrentHashMap<K,
244
245		/**
246		* A function computing a new mapping from the given key and its
247	<	* current value to a new value, or <code>null</code> if there is
248	<	* no mapping
247	>	* current value to a new value, or {@code null} if there is
248	>	* no mapping.
249		*/
250		public static interface RemappingFunction<K, V> {
251		/**
#	Line 320 | Line 320 | public class CustomConcurrentHashMap<K,
320		* Returns the value established during the creation of this
321		* node or, if since updated, the value set by the most
322		* recent call to setValue, or throws an exception if
323	<	* value could not be computed
323	>	* value could not be computed.
324		* @return the value
325		* @throws RuntimeException or Error if computeValue failed
326		*/
#	Line 344 | Line 344 | public class CustomConcurrentHashMap<K,
344		* Records the linkage to be returned by the next call to getLinkage.
345		* @param linkage the linkage
346		*/
347	<	void setLinkage(Node r);
347	>	void setLinkage(Node linkage);
348		}
349
350		/**
351		* Each Segment holds a count and table corresponding to a segment
352		* of the table. This class contains only those methods for
353		* directly assigning these fields, which must only be called
354	<	* while holding locks
354	>	* while holding locks.
355		*/
356		static final class Segment extends ReentrantLock {
357		volatile Node[] table;
#	Line 386 | Line 386 | public class CustomConcurrentHashMap<K,
386		}
387
388		/**
389	<	* See the similar code in ConcurrentHashMap for explanation
389	>	* See the similar code in ConcurrentHashMap for explanation.
390		*/
391		final Node[] resizeTable(CustomConcurrentHashMap cchm) {
392		Node[] oldTable = table;
393		if (oldTable == null)
394	<	return table = (Node[])
395	<	new Node[cchm.initialSegmentCapacity];
394	>	return table = new Node[cchm.initialSegmentCapacity];
395
396		int oldCapacity = oldTable.length;
397		if (oldCapacity >= MAX_SEGMENT_CAPACITY)
398		return oldTable;
399	<	Node[] newTable =
401	<	(Node[])new Node[oldCapacity<<1];
399	>	Node[] newTable = new Node[oldCapacity<<1];
400		int sizeMask = newTable.length - 1;
401		NodeFactory fac = cchm.factory;
402		for (int i = 0; i < oldCapacity ; i++) {
#	Line 540 | Line 538 | public class CustomConcurrentHashMap<K,
538		capacity = MAX_SEGMENT_CAPACITY;
539		this.initialSegmentCapacity = capacity;
540		}
541	<	this.segments = (Segment[])new Segment[NSEGMENTS];
541	>	this.segments = new Segment[NSEGMENTS];
542		}
543
544		/**
545	<	* Creates a new CustomConcurrentHashMap with the given parameters
545	>	* Creates a new CustomConcurrentHashMap with the given parameters.
546		* @param keyStrength the strength for keys
547		* @param keyEquivalence the Equivalence to use for keys
548		* @param valueStrength the strength for values
#	Line 573 | Line 571 | public class CustomConcurrentHashMap<K,
571
572		/**
573		* Returns a new map using Integer keys and the given value
574	<	* parameters
574	>	* parameters.
575		* @param valueStrength the strength for values
576		* @param valueEquivalence the Equivalence to use for values
577		* @param expectedSize an estimate of the number of elements
#	Line 591 | Line 589 | public class CustomConcurrentHashMap<K,
589		}
590
591		/**
592	<	* Returns a new map using the given key parameters and Integer values
592	>	* Returns a new map using the given key parameters and Integer values.
593		* @param keyStrength the strength for keys
594		* @param keyEquivalence the Equivalence to use for keys
595		* @param expectedSize an estimate of the number of elements
#	Line 609 | Line 607 | public class CustomConcurrentHashMap<K,
607		}
608
609		/**
610	<	* Returns a new map using Integer keys and values
610	>	* Returns a new map using Integer keys and values.
611		* @param expectedSize an estimate of the number of elements
612		* that will be held in the map. If no estimate is known,
613		* zero is an acceptable value.
#	Line 623 | Line 621 | public class CustomConcurrentHashMap<K,
621		}
622
623		/**
624	<	* Returns the segment for traversing table for key with given hash
624	>	* Returns the segment for traversing table for key with given hash.
625		* @param hash the hash code for the key
626		* @return the segment, or null if not yet initialized
627		*/
#	Line 642 | Line 640 | public class CustomConcurrentHashMap<K,
640		int index = (hash >>> SEGMENT_SHIFT) & SEGMENT_MASK;
641		Segment seg = segs[index];
642		if (seg == null) {
643	<	synchronized(segs) {
643	>	synchronized (segs) {
644		seg = segs[index];
645		if (seg == null) {
646		seg = new Segment();
#	Line 656 | Line 654 | public class CustomConcurrentHashMap<K,
654		}
655
656		/**
657	<	* Returns node for key, or null if none
657	>	* Returns node for key, or null if none.
658		*/
659		final Node findNode(Object key, int hash, Segment seg) {
660		if (seg != null) {
#	Line 678 | Line 676 | public class CustomConcurrentHashMap<K,
676		}
677
678		/**
679	<	* Returns <tt>true</tt> if this map contains a key equivalent to
679	>	* Returns {@code true} if this map contains a key equivalent to
680		* the given key with respect to this map's key Equivalence.
681		*
682		* @param  key   possible key
683	<	* @return <tt>true</tt> if this map contains the specified key
683	>	* @return {@code true} if this map contains the specified key
684		* @throws NullPointerException if the specified key is null
685		*/
686		public boolean containsKey(Object key) {
#	Line 697 | Line 695 | public class CustomConcurrentHashMap<K,
695		/**
696		* Returns the value associated with a key equivalent to the given
697		* key with respect to this map's key Equivalence, or {@code null}
698	<	* if no such mapping exists
698	>	* if no such mapping exists.
699		*
700		* @param  key   possible key
701	<	* @return the value associated with the key or <tt>null</tt> if
702	<	* there is no mapping.
701	>	* @return the value associated with the key or {@code null} if
702	>	* there is no mapping
703		* @throws NullPointerException if the specified key is null
704		*/
705		public V get(Object key) {
#	Line 752 | Line 750 | public class CustomConcurrentHashMap<K,
750		*
751		* @param key key with which the specified value is to be associated
752		* @param value value to be associated with the specified key
753	<	* @return the previous value associated with <tt>key</tt>, or
754	<	*         <tt>null</tt> if there was no mapping for <tt>key</tt>
753	>	* @return the previous value associated with {@code key}, or
754	>	*         {@code null} if there was no mapping for {@code key}
755		* @throws NullPointerException if the specified key or value is null
756		*/
757		public V put(K key, V value) {
#	Line 764 | Line 762 | public class CustomConcurrentHashMap<K,
762		* {@inheritDoc}
763		*
764		* @return the previous value associated with the specified key,
765	<	*         or <tt>null</tt> if there was no mapping for the key
765	>	*         or {@code null} if there was no mapping for the key
766		* @throws NullPointerException if the specified key or value is null
767		*/
768		public V putIfAbsent(K key, V value) {
#	Line 813 | Line 811 | public class CustomConcurrentHashMap<K,
811		* {@inheritDoc}
812		*
813		* @return the previous value associated with the specified key,
814	<	*         or <tt>null</tt> if there was no mapping for the key
814	>	*         or {@code null} if there was no mapping for the key
815		* @throws NullPointerException if the specified key or value is null
816		*/
817		public boolean replace(K key, V oldValue, V newValue) {
#	Line 845 | Line 843 | public class CustomConcurrentHashMap<K,
843		* Removes the mapping for the specified key.
844		*
845		* @param  key the key to remove
846	<	* @return the previous value associated with <tt>key</tt>, or
847	<	*         <tt>null</tt> if there was no mapping for <tt>key</tt>
846	>	* @return the previous value associated with {@code key}, or
847	>	*         {@code null} if there was no mapping for {@code key}
848		* @throws NullPointerException if the specified key is null
849		*/
850		public V remove(Object key) {
#	Line 942 | Line 940 | public class CustomConcurrentHashMap<K,
940		}
941
942		/**
943	<	* Remove node if its key or value are null
943	>	* Removes node if its key or value are null.
944		*/
945		final void removeIfReclaimed(Node r) {
946		int hash = r.getLocator();
#	Line 979 | Line 977 | public class CustomConcurrentHashMap<K,
977		}
978
979		/**
980	<	* Returns <tt>true</tt> if this map contains no key-value mappings.
980	>	* Returns {@code true} if this map contains no key-value mappings.
981		*
982	<	* @return <tt>true</tt> if this map contains no key-value mappings
982	>	* @return {@code true} if this map contains no key-value mappings
983		*/
984		public final boolean isEmpty() {
985		final Segment[] segs = this.segments;
#	Line 997 | Line 995 | public class CustomConcurrentHashMap<K,
995
996		/**
997		* Returns the number of key-value mappings in this map.  If the
998	<	* map contains more than <tt>Integer.MAX_VALUE</tt> elements, returns
999	<	* <tt>Integer.MAX_VALUE</tt>.
998	>	* map contains more than {@code Integer.MAX_VALUE} elements, returns
999	>	* {@code Integer.MAX_VALUE}.
1000		*
1001		* @return the number of key-value mappings in this map
1002		*/
#	Line 1010 | Line 1008 | public class CustomConcurrentHashMap<K,
1008		if (seg != null && seg.getTableForTraversal() != null)
1009		sum += seg.count;
1010		}
1011	<	return sum >= Integer.MAX_VALUE? Integer.MAX_VALUE : (int)sum;
1011	>	return (sum >= Integer.MAX_VALUE) ? Integer.MAX_VALUE : (int) sum;
1012		}
1013
1014		/**
1015	<	* Returns <tt>true</tt> if this map maps one or more keys to a
1015	>	* Returns {@code true} if this map maps one or more keys to a
1016		* value equivalent to the given value with respect to this map's
1017		* value Equivalence.  Note: This method requires a full internal
1018		* traversal of the hash table, and so is much slower than method
1019	<	* <tt>containsKey</tt>.
1019	>	* {@code containsKey}.
1020		*
1021		* @param value value whose presence in this map is to be tested
1022	<	* @return <tt>true</tt> if this map maps one or more keys to the
1022	>	* @return {@code true} if this map maps one or more keys to the
1023		*         specified value
1024		* @throws NullPointerException if the specified value is null
1025		*/
#	Line 1069 | Line 1067 | public class CustomConcurrentHashMap<K,
1067		/**
1068		* If the specified key is not already associated with a value,
1069		* computes its value using the given mappingFunction, and if
1070	<	* nonnull, enters it into the map.  This is equivalent to
1070	>	* non-null, enters it into the map.  This is equivalent to
1071		*
1072		* <pre>
1073		*   if (map.containsKey(key))
#	Line 1091 | Line 1089 | public class CustomConcurrentHashMap<K,
1089		* @param key key with which the specified value is to be associated
1090		* @param mappingFunction the function to compute a value
1091		* @return the current (existing or computed) value associated with
1092	<	*         the specified key, or <tt>null</tt> if the computation
1093	<	*         returned <tt>null</tt>.
1092	>	*         the specified key, or {@code null} if the computation
1093	>	*         returned {@code null}
1094		* @throws NullPointerException if the specified key or mappingFunction
1095	<	*         is null,
1095	>	*         is null
1096		* @throws RuntimeException or Error if the mappingFunction does so,
1097	<	*         in which case the mapping is left unestablished.
1097	>	*         in which case the mapping is left unestablished
1098		*/
1099		public V computeIfAbsent(K key, MappingFunction<? super K, ? extends V> mappingFunction) {
1100		if (key == null || mappingFunction == null)
#	Line 1158 | Line 1156 | public class CustomConcurrentHashMap<K,
1156		* <pre>
1157		* map.compute(word, new RemappingFunction&lt;String,Integer&gt;() {
1158		*   public Integer remap(String k, Integer v) {
1159	<	*     return v == null? 1 : v + 1;
1159	>	*     return (v == null) ? 1 : v + 1;
1160		*   }});
1161		* </pre>
1162		*
1163		* @param key key with which the specified value is to be associated
1164		* @param remappingFunction the function to compute a value
1165		* @return the updated value or
1166	<	*         <tt>null</tt> if the computation returned <tt>null</tt>
1166	>	*         {@code null} if the computation returned {@code null}
1167		* @throws NullPointerException if the specified key or remappingFunction
1168	<	*         is null,
1168	>	*         is null
1169		* @throws RuntimeException or Error if the remappingFunction does so,
1170		*         in which case the mapping is left in its previous state
1171		*/
#	Line 1414 | Line 1412 | public class CustomConcurrentHashMap<K,
1412		if (!(o instanceof Map.Entry))
1413		return false;
1414		Map.Entry<?,?> e = (Map.Entry<?,?>)o;
1415	<	return CustomConcurrentHashMap.this.remove(e.getKey(), e.getValue());
1415	>	return CustomConcurrentHashMap.this.remove(e.getKey(),
1416	>	e.getValue());
1417		}
1418		public int size() {
1419		return CustomConcurrentHashMap.this.size();
#	Line 1432 | Line 1431 | public class CustomConcurrentHashMap<K,
1431		* The set is backed by the map, so changes to the map are
1432		* reflected in the set, and vice-versa.  The set supports element
1433		* removal, which removes the corresponding mapping from this map,
1434	<	* via the <tt>Iterator.remove</tt>, <tt>Set.remove</tt>,
1435	<	* <tt>removeAll</tt>, <tt>retainAll</tt>, and <tt>clear</tt>
1436	<	* operations.  It does not support the <tt>add</tt> or
1437	<	* <tt>addAll</tt> operations.
1434	>	* via the {@code Iterator.remove}, {@code Set.remove},
1435	>	* {@code removeAll}, {@code retainAll}, and {@code clear}
1436	>	* operations.  It does not support the {@code add} or
1437	>	* {@code addAll} operations.
1438		*
1439	<	* <p>The view's <tt>iterator</tt> is a "weakly consistent" iterator
1439	>	* <p>The view's {@code iterator} is a "weakly consistent" iterator
1440		* that will never throw {@link ConcurrentModificationException},
1441		* and guarantees to traverse elements as they existed upon
1442		* construction of the iterator, and may (but is not guaranteed to)
#	Line 1453 | Line 1452 | public class CustomConcurrentHashMap<K,
1452		* The collection is backed by the map, so changes to the map are
1453		* reflected in the collection, and vice-versa.  The collection
1454		* supports element removal, which removes the corresponding
1455	<	* mapping from this map, via the <tt>Iterator.remove</tt>,
1456	<	* <tt>Collection.remove</tt>, <tt>removeAll</tt>,
1457	<	* <tt>retainAll</tt>, and <tt>clear</tt> operations.  It does not
1458	<	* support the <tt>add</tt> or <tt>addAll</tt> operations.
1455	>	* mapping from this map, via the {@code Iterator.remove},
1456	>	* {@code Collection.remove}, {@code removeAll},
1457	>	* {@code retainAll}, and {@code clear} operations.  It does not
1458	>	* support the {@code add} or {@code addAll} operations.
1459		*
1460	<	* <p>The view's <tt>iterator</tt> is a "weakly consistent" iterator
1460	>	* <p>The view's {@code iterator} is a "weakly consistent" iterator
1461		* that will never throw {@link ConcurrentModificationException},
1462		* and guarantees to traverse elements as they existed upon
1463		* construction of the iterator, and may (but is not guaranteed to)
#	Line 1474 | Line 1473 | public class CustomConcurrentHashMap<K,
1473		* The set is backed by the map, so changes to the map are
1474		* reflected in the set, and vice-versa.  The set supports element
1475		* removal, which removes the corresponding mapping from the map,
1476	<	* via the <tt>Iterator.remove</tt>, <tt>Set.remove</tt>,
1477	<	* <tt>removeAll</tt>, <tt>retainAll</tt>, and <tt>clear</tt>
1478	<	* operations.  It does not support the <tt>add</tt> or
1479	<	* <tt>addAll</tt> operations.
1476	>	* via the {@code Iterator.remove}, {@code Set.remove},
1477	>	* {@code removeAll}, {@code retainAll}, and {@code clear}
1478	>	* operations.  It does not support the {@code add} or
1479	>	* {@code addAll} operations.
1480		*
1481	<	* <p>The view's <tt>iterator</tt> is a "weakly consistent" iterator
1481	>	* <p>The view's {@code iterator} is a "weakly consistent" iterator
1482		* that will never throw {@link ConcurrentModificationException},
1483		* and guarantees to traverse elements as they existed upon
1484		* construction of the iterator, and may (but is not guaranteed to)
#	Line 1494 | Line 1493 | public class CustomConcurrentHashMap<K,
1493
1494		/**
1495		* Compares the specified object with this map for equality.
1496	<	* Returns <tt>true</tt> if the given object is also a map of the
1496	>	* Returns {@code true} if the given object is also a map of the
1497		* same size, holding keys that are equal using this Map's key
1498		* Equivalence, and which map to values that are equal according
1499		* to this Map's value equivalence.
1500		*
1501		* @param o object to be compared for equality with this map
1502	<	* @return <tt>true</tt> if the specified object is equal to this map
1502	>	* @return {@code true} if the specified object is equal to this map
1503		*/
1504		public boolean equals(Object o) {
1505		if (o == this)
#	Line 1537 | Line 1536 | public class CustomConcurrentHashMap<K,
1536
1537		/**
1538		* Returns the sum of the hash codes of each entry in this map's
1539	<	* <tt>entrySet()</tt> view, which in turn are the hash codes
1539	>	* {@code entrySet()} view, which in turn are the hash codes
1540		* computed using key and value Equivalences for this Map.
1541		* @return the hash code
1542		*/
#	Line 1550 | Line 1549 | public class CustomConcurrentHashMap<K,
1549		}
1550
1551		/**
1552	<	* Save the state of the instance to a stream (i.e., serialize
1553	<	* it).
1552	>	* Saves the state of the instance to a stream (i.e., serializes it).
1553	>	*
1554		* @param s the stream
1555		* @serialData
1556		* the key (Object) and value (Object)
1557		* for each key-value mapping, followed by a null pair.
1558		* The key-value mappings are emitted in no particular order.
1559		*/
1560	<	private void writeObject(java.io.ObjectOutputStream s) throws IOException  {
1560	>	private void writeObject(java.io.ObjectOutputStream s) throws IOException {
1561		s.defaultWriteObject();
1562		for (Map.Entry<K,V> e : entrySet()) {
1563		s.writeObject(e.getKey());
#	Line 1569 | Line 1568 | public class CustomConcurrentHashMap<K,
1568		}
1569
1570		/**
1571	<	* Reconstitute the instance from a stream (i.e., deserialize it).
1571	>	* Reconstitutes the instance from a stream (that is, deserializes it).
1572		* @param s the stream
1573		*/
1574		private void readObject(java.io.ObjectInputStream s)
1575	<	throws IOException, ClassNotFoundException  {
1575	>	throws IOException, ClassNotFoundException {
1576		s.defaultReadObject();
1577	<	this.segments = (Segment[])(new Segment[NSEGMENTS]);
1577	>	this.segments = new Segment[NSEGMENTS];
1578		for (;;) {
1579		K key = (K) s.readObject();
1580		V value = (V) s.readObject();
#	Line 1587 | Line 1586 | public class CustomConcurrentHashMap<K,
1586
1587		/**
1588		* A hash-based set with properties identical to those of
1589	<	* <code>Collections.newSetFromMap</code> applied to a
1590	<	* <code>CustomConcurrentHashMap</code>, but possibly more
1589	>	* {@code Collections.newSetFromMap} applied to a
1590	>	* {@code CustomConcurrentHashMap}, but possibly more
1591		* space-efficient.  The set does not permit null elements. The
1592		* set is serializable; however, serializing a set that uses soft
1593		* or weak references can give unpredictable results.
#	Line 1599 | Line 1598 | public class CustomConcurrentHashMap<K,
1598		final CustomConcurrentHashMap<K,K> cchm;
1599
1600		/**
1601	<	* Creates a set with the given parameters
1601	>	* Creates a set with the given parameters.
1602		* @param strength the strength of elements
1603		* @param equivalence the Equivalence to use
1604		* @param expectedSize an estimate of the number of elements
#	Line 1620 | Line 1619 | public class CustomConcurrentHashMap<K,
1619		* exists, else adds and returns the given element.
1620		*
1621		* @param e the element
1622	<	* @return e, or an element equivalent to e.
1622	>	* @return e, or an element equivalent to e
1623		*/
1624		public K intern(K e) {
1625		K oldElement = cchm.doPut(e, e, true);
#	Line 1628 | Line 1627 | public class CustomConcurrentHashMap<K,
1627		}
1628
1629		/**
1630	<	* Returns <tt>true</tt> if this set contains an
1630	>	* Returns {@code true} if this set contains an
1631		* element equivalent to the given element with respect
1632		* to this set's Equivalence.
1633		* @param o element whose presence in this set is to be tested
1634	<	* @return <tt>true</tt> if this set contains the specified element
1634	>	* @return {@code true} if this set contains the specified element
1635		*/
1636		public boolean contains(Object o) {
1637		return cchm.containsKey(o);
#	Line 1655 | Line 1654 | public class CustomConcurrentHashMap<K,
1654		* respect to this set's Equivalence.
1655		*
1656		* @param e element to be added to this set
1657	<	* @return <tt>true</tt> if this set did not already contain
1657	>	* @return {@code true} if this set did not already contain
1658		* the specified element
1659		*/
1660		public boolean add(K e) {
#	Line 1667 | Line 1666 | public class CustomConcurrentHashMap<K,
1666		* respect to this set's Equivalence, if one is present.
1667		*
1668		* @param o object to be removed from this set, if present
1669	<	* @return <tt>true</tt> if the set contained the specified element
1669	>	* @return {@code true} if the set contained the specified element
1670		*/
1671		public boolean remove(Object o) {
1672		return cchm.remove(o) != null;
1673		}
1674
1675		/**
1676	<	* Returns <tt>true</tt> if this set contains no elements.
1676	>	* Returns {@code true} if this set contains no elements.
1677		*
1678	<	* @return <tt>true</tt> if this set contains no elements
1678	>	* @return {@code true} if this set contains no elements
1679		*/
1680		public boolean isEmpty() {
1681		return cchm.isEmpty();
#	Line 1721 | Line 1720 | public class CustomConcurrentHashMap<K,
1720		* to {@link java.lang.ref.Reference} constructors to arrange
1721		* removal of reclaimed nodes from maps via a background thread.
1722		* @return the reference queue associated with the background
1723	<	* cleanup thread.
1723	>	* cleanup thread
1724		*/
1725		static ReferenceQueue<Object> getReclamationQueue() {
1726		ReferenceQueue<Object> q = refQueue;
#	Line 1792 | Line 1791 | public class CustomConcurrentHashMap<K,
1791
1792		// Strong Keys
1793
1794	<	static abstract class StrongKeyNode implements Node {
1794	>	abstract static class StrongKeyNode implements Node {
1795		final Object key;
1796		final int locator;
1797		StrongKeyNode(int locator, Object key) {
#	Line 1804 | Line 1803 | public class CustomConcurrentHashMap<K,
1803		}
1804
1805
1806	<	static abstract class StrongKeySelfValueNode
1806	>	abstract static class StrongKeySelfValueNode
1807		extends StrongKeyNode {
1808		StrongKeySelfValueNode(int locator, Object key) {
1809		super(locator, key);
#	Line 1820 | Line 1819 | public class CustomConcurrentHashMap<K,
1819		super(locator, key);
1820		}
1821		public final Node getLinkage() { return null; }
1822	<	public final void setLinkage(Node r) { }
1822	>	public final void setLinkage(Node linkage) { }
1823		}
1824
1825		static final class LinkedStrongKeySelfValueNode
#	Line 1832 | Line 1831 | public class CustomConcurrentHashMap<K,
1831		this.linkage = linkage;
1832		}
1833		public final Node getLinkage() { return linkage; }
1834	<	public final void setLinkage(Node r) { linkage = r; }
1834	>	public final void setLinkage(Node linkage) { this.linkage = linkage; }
1835		}
1836
1837		static final class StrongKeySelfValueNodeFactory
#	Line 1851 | Line 1850 | public class CustomConcurrentHashMap<K,
1850		}
1851		}
1852
1853	<	static abstract class StrongKeyStrongValueNode
1853	>	abstract static class StrongKeyStrongValueNode
1854		extends StrongKeyNode {
1855		volatile Object value;
1856		StrongKeyStrongValueNode(int locator, Object key, Object value) {
#	Line 1870 | Line 1869 | public class CustomConcurrentHashMap<K,
1869		super(locator, key, value);
1870		}
1871		public final Node getLinkage() { return null; }
1872	<	public final void setLinkage(Node r) { }
1872	>	public final void setLinkage(Node linkage) { }
1873		}
1874
1875		static final class LinkedStrongKeyStrongValueNode
#	Line 1883 | Line 1882 | public class CustomConcurrentHashMap<K,
1882		this.linkage = linkage;
1883		}
1884		public final Node getLinkage() { return linkage; }
1885	<	public final void setLinkage(Node r) { linkage = r; }
1885	>	public final void setLinkage(Node linkage) { this.linkage = linkage; }
1886		}
1887
1888		static final class StrongKeyStrongValueNodeFactory
#	Line 1904 | Line 1903 | public class CustomConcurrentHashMap<K,
1903
1904		// ...
1905
1906	<	static abstract class StrongKeyIntValueNode
1906	>	abstract static class StrongKeyIntValueNode
1907		extends StrongKeyNode {
1908		volatile int value;
1909		StrongKeyIntValueNode(int locator, Object key, Object value) {
#	Line 1925 | Line 1924 | public class CustomConcurrentHashMap<K,
1924		super(locator, key, value);
1925		}
1926		public final Node getLinkage() { return null; }
1927	<	public final void setLinkage(Node r) { }
1927	>	public final void setLinkage(Node linkage) { }
1928		}
1929
1930		static final class LinkedStrongKeyIntValueNode
#	Line 1938 | Line 1937 | public class CustomConcurrentHashMap<K,
1937		this.linkage = linkage;
1938		}
1939		public final Node getLinkage() { return linkage; }
1940	<	public final void setLinkage(Node r) { linkage = r; }
1940	>	public final void setLinkage(Node linkage) { this.linkage = linkage; }
1941		}
1942
1943		static final class StrongKeyIntValueNodeFactory
#	Line 1959 | Line 1958 | public class CustomConcurrentHashMap<K,
1958
1959		// ...
1960
1961	<	static abstract class StrongKeyWeakValueNode
1961	>	abstract static class StrongKeyWeakValueNode
1962		extends StrongKeyNode {
1963		volatile EmbeddedWeakReference valueRef;
1964		final CustomConcurrentHashMap cchm;
#	Line 1975 | Line 1974 | public class CustomConcurrentHashMap<K,
1974		}
1975		public final Object getValue() {
1976		EmbeddedWeakReference vr = valueRef;
1977	<	return vr == null? null : vr.get();
1977	>	return (vr == null) ? null : vr.get();
1978		}
1979		public final void setValue(Object value) {
1980		if (value == null)
#	Line 1993 | Line 1992 | public class CustomConcurrentHashMap<K,
1992		super(locator, key, value, cchm);
1993		}
1994		public final Node getLinkage() { return null; }
1995	<	public final void setLinkage(Node r) { }
1995	>	public final void setLinkage(Node linkage) { }
1996		}
1997
1998		static final class LinkedStrongKeyWeakValueNode
#	Line 2007 | Line 2006 | public class CustomConcurrentHashMap<K,
2006		this.linkage = linkage;
2007		}
2008		public final Node getLinkage() { return linkage; }
2009	<	public final void setLinkage(Node r) { linkage = r; }
2009	>	public final void setLinkage(Node linkage) { this.linkage = linkage; }
2010		}
2011
2012		static final class StrongKeyWeakValueNodeFactory
#	Line 2027 | Line 2026 | public class CustomConcurrentHashMap<K,
2026		}
2027
2028
2029	<	static abstract class StrongKeySoftValueNode
2029	>	abstract static class StrongKeySoftValueNode
2030		extends StrongKeyNode {
2031		volatile EmbeddedSoftReference valueRef;
2032		final CustomConcurrentHashMap cchm;
#	Line 2043 | Line 2042 | public class CustomConcurrentHashMap<K,
2042		}
2043		public final Object getValue() {
2044		EmbeddedSoftReference vr = valueRef;
2045	<	return vr == null? null : vr.get();
2045	>	return (vr == null) ? null : vr.get();
2046		}
2047		public final void setValue(Object value) {
2048		if (value == null)
#	Line 2061 | Line 2060 | public class CustomConcurrentHashMap<K,
2060		super(locator, key, value, cchm);
2061		}
2062		public final Node getLinkage() { return null; }
2063	<	public final void setLinkage(Node r) { }
2063	>	public final void setLinkage(Node linkage) { }
2064		}
2065
2066		static final class LinkedStrongKeySoftValueNode
#	Line 2075 | Line 2074 | public class CustomConcurrentHashMap<K,
2074		this.linkage = linkage;
2075		}
2076		public final Node getLinkage() { return linkage; }
2077	<	public final void setLinkage(Node r) { linkage = r; }
2077	>	public final void setLinkage(Node linkage) { this.linkage = linkage; }
2078		}
2079
2080		static final class StrongKeySoftValueNodeFactory
#	Line 2096 | Line 2095 | public class CustomConcurrentHashMap<K,
2095
2096		// Weak keys
2097
2098	<	static abstract class WeakKeyNode extends WeakReference
2098	>	abstract static class WeakKeyNode extends WeakReference
2099		implements Node {
2100		final int locator;
2101		final CustomConcurrentHashMap cchm;
#	Line 2112 | Line 2111 | public class CustomConcurrentHashMap<K,
2111		}
2112		}
2113
2114	<	static abstract class WeakKeySelfValueNode
2114	>	abstract static class WeakKeySelfValueNode
2115		extends WeakKeyNode {
2116	<	WeakKeySelfValueNode(int locator, Object key, CustomConcurrentHashMap cchm) {
2116	>	WeakKeySelfValueNode(int locator, Object key,
2117	>	CustomConcurrentHashMap cchm) {
2118		super(locator, key, cchm);
2119		}
2120		public final Object getValue() { return get(); }
#	Line 2123 | Line 2123 | public class CustomConcurrentHashMap<K,
2123
2124		static final class TerminalWeakKeySelfValueNode
2125		extends WeakKeySelfValueNode {
2126	<	TerminalWeakKeySelfValueNode(int locator, Object key, CustomConcurrentHashMap cchm) {
2126	>	TerminalWeakKeySelfValueNode(int locator, Object key,
2127	>	CustomConcurrentHashMap cchm) {
2128		super(locator, key, cchm);
2129		}
2130		public final Node getLinkage() { return null; }
2131	<	public final void setLinkage(Node r) { }
2131	>	public final void setLinkage(Node linkage) { }
2132		}
2133
2134		static final class LinkedWeakKeySelfValueNode
2135		extends WeakKeySelfValueNode {
2136		volatile Node linkage;
2137	<	LinkedWeakKeySelfValueNode(int locator, Object key, CustomConcurrentHashMap cchm,
2137	>	LinkedWeakKeySelfValueNode(int locator, Object key,
2138	>	CustomConcurrentHashMap cchm,
2139		Node linkage) {
2140		super(locator, key, cchm);
2141		this.linkage = linkage;
2142		}
2143		public final Node getLinkage() { return linkage; }
2144	<	public final void setLinkage(Node r) { linkage = r; }
2144	>	public final void setLinkage(Node linkage) { this.linkage = linkage; }
2145		}
2146
2147		static final class WeakKeySelfValueNodeFactory
#	Line 2159 | Line 2161 | public class CustomConcurrentHashMap<K,
2161		}
2162
2163
2164	<	static abstract class WeakKeyStrongValueNode
2164	>	abstract static class WeakKeyStrongValueNode
2165		extends WeakKeyNode {
2166		volatile Object value;
2167	<	WeakKeyStrongValueNode(int locator, Object key, Object value, CustomConcurrentHashMap cchm) {
2167	>	WeakKeyStrongValueNode(int locator, Object key, Object value,
2168	>	CustomConcurrentHashMap cchm) {
2169		super(locator, key, cchm);
2170		this.value = value;
2171		}
#	Line 2173 | Line 2176 | public class CustomConcurrentHashMap<K,
2176		static final class TerminalWeakKeyStrongValueNode
2177		extends WeakKeyStrongValueNode {
2178		TerminalWeakKeyStrongValueNode(int locator,
2179	<	Object key, Object value, CustomConcurrentHashMap cchm) {
2179	>	Object key, Object value,
2180	>	CustomConcurrentHashMap cchm) {
2181		super(locator, key, value, cchm);
2182		}
2183		public final Node getLinkage() { return null; }
2184	<	public final void setLinkage(Node r) { }
2184	>	public final void setLinkage(Node linkage) { }
2185		}
2186
2187		static final class LinkedWeakKeyStrongValueNode
2188		extends WeakKeyStrongValueNode {
2189		volatile Node linkage;
2190		LinkedWeakKeyStrongValueNode(int locator,
2191	<	Object key, Object value, CustomConcurrentHashMap cchm,
2191	>	Object key, Object value,
2192	>	CustomConcurrentHashMap cchm,
2193		Node linkage) {
2194		super(locator, key, value, cchm);
2195		this.linkage = linkage;
2196		}
2197		public final Node getLinkage() { return linkage; }
2198	<	public final void setLinkage(Node r) { linkage = r; }
2198	>	public final void setLinkage(Node linkage) { this.linkage = linkage; }
2199		}
2200
2201		static final class WeakKeyStrongValueNodeFactory
#	Line 2209 | Line 2214 | public class CustomConcurrentHashMap<K,
2214		}
2215		}
2216
2217	<	static abstract class WeakKeyIntValueNode
2217	>	abstract static class WeakKeyIntValueNode
2218		extends WeakKeyNode {
2219		volatile int value;
2220		WeakKeyIntValueNode(int locator, Object key, Object value,
#	Line 2231 | Line 2236 | public class CustomConcurrentHashMap<K,
2236		super(locator, key, value, cchm);
2237		}
2238		public final Node getLinkage() { return null; }
2239	<	public final void setLinkage(Node r) { }
2239	>	public final void setLinkage(Node linkage) { }
2240		}
2241
2242		static final class LinkedWeakKeyIntValueNode
#	Line 2245 | Line 2250 | public class CustomConcurrentHashMap<K,
2250		this.linkage = linkage;
2251		}
2252		public final Node getLinkage() { return linkage; }
2253	<	public final void setLinkage(Node r) { linkage = r; }
2253	>	public final void setLinkage(Node linkage) { this.linkage = linkage; }
2254		}
2255
2256		static final class WeakKeyIntValueNodeFactory
#	Line 2264 | Line 2269 | public class CustomConcurrentHashMap<K,
2269		}
2270		}
2271
2272	<	static abstract class WeakKeyWeakValueNode
2272	>	abstract static class WeakKeyWeakValueNode
2273		extends WeakKeyNode {
2274		volatile EmbeddedWeakReference valueRef;
2275		WeakKeyWeakValueNode(int locator, Object key, Object value,
#	Line 2275 | Line 2280 | public class CustomConcurrentHashMap<K,
2280		}
2281		public final Object getValue() {
2282		EmbeddedWeakReference vr = valueRef;
2283	<	return vr == null? null : vr.get();
2283	>	return (vr == null) ? null : vr.get();
2284		}
2285		public final void setValue(Object value) {
2286		if (value == null)
#	Line 2293 | Line 2298 | public class CustomConcurrentHashMap<K,
2298		super(locator, key, value, cchm);
2299		}
2300		public final Node getLinkage() { return null; }
2301	<	public final void setLinkage(Node r) { }
2301	>	public final void setLinkage(Node linkage) { }
2302		}
2303
2304		static final class LinkedWeakKeyWeakValueNode
#	Line 2307 | Line 2312 | public class CustomConcurrentHashMap<K,
2312		this.linkage = linkage;
2313		}
2314		public final Node getLinkage() { return linkage; }
2315	<	public final void setLinkage(Node r) { linkage = r; }
2315	>	public final void setLinkage(Node linkage) { this.linkage = linkage; }
2316		}
2317
2318		static final class WeakKeyWeakValueNodeFactory
#	Line 2327 | Line 2332 | public class CustomConcurrentHashMap<K,
2332		}
2333
2334
2335	<	static abstract class WeakKeySoftValueNode
2335	>	abstract static class WeakKeySoftValueNode
2336		extends WeakKeyNode {
2337		volatile EmbeddedSoftReference valueRef;
2338		WeakKeySoftValueNode(int locator, Object key, Object value,
#	Line 2338 | Line 2343 | public class CustomConcurrentHashMap<K,
2343		}
2344		public final Object getValue() {
2345		EmbeddedSoftReference vr = valueRef;
2346	<	return vr == null? null : vr.get();
2346	>	return (vr == null) ? null : vr.get();
2347		}
2348		public final void setValue(Object value) {
2349		if (value == null)
#	Line 2356 | Line 2361 | public class CustomConcurrentHashMap<K,
2361		super(locator, key, value, cchm);
2362		}
2363		public final Node getLinkage() { return null; }
2364	<	public final void setLinkage(Node r) { }
2364	>	public final void setLinkage(Node linkage) { }
2365		}
2366
2367		static final class LinkedWeakKeySoftValueNode
#	Line 2370 | Line 2375 | public class CustomConcurrentHashMap<K,
2375		this.linkage = linkage;
2376		}
2377		public final Node getLinkage() { return linkage; }
2378	<	public final void setLinkage(Node r) { linkage = r; }
2378	>	public final void setLinkage(Node linkage) { this.linkage = linkage; }
2379		}
2380
2381		static final class WeakKeySoftValueNodeFactory
#	Line 2391 | Line 2396 | public class CustomConcurrentHashMap<K,
2396
2397		// Soft keys
2398
2399	<	static abstract class SoftKeyNode extends SoftReference
2399	>	abstract static class SoftKeyNode extends SoftReference
2400		implements Node {
2401		final int locator;
2402		final CustomConcurrentHashMap cchm;
#	Line 2407 | Line 2412 | public class CustomConcurrentHashMap<K,
2412		}
2413		}
2414
2415	<	static abstract class SoftKeySelfValueNode
2415	>	abstract static class SoftKeySelfValueNode
2416		extends SoftKeyNode {
2417	<	SoftKeySelfValueNode(int locator, Object key, CustomConcurrentHashMap cchm) {
2417	>	SoftKeySelfValueNode(int locator, Object key,
2418	>	CustomConcurrentHashMap cchm) {
2419		super(locator, key, cchm);
2420		}
2421		public final Object getValue() { return get(); }
#	Line 2418 | Line 2424 | public class CustomConcurrentHashMap<K,
2424
2425		static final class TerminalSoftKeySelfValueNode
2426		extends SoftKeySelfValueNode {
2427	<	TerminalSoftKeySelfValueNode(int locator, Object key, CustomConcurrentHashMap cchm) {
2427	>	TerminalSoftKeySelfValueNode(int locator, Object key,
2428	>	CustomConcurrentHashMap cchm) {
2429		super(locator, key, cchm);
2430		}
2431		public final Node getLinkage() { return null; }
2432	<	public final void setLinkage(Node r) { }
2432	>	public final void setLinkage(Node linkage) { }
2433		}
2434
2435		static final class LinkedSoftKeySelfValueNode
2436		extends SoftKeySelfValueNode {
2437		volatile Node linkage;
2438	<	LinkedSoftKeySelfValueNode(int locator, Object key, CustomConcurrentHashMap cchm,
2438	>	LinkedSoftKeySelfValueNode(int locator, Object key,
2439	>	CustomConcurrentHashMap cchm,
2440		Node linkage) {
2441		super(locator, key, cchm);
2442		this.linkage = linkage;
2443		}
2444		public final Node getLinkage() { return linkage; }
2445	<	public final void setLinkage(Node r) { linkage = r; }
2445	>	public final void setLinkage(Node linkage) { this.linkage = linkage; }
2446		}
2447
2448		static final class SoftKeySelfValueNodeFactory
#	Line 2454 | Line 2462 | public class CustomConcurrentHashMap<K,
2462		}
2463
2464
2465	<	static abstract class SoftKeyStrongValueNode
2465	>	abstract static class SoftKeyStrongValueNode
2466		extends SoftKeyNode {
2467		volatile Object value;
2468	<	SoftKeyStrongValueNode(int locator, Object key, Object value, CustomConcurrentHashMap cchm) {
2468	>	SoftKeyStrongValueNode(int locator, Object key, Object value,
2469	>	CustomConcurrentHashMap cchm) {
2470		super(locator, key, cchm);
2471		this.value = value;
2472		}
#	Line 2468 | Line 2477 | public class CustomConcurrentHashMap<K,
2477		static final class TerminalSoftKeyStrongValueNode
2478		extends SoftKeyStrongValueNode {
2479		TerminalSoftKeyStrongValueNode(int locator,
2480	<	Object key, Object value, CustomConcurrentHashMap cchm) {
2480	>	Object key, Object value,
2481	>	CustomConcurrentHashMap cchm) {
2482		super(locator, key, value, cchm);
2483		}
2484		public final Node getLinkage() { return null; }
2485	<	public final void setLinkage(Node r) { }
2485	>	public final void setLinkage(Node linkage) { }
2486		}
2487
2488		static final class LinkedSoftKeyStrongValueNode
2489		extends SoftKeyStrongValueNode {
2490		volatile Node linkage;
2491		LinkedSoftKeyStrongValueNode(int locator,
2492	<	Object key, Object value, CustomConcurrentHashMap cchm,
2492	>	Object key, Object value,
2493	>	CustomConcurrentHashMap cchm,
2494		Node linkage) {
2495		super(locator, key, value, cchm);
2496		this.linkage = linkage;
2497		}
2498		public final Node getLinkage() { return linkage; }
2499	<	public final void setLinkage(Node r) { linkage = r; }
2499	>	public final void setLinkage(Node linkage) { this.linkage = linkage; }
2500		}
2501
2502		static final class SoftKeyStrongValueNodeFactory
#	Line 2504 | Line 2515 | public class CustomConcurrentHashMap<K,
2515		}
2516		}
2517
2518	<	static abstract class SoftKeyIntValueNode
2518	>	abstract static class SoftKeyIntValueNode
2519		extends SoftKeyNode {
2520		volatile int value;
2521		SoftKeyIntValueNode(int locator, Object key, Object value,
#	Line 2526 | Line 2537 | public class CustomConcurrentHashMap<K,
2537		super(locator, key, value, cchm);
2538		}
2539		public final Node getLinkage() { return null; }
2540	<	public final void setLinkage(Node r) { }
2540	>	public final void setLinkage(Node linkage) { }
2541		}
2542
2543		static final class LinkedSoftKeyIntValueNode
#	Line 2540 | Line 2551 | public class CustomConcurrentHashMap<K,
2551		this.linkage = linkage;
2552		}
2553		public final Node getLinkage() { return linkage; }
2554	<	public final void setLinkage(Node r) { linkage = r; }
2554	>	public final void setLinkage(Node linkage) { this.linkage = linkage; }
2555		}
2556
2557		static final class SoftKeyIntValueNodeFactory
#	Line 2559 | Line 2570 | public class CustomConcurrentHashMap<K,
2570		}
2571		}
2572
2573	<	static abstract class SoftKeyWeakValueNode
2573	>	abstract static class SoftKeyWeakValueNode
2574		extends SoftKeyNode {
2575		volatile EmbeddedWeakReference valueRef;
2576		SoftKeyWeakValueNode(int locator, Object key, Object value,
#	Line 2570 | Line 2581 | public class CustomConcurrentHashMap<K,
2581		}
2582		public final Object getValue() {
2583		EmbeddedWeakReference vr = valueRef;
2584	<	return vr == null? null : vr.get();
2584	>	return (vr == null) ? null : vr.get();
2585		}
2586		public final void setValue(Object value) {
2587		if (value == null)
#	Line 2588 | Line 2599 | public class CustomConcurrentHashMap<K,
2599		super(locator, key, value, cchm);
2600		}
2601		public final Node getLinkage() { return null; }
2602	<	public final void setLinkage(Node r) { }
2602	>	public final void setLinkage(Node linkage) { }
2603		}
2604
2605		static final class LinkedSoftKeyWeakValueNode
#	Line 2602 | Line 2613 | public class CustomConcurrentHashMap<K,
2613		this.linkage = linkage;
2614		}
2615		public final Node getLinkage() { return linkage; }
2616	<	public final void setLinkage(Node r) { linkage = r; }
2616	>	public final void setLinkage(Node linkage) { this.linkage = linkage; }
2617		}
2618
2619		static final class SoftKeyWeakValueNodeFactory
#	Line 2622 | Line 2633 | public class CustomConcurrentHashMap<K,
2633		}
2634
2635
2636	<	static abstract class SoftKeySoftValueNode
2636	>	abstract static class SoftKeySoftValueNode
2637		extends SoftKeyNode {
2638		volatile EmbeddedSoftReference valueRef;
2639		SoftKeySoftValueNode(int locator, Object key, Object value,
#	Line 2633 | Line 2644 | public class CustomConcurrentHashMap<K,
2644		}
2645		public final Object getValue() {
2646		EmbeddedSoftReference vr = valueRef;
2647	<	return vr == null? null : vr.get();
2647	>	return (vr == null) ? null : vr.get();
2648		}
2649		public final void setValue(Object value) {
2650		if (value == null)
#	Line 2651 | Line 2662 | public class CustomConcurrentHashMap<K,
2662		super(locator, key, value, cchm);
2663		}
2664		public final Node getLinkage() { return null; }
2665	<	public final void setLinkage(Node r) { }
2665	>	public final void setLinkage(Node linkage) { }
2666		}
2667
2668		static final class LinkedSoftKeySoftValueNode
#	Line 2665 | Line 2676 | public class CustomConcurrentHashMap<K,
2676		this.linkage = linkage;
2677		}
2678		public final Node getLinkage() { return linkage; }
2679	<	public final void setLinkage(Node r) { linkage = r; }
2679	>	public final void setLinkage(Node linkage) { this.linkage = linkage; }
2680		}
2681
2682		static final class SoftKeySoftValueNodeFactory
#	Line 2684 | Line 2695 | public class CustomConcurrentHashMap<K,
2695		}
2696		}
2697
2698	<	static abstract class IntKeyNode implements Node {
2698	>	abstract static class IntKeyNode implements Node {
2699		final int key;
2700		IntKeyNode(int locator, Object key) {
2701		this.key = ((Integer)key).intValue();
#	Line 2694 | Line 2705 | public class CustomConcurrentHashMap<K,
2705		}
2706
2707
2708	<	static abstract class IntKeySelfValueNode
2708	>	abstract static class IntKeySelfValueNode
2709		extends IntKeyNode {
2710		IntKeySelfValueNode(int locator, Object key) {
2711		super(locator, key);
#	Line 2710 | Line 2721 | public class CustomConcurrentHashMap<K,
2721		super(locator, key);
2722		}
2723		public final Node getLinkage() { return null; }
2724	<	public final void setLinkage(Node r) { }
2724	>	public final void setLinkage(Node linkage) { }
2725		}
2726
2727		static final class LinkedIntKeySelfValueNode
#	Line 2722 | Line 2733 | public class CustomConcurrentHashMap<K,
2733		this.linkage = linkage;
2734		}
2735		public final Node getLinkage() { return linkage; }
2736	<	public final void setLinkage(Node r) { linkage = r; }
2736	>	public final void setLinkage(Node linkage) { this.linkage = linkage; }
2737		}
2738
2739		static final class IntKeySelfValueNodeFactory
#	Line 2741 | Line 2752 | public class CustomConcurrentHashMap<K,
2752		}
2753		}
2754
2755	<	static abstract class IntKeyStrongValueNode
2755	>	abstract static class IntKeyStrongValueNode
2756		extends IntKeyNode {
2757		volatile Object value;
2758		IntKeyStrongValueNode(int locator, Object key, Object value) {
#	Line 2760 | Line 2771 | public class CustomConcurrentHashMap<K,
2771		super(locator, key, value);
2772		}
2773		public final Node getLinkage() { return null; }
2774	<	public final void setLinkage(Node r) { }
2774	>	public final void setLinkage(Node linkage) { }
2775		}
2776
2777		static final class LinkedIntKeyStrongValueNode
#	Line 2773 | Line 2784 | public class CustomConcurrentHashMap<K,
2784		this.linkage = linkage;
2785		}
2786		public final Node getLinkage() { return linkage; }
2787	<	public final void setLinkage(Node r) { linkage = r; }
2787	>	public final void setLinkage(Node linkage) { this.linkage = linkage; }
2788		}
2789
2790		static final class IntKeyStrongValueNodeFactory
#	Line 2792 | Line 2803 | public class CustomConcurrentHashMap<K,
2803		}
2804		}
2805
2806	<	static abstract class IntKeyIntValueNode
2806	>	abstract static class IntKeyIntValueNode
2807		extends IntKeyNode {
2808		volatile int value;
2809		IntKeyIntValueNode(int locator, Object key, Object value) {
#	Line 2813 | Line 2824 | public class CustomConcurrentHashMap<K,
2824		super(locator, key, value);
2825		}
2826		public final Node getLinkage() { return null; }
2827	<	public final void setLinkage(Node r) { }
2827	>	public final void setLinkage(Node linkage) { }
2828		}
2829
2830		static final class LinkedIntKeyIntValueNode
#	Line 2826 | Line 2837 | public class CustomConcurrentHashMap<K,
2837		this.linkage = linkage;
2838		}
2839		public final Node getLinkage() { return linkage; }
2840	<	public final void setLinkage(Node r) { linkage = r; }
2840	>	public final void setLinkage(Node linkage) { this.linkage = linkage; }
2841		}
2842
2843		static final class IntKeyIntValueNodeFactory
#	Line 2845 | Line 2856 | public class CustomConcurrentHashMap<K,
2856		}
2857		}
2858
2859	<	static abstract class IntKeyWeakValueNode
2859	>	abstract static class IntKeyWeakValueNode
2860		extends IntKeyNode {
2861		volatile EmbeddedWeakReference valueRef;
2862		final CustomConcurrentHashMap cchm;
#	Line 2861 | Line 2872 | public class CustomConcurrentHashMap<K,
2872		}
2873		public final Object getValue() {
2874		EmbeddedWeakReference vr = valueRef;
2875	<	return vr == null? null : vr.get();
2875	>	return (vr == null) ? null : vr.get();
2876		}
2877		public final void setValue(Object value) {
2878		if (value == null)
#	Line 2879 | Line 2890 | public class CustomConcurrentHashMap<K,
2890		super(locator, key, value, cchm);
2891		}
2892		public final Node getLinkage() { return null; }
2893	<	public final void setLinkage(Node r) { }
2893	>	public final void setLinkage(Node linkage) { }
2894		}
2895
2896		static final class LinkedIntKeyWeakValueNode
#	Line 2893 | Line 2904 | public class CustomConcurrentHashMap<K,
2904		this.linkage = linkage;
2905		}
2906		public final Node getLinkage() { return linkage; }
2907	<	public final void setLinkage(Node r) { linkage = r; }
2907	>	public final void setLinkage(Node linkage) { this.linkage = linkage; }
2908		}
2909
2910		static final class IntKeyWeakValueNodeFactory
#	Line 2913 | Line 2924 | public class CustomConcurrentHashMap<K,
2924		}
2925
2926
2927	<	static abstract class IntKeySoftValueNode
2927	>	abstract static class IntKeySoftValueNode
2928		extends IntKeyNode {
2929		volatile EmbeddedSoftReference valueRef;
2930		final CustomConcurrentHashMap cchm;
2931		IntKeySoftValueNode(int locator, Object key, Object value,
2932	<	CustomConcurrentHashMap cchm) {
2932	>	CustomConcurrentHashMap cchm) {
2933		super(locator, key);
2934		this.cchm = cchm;
2935		if (value != null)
#	Line 2929 | Line 2940 | public class CustomConcurrentHashMap<K,
2940		}
2941		public final Object getValue() {
2942		EmbeddedSoftReference vr = valueRef;
2943	<	return vr == null? null : vr.get();
2943	>	return (vr == null) ? null : vr.get();
2944		}
2945		public final void setValue(Object value) {
2946		if (value == null)
#	Line 2947 | Line 2958 | public class CustomConcurrentHashMap<K,
2958		super(locator, key, value, cchm);
2959		}
2960		public final Node getLinkage() { return null; }
2961	<	public final void setLinkage(Node r) { }
2961	>	public final void setLinkage(Node linkage) { }
2962		}
2963
2964		static final class LinkedIntKeySoftValueNode
#	Line 2961 | Line 2972 | public class CustomConcurrentHashMap<K,
2972		this.linkage = linkage;
2973		}
2974		public final Node getLinkage() { return linkage; }
2975	<	public final void setLinkage(Node r) { linkage = r; }
2975	>	public final void setLinkage(Node linkage) { this.linkage = linkage; }
2976		}
2977
2978		static final class IntKeySoftValueNodeFactory
#	Line 2990 | Line 3001 | public class CustomConcurrentHashMap<K,
3001		static final long segmentsBase;
3002		static final int segmentsShift;
3003
2993	–	private static Unsafe getUnsafe() throws Throwable {
2994	–	try {
2995	–	return Unsafe.getUnsafe();
2996	–	} catch (SecurityException se) {
2997	–	try {
2998	–	return java.security.AccessController.doPrivileged
2999	–	(new java.security.PrivilegedExceptionAction<Unsafe>() {
3000	–	public Unsafe run() throws Exception {
3001	–	return getUnsafePrivileged();
3002	–	}});
3003	–	} catch (java.security.PrivilegedActionException e) {
3004	–	throw e.getCause();
3005	–	}
3006	–	}
3007	–	}
3008	–
3009	–	private static Unsafe getUnsafePrivileged()
3010	–	throws NoSuchFieldException, IllegalAccessException {
3011	–	Field f = Unsafe.class.getDeclaredField("theUnsafe");
3012	–	f.setAccessible(true);
3013	–	return (Unsafe) f.get(null);
3014	–	}
3015	–
3004		static {
3005		try {
3006		UNSAFE = getUnsafe();
3007		tableBase = UNSAFE.arrayBaseOffset(Node[].class);
3008	<	int s = UNSAFE.arrayIndexScale(Node[].class);
3009	<	if ((s & (s-1)) != 0)
3008	>	int scale = UNSAFE.arrayIndexScale(Node[].class);
3009	>	if ((scale & (scale - 1)) != 0)
3010		throw new Error("data type scale not a power of two");
3011	<	tableShift = 31 - Integer.numberOfLeadingZeros(s);
3011	>	tableShift = 31 - Integer.numberOfLeadingZeros(scale);
3012		segmentsBase = UNSAFE.arrayBaseOffset(Segment[].class);
3013	<	s = UNSAFE.arrayIndexScale(Segment[].class);
3014	<	if ((s & (s-1)) != 0)
3013	>	scale = UNSAFE.arrayIndexScale(Segment[].class);
3014	>	if ((scale & (scale - 1)) != 0)
3015		throw new Error("data type scale not a power of two");
3016	<	segmentsShift = 31 - Integer.numberOfLeadingZeros(s);
3016	>	segmentsShift = 31 - Integer.numberOfLeadingZeros(scale);
3017		} catch (Throwable e) {
3018		throw new RuntimeException("Could not initialize intrinsics", e);
3019		}
3020		}
3021
3022		// Fenced store into segment table array. Unneeded when we have Fences
3023	<	static final  void storeNode(Node[] table,
3024	<	int i, Node r) {
3023	>	static final void storeNode(Node[] table,
3024	>	int i, Node r) {
3025		long nodeOffset = ((long) i << tableShift) + tableBase;
3026		UNSAFE.putOrderedObject(table, nodeOffset, r);
3027		}
3028
3029	<	static final  void storeSegment(Segment[] segs,
3030	<	int i, Segment s) {
3029	>	static final void storeSegment(Segment[] segs,
3030	>	int i, Segment s) {
3031		long segmentOffset = ((long) i << segmentsShift) + segmentsBase;
3032		UNSAFE.putOrderedObject(segs, segmentOffset, s);
3033		}
3034
3035	<
3035	>	/**
3036	>	* Returns a sun.misc.Unsafe.  Suitable for use in a 3rd party package.
3037	>	* Replace with a simple call to Unsafe.getUnsafe when integrating
3038	>	* into a jdk.
3039	>	*
3040	>	* @return a sun.misc.Unsafe
3041	>	*/
3042	>	private static sun.misc.Unsafe getUnsafe() {
3043	>	try {
3044	>	return sun.misc.Unsafe.getUnsafe();
3045	>	} catch (SecurityException tryReflectionInstead) {}
3046	>	try {
3047	>	return java.security.AccessController.doPrivileged
3048	>	(new java.security.PrivilegedExceptionAction<sun.misc.Unsafe>() {
3049	>	public sun.misc.Unsafe run() throws Exception {
3050	>	Class<sun.misc.Unsafe> k = sun.misc.Unsafe.class;
3051	>	for (java.lang.reflect.Field f : k.getDeclaredFields()) {
3052	>	f.setAccessible(true);
3053	>	Object x = f.get(null);
3054	>	if (k.isInstance(x))
3055	>	return k.cast(x);
3056	>	}
3057	>	throw new NoSuchFieldError("the Unsafe");
3058	>	}});
3059	>	} catch (java.security.PrivilegedActionException e) {
3060	>	throw new RuntimeException("Could not initialize intrinsics",
3061	>	e.getCause());
3062	>	}
3063	>	}
3064		}

Diff Legend

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