----------------------------------------------------------------
Unincorporated changes:
----------------------------------------------------------------
changeset: 60185:50d5266f275f
user: chegar
date: Fri Apr 03 17:20:45 2020 +0100
summary: 8237117: Better ForkJoinPool behavior
diff --git a/src/java.base/share/classes/java/util/concurrent/ForkJoinWorkerThread.java b/src/java.base/share/classes/java/util/concurrent/ForkJoinWorkerThread.java
--- a/src/java.base/share/classes/java/util/concurrent/ForkJoinWorkerThread.java
+++ b/src/java.base/share/classes/java/util/concurrent/ForkJoinWorkerThread.java
@@ -78,6 +78,11 @@
final ForkJoinPool pool; // the pool this thread works in
final ForkJoinPool.WorkQueue workQueue; // work-stealing mechanics
+ /** An AccessControlContext supporting no privileges */
+ private static final AccessControlContext INNOCUOUS_ACC =
+ new AccessControlContext(
+ new ProtectionDomain[] { new ProtectionDomain(null, null) });
+
/**
* Creates a ForkJoinWorkerThread operating in the given pool.
*
@@ -99,6 +104,7 @@
ForkJoinWorkerThread(ForkJoinPool pool, ClassLoader ccl) {
super("aForkJoinWorkerThread");
super.setContextClassLoader(ccl);
+ ThreadLocalRandom.setInheritedAccessControlContext(this, INNOCUOUS_ACC);
this.pool = pool;
this.workQueue = pool.registerWorker(this);
}
@@ -214,11 +220,6 @@
group, "InnocuousForkJoinWorkerThreadGroup");
}});
- /** An AccessControlContext supporting no privileges */
- private static final AccessControlContext INNOCUOUS_ACC =
- new AccessControlContext(
- new ProtectionDomain[] { new ProtectionDomain(null, null) });
-
InnocuousForkJoinWorkerThread(ForkJoinPool pool) {
super(pool,
ClassLoader.getSystemClassLoader(),
changeset: 60186:fea3019d444a
user: smarks
date: Tue Apr 07 13:27:55 2020 -0700
summary: 8231800: Better listing of arrays
diff --git a/src/java.base/share/classes/java/util/ArrayList.java b/src/java.base/share/classes/java/util/ArrayList.java
--- a/src/java.base/share/classes/java/util/ArrayList.java
+++ b/src/java.base/share/classes/java/util/ArrayList.java
@@ -178,15 +178,16 @@
* @throws NullPointerException if the specified collection is null
*/
public ArrayList(Collection extends E> c) {
- elementData = c.toArray();
- if ((size = elementData.length) != 0) {
- // defend against c.toArray (incorrectly) not returning Object[]
- // (see e.g. https://bugs.openjdk.java.net/browse/JDK-6260652)
- if (elementData.getClass() != Object[].class)
- elementData = Arrays.copyOf(elementData, size, Object[].class);
+ Object[] a = c.toArray();
+ if ((size = a.length) != 0) {
+ if (c.getClass() == ArrayList.class) {
+ elementData = a;
+ } else {
+ elementData = Arrays.copyOf(a, size, Object[].class);
+ }
} else {
// replace with empty array.
- this.elementData = EMPTY_ELEMENTDATA;
+ elementData = EMPTY_ELEMENTDATA;
}
}
diff --git a/src/java.base/share/classes/java/util/PriorityQueue.java b/src/java.base/share/classes/java/util/PriorityQueue.java
--- a/src/java.base/share/classes/java/util/PriorityQueue.java
+++ b/src/java.base/share/classes/java/util/PriorityQueue.java
@@ -263,8 +263,7 @@
private void initElementsFromCollection(Collection extends E> c) {
Object[] es = c.toArray();
int len = es.length;
- // If c.toArray incorrectly doesn't return Object[], copy it.
- if (es.getClass() != Object[].class)
+ if (c.getClass() != ArrayList.class)
es = Arrays.copyOf(es, len, Object[].class);
if (len == 1 || this.comparator != null)
for (Object e : es)
diff --git a/src/java.base/share/classes/java/util/Vector.java b/src/java.base/share/classes/java/util/Vector.java
--- a/src/java.base/share/classes/java/util/Vector.java
+++ b/src/java.base/share/classes/java/util/Vector.java
@@ -179,12 +179,13 @@
* @since 1.2
*/
public Vector(Collection extends E> c) {
- elementData = c.toArray();
- elementCount = elementData.length;
- // defend against c.toArray (incorrectly) not returning Object[]
- // (see e.g. https://bugs.openjdk.java.net/browse/JDK-6260652)
- if (elementData.getClass() != Object[].class)
- elementData = Arrays.copyOf(elementData, elementCount, Object[].class);
+ Object[] a = c.toArray();
+ elementCount = a.length;
+ if (c.getClass() == ArrayList.class) {
+ elementData = a;
+ } else {
+ elementData = Arrays.copyOf(a, elementCount, Object[].class);
+ }
}
/**
diff --git a/src/java.base/share/classes/java/util/concurrent/CopyOnWriteArrayList.java b/src/java.base/share/classes/java/util/concurrent/CopyOnWriteArrayList.java
--- a/src/java.base/share/classes/java/util/concurrent/CopyOnWriteArrayList.java
+++ b/src/java.base/share/classes/java/util/concurrent/CopyOnWriteArrayList.java
@@ -36,6 +36,7 @@
import java.lang.invoke.VarHandle;
import java.lang.reflect.Field;
+import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collection;
import java.util.Comparator;
@@ -139,9 +140,7 @@
es = ((CopyOnWriteArrayList>)c).getArray();
else {
es = c.toArray();
- // defend against c.toArray (incorrectly) not returning Object[]
- // (see e.g. https://bugs.openjdk.java.net/browse/JDK-6260652)
- if (es.getClass() != Object[].class)
+ if (c.getClass() != java.util.ArrayList.class)
es = Arrays.copyOf(es, es.length, Object[].class);
}
setArray(es);
@@ -690,6 +689,9 @@
*/
public int addAllAbsent(Collection extends E> c) {
Object[] cs = c.toArray();
+ if (c.getClass() != ArrayList.class) {
+ cs = cs.clone();
+ }
if (cs.length == 0)
return 0;
synchronized (lock) {
@@ -741,9 +743,10 @@
Object[] es = getArray();
int len = es.length;
Object[] newElements;
- if (len == 0 && cs.getClass() == Object[].class)
+ if (len == 0 && (c.getClass() == CopyOnWriteArrayList.class ||
+ c.getClass() == ArrayList.class)) {
newElements = cs;
- else {
+ } else {
newElements = Arrays.copyOf(es, len + cs.length);
System.arraycopy(cs, 0, newElements, len, cs.length);
}
diff --git a/src/java.base/share/classes/java/util/concurrent/PriorityBlockingQueue.java b/src/java.base/share/classes/java/util/concurrent/PriorityBlockingQueue.java
--- a/src/java.base/share/classes/java/util/concurrent/PriorityBlockingQueue.java
+++ b/src/java.base/share/classes/java/util/concurrent/PriorityBlockingQueue.java
@@ -257,8 +257,7 @@
}
Object[] es = c.toArray();
int n = es.length;
- // If c.toArray incorrectly doesn't return Object[], copy it.
- if (es.getClass() != Object[].class)
+ if (c.getClass() != java.util.ArrayList.class)
es = Arrays.copyOf(es, n, Object[].class);
if (screen && (n == 1 || this.comparator != null)) {
for (Object e : es)
changeset: 60216:bd9b43d749fd
user: mr
date: Wed Jul 15 14:21:54 2020 -0700
summary: 8249205: Remove unnecessary trademark symbols
diff --git a/src/java.base/share/classes/java/util/concurrent/locks/Lock.java b/src/java.base/share/classes/java/util/concurrent/locks/Lock.java
--- a/src/java.base/share/classes/java/util/concurrent/locks/Lock.java
+++ b/src/java.base/share/classes/java/util/concurrent/locks/Lock.java
@@ -123,7 +123,7 @@
* memory synchronization semantics as provided by the built-in monitor
* lock, as described in
* Chapter 17 of
- * The Java™ Language Specification:
+ * The Java Language Specification:
*
* - A successful {@code lock} operation has the same memory
* synchronization effects as a successful Lock action.
diff --git a/src/java.base/share/classes/java/util/concurrent/locks/StampedLock.java b/src/java.base/share/classes/java/util/concurrent/locks/StampedLock.java
--- a/src/java.base/share/classes/java/util/concurrent/locks/StampedLock.java
+++ b/src/java.base/share/classes/java/util/concurrent/locks/StampedLock.java
@@ -132,7 +132,7 @@
*
Memory Synchronization. Methods with the effect of
* successfully locking in any mode have the same memory
* synchronization effects as a Lock action, as described in
- * Chapter 17 of The Java™ Language Specification.
+ * Chapter 17 of The Java Language Specification.
* Methods successfully unlocking in write mode have the same memory
* synchronization effects as an Unlock action. In optimistic
* read usages, actions prior to the most recent write mode unlock action
diff --git a/src/java.base/share/classes/java/util/concurrent/package-info.java b/src/java.base/share/classes/java/util/concurrent/package-info.java
--- a/src/java.base/share/classes/java/util/concurrent/package-info.java
+++ b/src/java.base/share/classes/java/util/concurrent/package-info.java
@@ -227,7 +227,7 @@
*
Memory Consistency Properties
*
* Chapter 17 of
- * The Java™ Language Specification defines the
+ * The Java Language Specification defines the
* happens-before relation on memory operations such as reads and
* writes of shared variables. The results of a write by one thread are
* guaranteed to be visible to a read by another thread only if the write
changeset: 60293:44f4a2ddad19
user: darcy
date: Thu Jul 23 22:50:12 2020 -0700
summary: 8250240: Address use of default constructors in the java.util.concurrent
diff --git a/src/java.base/share/classes/java/util/concurrent/AbstractExecutorService.java b/src/java.base/share/classes/java/util/concurrent/AbstractExecutorService.java
--- a/src/java.base/share/classes/java/util/concurrent/AbstractExecutorService.java
+++ b/src/java.base/share/classes/java/util/concurrent/AbstractExecutorService.java
@@ -77,6 +77,11 @@
public abstract class AbstractExecutorService implements ExecutorService {
/**
+ * Constructor for subclasses to call.
+ */
+ public AbstractExecutorService() {}
+
+ /**
* Returns a {@code RunnableFuture} for the given runnable and default
* value.
*
diff --git a/src/java.base/share/classes/java/util/concurrent/ForkJoinTask.java b/src/java.base/share/classes/java/util/concurrent/ForkJoinTask.java
--- a/src/java.base/share/classes/java/util/concurrent/ForkJoinTask.java
+++ b/src/java.base/share/classes/java/util/concurrent/ForkJoinTask.java
@@ -242,6 +242,11 @@
private static final int SIGNAL = 1 << 16; // true if joiner waiting
private static final int SMASK = 0xffff; // short bits for tags
+ /**
+ * Constructor for subclasses to call.
+ */
+ public ForkJoinTask() {}
+
static boolean isExceptionalStatus(int s) { // needed by subclasses
return (s & THROWN) != 0;
}
diff --git a/src/java.base/share/classes/java/util/concurrent/RecursiveAction.java b/src/java.base/share/classes/java/util/concurrent/RecursiveAction.java
--- a/src/java.base/share/classes/java/util/concurrent/RecursiveAction.java
+++ b/src/java.base/share/classes/java/util/concurrent/RecursiveAction.java
@@ -166,6 +166,11 @@
private static final long serialVersionUID = 5232453952276485070L;
/**
+ * Constructor for subclasses to call.
+ */
+ public RecursiveAction() {}
+
+ /**
* The main computation performed by this task.
*/
protected abstract void compute();
diff --git a/src/java.base/share/classes/java/util/concurrent/RecursiveTask.java b/src/java.base/share/classes/java/util/concurrent/RecursiveTask.java
--- a/src/java.base/share/classes/java/util/concurrent/RecursiveTask.java
+++ b/src/java.base/share/classes/java/util/concurrent/RecursiveTask.java
@@ -69,6 +69,11 @@
private static final long serialVersionUID = 5232453952276485270L;
/**
+ * Constructor for subclasses to call.
+ */
+ public RecursiveTask() {}
+
+ /**
* The result of the computation.
*/
@SuppressWarnings("serial") // Conditionally serializable
diff --git a/src/java.base/share/classes/java/util/concurrent/locks/AbstractQueuedLongSynchronizer.java b/src/java.base/share/classes/java/util/concurrent/locks/AbstractQueuedLongSynchronizer.java
--- a/src/java.base/share/classes/java/util/concurrent/locks/AbstractQueuedLongSynchronizer.java
+++ b/src/java.base/share/classes/java/util/concurrent/locks/AbstractQueuedLongSynchronizer.java
@@ -65,6 +65,11 @@
private static final long serialVersionUID = 7373984972572414692L;
+ /**
+ * Constructor for subclasses to call.
+ */
+ public AbstractQueuedLongSynchronizer() {}
+
/*
* To keep sources in sync, the remainder of this source file is
* exactly cloned from AbstractQueuedSynchronizer, replacing class
changeset: 60500:66992d8c1441
user: tvaleev
date: Mon Aug 10 16:14:03 2020 +0000
summary: 8247605: Avoid array allocation when concatenating with empty string
diff --git a/test/jdk/java/util/NavigableMap/LockStep.java b/test/jdk/java/util/NavigableMap/LockStep.java
--- a/test/jdk/java/util/NavigableMap/LockStep.java
+++ b/test/jdk/java/util/NavigableMap/LockStep.java
@@ -46,11 +46,11 @@
import java.util.Comparator;
import java.util.HashSet;
import java.util.Iterator;
-import java.util.List;
import java.util.Map;
import java.util.NavigableMap;
import java.util.NavigableSet;
import java.util.NoSuchElementException;
+import java.util.Objects;
import java.util.Random;
import java.util.Set;
import java.util.TreeMap;
@@ -79,26 +79,26 @@
static void realMain(String[] args) {
size = intArg(args, 0, DEFAULT_SIZE);
- lockSteps(new TreeMap(),
- new ConcurrentSkipListMap());
- lockSteps(new TreeMap(),
- Collections.checkedNavigableMap(new TreeMap(), Integer.class, Integer.class));
- lockSteps(new TreeMap(),
- Collections.synchronizedNavigableMap(new TreeMap()));
- lockSteps(new TreeMap(reverseOrder()),
- new ConcurrentSkipListMap(reverseOrder()));
+ lockSteps(new TreeMap<>(),
+ new ConcurrentSkipListMap<>());
+ lockSteps(new TreeMap<>(),
+ Collections.checkedNavigableMap(new TreeMap<>(), Integer.class, Integer.class));
+ lockSteps(new TreeMap<>(),
+ Collections.synchronizedNavigableMap(new TreeMap<>()));
+ lockSteps(new TreeMap<>(reverseOrder()),
+ new ConcurrentSkipListMap<>(reverseOrder()));
- lockSteps(new TreeSet(),
- new ConcurrentSkipListSet());
- lockSteps(new TreeSet(),
- Collections.checkedNavigableSet(new TreeSet(), Integer.class));
- lockSteps(new TreeSet(),
- Collections.synchronizedNavigableSet(new TreeSet()));
- lockSteps(new TreeSet(reverseOrder()),
- new ConcurrentSkipListSet(reverseOrder()));
+ lockSteps(new TreeSet<>(),
+ new ConcurrentSkipListSet<>());
+ lockSteps(new TreeSet<>(),
+ Collections.checkedNavigableSet(new TreeSet<>(), Integer.class));
+ lockSteps(new TreeSet<>(),
+ Collections.synchronizedNavigableSet(new TreeSet<>()));
+ lockSteps(new TreeSet<>(reverseOrder()),
+ new ConcurrentSkipListSet<>(reverseOrder()));
}
- static void lockSteps(NavigableMap m1, NavigableMap m2) {
+ static void lockSteps(NavigableMap m1, NavigableMap m2) {
if (maybe(4)) m1 = serialClone(m1);
if (maybe(4)) m2 = serialClone(m2);
lockStep(m1,
@@ -119,7 +119,7 @@
fullTailMap(m2.descendingMap()));
}
- static void lockSteps(NavigableSet s1, NavigableSet s2) {
+ static void lockSteps(NavigableSet s1, NavigableSet s2) {
if (maybe(4)) s1 = serialClone(s1);
if (maybe(4)) s2 = serialClone(s2);
lockStep(s1,
@@ -140,47 +140,47 @@
fullTailSet(s2.descendingSet()));
}
- static boolean isAscending(NavigableMap m) {
- Comparator cmp = m.comparator();
+ static boolean isAscending(NavigableMap m) {
+ var cmp = m.comparator();
return (cmp == null || cmp.compare(1, 2) < 0);
}
- static NavigableMap fullSubMap(NavigableMap m) {
+ static NavigableMap fullSubMap(NavigableMap m) {
return isAscending(m)
? m.subMap(Integer.MIN_VALUE, true, Integer.MAX_VALUE, true)
: m.subMap(Integer.MAX_VALUE, true, Integer.MIN_VALUE, true);
}
- static NavigableMap fullHeadMap(NavigableMap m) {
+ static NavigableMap fullHeadMap(NavigableMap m) {
return isAscending(m)
? m.headMap(Integer.MAX_VALUE, true)
: m.headMap(Integer.MIN_VALUE, true);
}
- static NavigableMap fullTailMap(NavigableMap m) {
+ static NavigableMap fullTailMap(NavigableMap m) {
return isAscending(m)
? m.tailMap(Integer.MIN_VALUE, true)
: m.tailMap(Integer.MAX_VALUE, true);
}
- static boolean isAscending(NavigableSet s) {
- Comparator cmp = s.comparator();
+ static boolean isAscending(NavigableSet s) {
+ var cmp = s.comparator();
return (cmp == null || cmp.compare(1, 2) < 0);
}
- static NavigableSet fullSubSet(NavigableSet s) {
+ static NavigableSet fullSubSet(NavigableSet s) {
return isAscending(s)
? s.subSet(Integer.MIN_VALUE, true, Integer.MAX_VALUE, true)
: s.subSet(Integer.MAX_VALUE, true, Integer.MIN_VALUE, true);
}
- static NavigableSet fullHeadSet(NavigableSet s) {
+ static NavigableSet fullHeadSet(NavigableSet s) {
return isAscending(s)
? s.headSet(Integer.MAX_VALUE, true)
: s.headSet(Integer.MIN_VALUE, true);
}
- static NavigableSet fullTailSet(NavigableSet s) {
+ static NavigableSet fullTailSet(NavigableSet s) {
return isAscending(s)
? s.tailSet(Integer.MIN_VALUE, true)
: s.tailSet(Integer.MAX_VALUE, true);
@@ -231,21 +231,17 @@
equal(it.next(), expected);
}
- static Comparator comparator(NavigableSet s) {
- Comparator cmp = s.comparator();
- return cmp != null ? cmp : new Comparator() {
- public int compare(Object o1, Object o2) {
- return ((Comparable) o1).compareTo(o2); }};
+ static Comparator super Integer> comparator(NavigableSet s) {
+ var cmp = s.comparator();
+ return cmp != null ? cmp : Comparator.naturalOrder();
}
- static Comparator comparator(NavigableMap m) {
- Comparator cmp = m.comparator();
- return cmp != null ? cmp : new Comparator() {
- public int compare(Object o1, Object o2) {
- return ((Comparable) o1).compareTo(o2); }};
+ static Comparator super Integer> comparator(NavigableMap m) {
+ var cmp = m.comparator();
+ return cmp != null ? cmp : Comparator.naturalOrder();
}
- static void checkNavigableSet(final NavigableSet s) {
+ static void checkNavigableSet(final NavigableSet s) {
if (s.comparator() == null)
check(s.descendingSet().descendingSet().comparator() == null);
equal(s.isEmpty(), s.size() == 0);
@@ -259,7 +255,7 @@
}
}
}
- Comparator cmp = comparator(s);
+ var cmp = comparator(s);
if (s.isEmpty()) {
THROWS(NoSuchElementException.class,
() -> s.first(),
@@ -269,8 +265,8 @@
equal(null, s.ceiling(1));
equal(null, s.higher(1));
} else {
- Object a = s.first();
- Object z = s.last();
+ Integer a = s.first();
+ Integer z = s.last();
equal(s.lower(a), null);
equal(s.higher(z), null);
equal2(s, s.tailSet(a));
@@ -285,28 +281,27 @@
equal2(s.headSet(a, true), singleton(a));
equal2(s.tailSet(z, true), singleton(z));
}
- Iterator[] its = new Iterator[] {
+ Iterator>[] its = new Iterator[] {
s.iterator(),
s.descendingSet().descendingSet().iterator(),
};
- for (final Iterator it : its)
+ for (final Iterator> it : its)
if (maybe(4))
THROWS(IllegalStateException.class, () -> it.remove());
- Object prev = null;
- for (Object e : s) {
+ Integer prev = null;
+ for (final Integer e : s) {
check(s.contains(e));
- for (Iterator it : its) equalNext(it, e);
+ for (Iterator> it : its) equalNext(it, e);
equal(e, s.ceiling(e));
equal(e, s.floor(e));
check(s.higher(e) == null || cmp.compare(e, s.higher(e)) < 0);
equal(s.lower(e), prev);
- if (prev == null) {
- } else {
+ if (prev != null) {
check(cmp.compare(prev, e) < 0);
}
prev = e;
}
- for (final Iterator it : its) {
+ for (final Iterator> it : its) {
if (maybe(2))
check(! it.hasNext());
Fun fun = () -> it.next();
@@ -324,7 +319,7 @@
check(! it2.hasNext());
}
- static void equalSetsLeaf(final Set s1, final Set s2) {
+ static void equalSetsLeaf(final Set> s1, final Set> s2) {
equal2(s1, s2);
equal( s1.size(), s2.size());
equal( s1.isEmpty(), s2.isEmpty());
@@ -333,8 +328,8 @@
equal( s1.containsAll(s2), s2.containsAll(s1));
}
- static void equalNavigableSetsLeaf(final NavigableSet s1,
- final NavigableSet s2) {
+ static void equalNavigableSetsLeaf(final NavigableSet s1,
+ final NavigableSet s2) {
equal2(s1, s2);
equal( s1.size(), s2.size());
equal( s1.isEmpty(), s2.isEmpty());
@@ -350,16 +345,16 @@
checkNavigableSet(s2);
}
- static void equalNavigableSets(final NavigableSet s1,
- final NavigableSet s2) {
+ static void equalNavigableSets(final NavigableSet s1,
+ final NavigableSet s2) {
equalNavigableSetsLeaf(s1, s2);
equalNavigableSetsLeaf(s1.descendingSet(), s2.descendingSet());
equalNavigableSetsLeaf(s1.descendingSet().descendingSet(), s2);
- Object min = s1.isEmpty() ? Integer.MIN_VALUE : s1.first();
- Object max = s2.isEmpty() ? Integer.MAX_VALUE : s2.last();
+ Integer min = s1.isEmpty() ? Integer.MIN_VALUE : s1.first();
+ Integer max = s2.isEmpty() ? Integer.MAX_VALUE : s2.last();
if (s1.comparator() != null &&
s1.comparator().compare(min, max) > 0) {
- Object tmp = min; min = max; max = tmp;
+ Integer tmp = min; min = max; max = tmp;
}
equalNavigableSetsLeaf(s1.subSet(min, true, max, true),
@@ -368,31 +363,29 @@
s2.tailSet(min, true));
equalNavigableSetsLeaf(s1.headSet(max, true),
s2.headSet(max, true));
- equalNavigableSetsLeaf((NavigableSet) s1.subSet(min, max),
- (NavigableSet) s2.subSet(min, max));
- equalNavigableSetsLeaf((NavigableSet) s1.tailSet(min),
- (NavigableSet) s2.tailSet(min));
- equalNavigableSetsLeaf((NavigableSet) s1.headSet(max),
- (NavigableSet) s2.headSet(max));
+ equalNavigableSetsLeaf((NavigableSet) s1.subSet(min, max),
+ (NavigableSet) s2.subSet(min, max));
+ equalNavigableSetsLeaf((NavigableSet) s1.tailSet(min),
+ (NavigableSet) s2.tailSet(min));
+ equalNavigableSetsLeaf((NavigableSet) s1.headSet(max),
+ (NavigableSet) s2.headSet(max));
}
// Destined for a Collections.java near you?
static T[] concat(T[]... arrays) {
int len = 0;
- for (int i = 0; i < arrays.length; i++)
- len += arrays[i].length;
+ for (T[] arr : arrays) len += arr.length;
T[] a = (T[])java.lang.reflect.Array
.newInstance(arrays[0].getClass().getComponentType(), len);
int k = 0;
- for (int i = 0; i < arrays.length; i++) {
- T[] array = arrays[i];
- System.arraycopy(array, 0, a, k, array.length);
- k += array.length;
+ for (T[] arr : arrays) {
+ System.arraycopy(arr, 0, a, k, arr.length);
+ k += arr.length;
}
return a;
}
- static void checkNavigableMap(final NavigableMap m) {
+ static void checkNavigableMap(final NavigableMap m) {
if (m.comparator() == null) {
check(m.descendingMap().descendingMap().comparator() == null);
check(m.descendingKeySet().descendingSet().comparator() == null);
@@ -402,7 +395,7 @@
if (maybe(4))
equal2(m, serialClone(m));
equal2(m.keySet(), m.descendingKeySet());
- Comparator cmp = comparator(m);
+ var cmp = comparator(m);
if (m.isEmpty()) {
THROWS(NoSuchElementException.class,
() -> m.firstKey(),
@@ -420,8 +413,8 @@
equal(null, m.ceilingEntry(1));
equal(null, m.higherEntry(1));
} else {
- Object a = m.firstKey();
- Object z = m.lastKey();
+ Integer a = m.firstKey();
+ Integer z = m.lastKey();
equal(m.lowerKey(a), null);
equal(m.higherKey(z), null);
equal(a, m.firstEntry().getKey());
@@ -439,32 +432,32 @@
equal2(m.tailMap(z, true), singletonMap(z, m.get(z)));
}
- Iterator[] kits = new Iterator[] {
+ Iterator>[] kits = new Iterator[] {
m.keySet().iterator(),
m.descendingMap().descendingKeySet().iterator(),
m.descendingKeySet().descendingSet().iterator(),
};
- Iterator[] vits = new Iterator[] {
+ Iterator>[] vits = new Iterator[] {
m.values().iterator(),
m.descendingMap().descendingMap().values().iterator(),
};
- Iterator[] eits = new Iterator[] {
+ Iterator>[] eits = new Iterator[] {
m.entrySet().iterator(),
m.descendingMap().descendingMap().entrySet().iterator(),
};
- Iterator[] its = concat(kits, vits, eits);
- for (final Iterator it : its)
+ Iterator>[] its = concat(kits, vits, eits);
+ for (final Iterator> it : its)
if (maybe(4))
THROWS(IllegalStateException.class, () -> it.remove());
- Map.Entry prev = null;
- for (Map.Entry e : (Set) m.entrySet()) {
- Object k = e.getKey();
- Object v = e.getValue();
+ Map.Entry prev = null;
+ for (var e : m.entrySet()) {
+ Integer k = e.getKey();
+ Integer v = e.getValue();
check(m.containsKey(k));
check(m.containsValue(v));
- for (Iterator kit : kits) equalNext(kit, k);
- for (Iterator vit : vits) equalNext(vit, v);
- for (Iterator eit : eits) equalNext(eit, e);
+ for (var kit : kits) equalNext(kit, k);
+ for (var vit : vits) equalNext(vit, v);
+ for (var eit : eits) equalNext(eit, e);
equal(k, m.ceilingKey(k));
equal(k, m.ceilingEntry(k).getKey());
equal(k, m.floorKey(k));
@@ -480,7 +473,7 @@
}
prev = e;
}
- for (final Iterator it : its) {
+ for (final var it : its) {
if (maybe(2))
check(! it.hasNext());
Fun fun = () -> it.next();
@@ -488,8 +481,8 @@
}
}
- static void equalNavigableMapsLeaf(final NavigableMap m1,
- final NavigableMap m2) {
+ static void equalNavigableMapsLeaf(final NavigableMap m1,
+ final NavigableMap m2) {
equal2(m1, m2);
equal( m1.size(), m2.size());
equal( m1.isEmpty(), m2.isEmpty());
@@ -501,8 +494,8 @@
checkNavigableMap(m2);
}
- static void equalNavigableMaps(NavigableMap m1,
- NavigableMap m2) {
+ static void equalNavigableMaps(NavigableMap m1,
+ NavigableMap m2) {
equalNavigableMapsLeaf(m1, m2);
equalSetsLeaf(m1.keySet(), m2.keySet());
equalNavigableSets(m1.navigableKeySet(),
@@ -515,8 +508,8 @@
m2.descendingMap());
equalNavigableMapsLeaf(m1.descendingMap().descendingMap(),
m2);
- equalNavigableSetsLeaf((NavigableSet) m1.descendingMap().keySet(),
- (NavigableSet) m2.descendingMap().keySet());
+ equalNavigableSetsLeaf((NavigableSet) m1.descendingMap().keySet(),
+ (NavigableSet) m2.descendingMap().keySet());
equalNavigableSetsLeaf(m1.descendingMap().descendingKeySet(),
m2.descendingMap().descendingKeySet());
equal2(m1.descendingMap().entrySet(),
@@ -525,11 +518,11 @@
//----------------------------------------------------------------
// submaps
//----------------------------------------------------------------
- Object min = Integer.MIN_VALUE;
- Object max = Integer.MAX_VALUE;
+ Integer min = Integer.MIN_VALUE;
+ Integer max = Integer.MAX_VALUE;
if (m1.comparator() != null
&& m1.comparator().compare(min, max) > 0) {
- Object tmp = min; min = max; max = tmp;
+ Integer tmp = min; min = max; max = tmp;
}
switch (rnd.nextInt(6)) {
case 0:
@@ -545,107 +538,119 @@
m2.headMap(max, true));
break;
case 3:
- equalNavigableMapsLeaf((NavigableMap) m1.subMap(min, max),
- (NavigableMap) m2.subMap(min, max));
+ equalNavigableMapsLeaf((NavigableMap) m1.subMap(min, max),
+ (NavigableMap) m2.subMap(min, max));
break;
case 4:
- equalNavigableMapsLeaf((NavigableMap) m1.tailMap(min),
- (NavigableMap) m2.tailMap(min));
+ equalNavigableMapsLeaf((NavigableMap) m1.tailMap(min),
+ (NavigableMap) m2.tailMap(min));
break;
case 5:
- equalNavigableMapsLeaf((NavigableMap) m1.headMap(max),
- (NavigableMap) m2.headMap(max));
+ equalNavigableMapsLeaf((NavigableMap) m1.headMap(max),
+ (NavigableMap) m2.headMap(max));
break;
}
}
- abstract static class MapFrobber { abstract void frob(NavigableMap m); }
- abstract static class SetFrobber { abstract void frob(NavigableSet m); }
+ interface MapFrobber { void frob(NavigableMap m); }
+ interface SetFrobber { void frob(NavigableSet m); }
- static MapFrobber randomAdder(NavigableMap m) {
+ static MapFrobber randomAdder(NavigableMap m) {
final Integer k = unusedKey(m);
final MapFrobber[] randomAdders = {
- new MapFrobber() {void frob(NavigableMap m) {
- equal(m.put(k, k+1), null);
- equal(m.get(k), k+1);
+ map -> {
+ equal(map.put(k, k + 1), null);
+ equal(map.get(k), k + 1);
if (maybe(4)) {
- equal(m.put(k, k+1), k+1);
- equal(m.get(k), k+1);}}},
- new MapFrobber() {void frob(NavigableMap m) {
- m.descendingMap().put(k, k+1);
- equal(m.get(k), k+1);}},
- new MapFrobber() {void frob(NavigableMap m) {
- m.tailMap(k,true).headMap(k,true).put(k,k+1);}},
- new MapFrobber() {void frob(NavigableMap m) {
- m.tailMap(k,true).headMap(k,true).descendingMap().put(k,k+1);}}
+ equal(map.put(k, k + 1), k + 1);
+ equal(map.get(k), k + 1);}},
+ map -> {
+ map.descendingMap().put(k, k + 1);
+ equal(map.get(k), k + 1);},
+ map -> map.tailMap(k,true).headMap(k,true).put(k, k + 1),
+ map -> {
+ equal(map.tailMap(k,true).headMap(k,true).putIfAbsent(k, k + 1), null);
+ equal(map.tailMap(k,true).headMap(k,true).putIfAbsent(k, k + 1), k + 1);},
+ map -> {
+ equal(map.tailMap(k,true).headMap(k,true).merge(k,k,Integer::sum), k);
+ equal(map.tailMap(k,true).headMap(k,true).merge(k,1,Integer::sum), k+1);},
+ map -> equal(map.subMap(k,true, k, true).computeIfAbsent(k, key -> key + 1), k + 1),
+ map -> {
+ equal(map.subMap(k,true, k, true).computeIfPresent(k, (key, val) -> 1), null);
+ equal(map.tailMap(k,true).compute(k, (key, val) -> {
+ equal(val, null);
+ return 1;
+ }), 1);
+ equal(map.headMap(k, true).computeIfPresent(k, (key, val) -> val + key), k + 1);
+ equal(map.tailMap(k, false).computeIfPresent(k, (key, val) -> 1), null);
+ equal(map.headMap(k, false).compute(k, (key, val) -> null), null);
+ equal(map.tailMap(k, false).computeIfAbsent(k, key -> null), null);
+ },
+ map -> map.tailMap(k,true).headMap(k,true).descendingMap().put(k, k + 1)
};
- return new MapFrobber() {void frob(NavigableMap m) {
- randomAdders[rnd.nextInt(randomAdders.length)].frob(m);
- if (maybe(2)) equal(m.get(k), k+1);
+ return map -> {
+ randomAdders[rnd.nextInt(randomAdders.length)].frob(map);
+ if (maybe(2)) equal(map.get(k), k + 1);
if (maybe(4)) {
- equal(m.put(k, k+1), k+1);
- equal(m.get(k), k+1);}}};
+ equal(map.put(k, k + 1), k + 1);
+ equal(map.get(k), k + 1);}};
}
- static SetFrobber randomAdder(NavigableSet s) {
+ static SetFrobber randomAdder(NavigableSet s) {
final Integer e = unusedElt(s);
final SetFrobber[] randomAdders = {
- new SetFrobber() {void frob(NavigableSet s) {
- check(s.add(e));}},
- new SetFrobber() {void frob(NavigableSet s) {
- s.descendingSet().add(e);}},
- new SetFrobber() {void frob(NavigableSet s) {
- s.tailSet(e,true).headSet(e,true).add(e);}},
- new SetFrobber() {void frob(NavigableSet s) {
- s.descendingSet().tailSet(e,true).headSet(e,true).add(e);}}
+ set -> check(set.add(e)),
+ set -> set.descendingSet().add(e),
+ set -> set.tailSet(e,true).headSet(e,true).add(e),
+ set -> set.descendingSet().tailSet(e,true).headSet(e,true).add(e)
};
- return new SetFrobber() {void frob(NavigableSet s) {
- if (maybe(2)) check(! s.contains(e));
- randomAdders[rnd.nextInt(randomAdders.length)].frob(s);
- if (maybe(2)) check(! s.add(e));
- if (maybe(2)) check(s.contains(e));}};
+ return set -> {
+ if (maybe(2)) check(! set.contains(e));
+ randomAdders[rnd.nextInt(randomAdders.length)].frob(set);
+ if (maybe(2)) check(! set.add(e));
+ if (maybe(2)) check(set.contains(e));};
}
- static Integer unusedElt(NavigableSet s) {
+ static Integer unusedElt(NavigableSet s) {
Integer e;
do { e = rnd.nextInt(1024); }
while (s.contains(e));
return e;
}
- static Integer unusedKey(NavigableMap m) {
+ static Integer unusedKey(NavigableMap m) {
Integer k;
do { k = rnd.nextInt(1024); }
while (m.containsKey(k));
return k;
}
- static Integer usedKey(NavigableMap m) {
+ static Integer usedKey(NavigableMap m) {
Integer x = rnd.nextInt(1024);
- Integer floor = (Integer) m.floorKey(x);
- Integer ceiling = (Integer) m.ceilingKey(x);
+ Integer floor = m.floorKey(x);
+ Integer ceiling = m.ceilingKey(x);
if (floor != null) return floor;
check(ceiling != null);
return ceiling;
}
- static Integer usedElt(NavigableSet s) {
+ static Integer usedElt(NavigableSet s) {
Integer x = rnd.nextInt(1024);
- Integer floor = (Integer) s.floor(x);
- Integer ceiling = (Integer) s.ceiling(x);
+ Integer floor = s.floor(x);
+ Integer ceiling = s.ceiling(x);
if (floor != null) return floor;
check(ceiling != null);
return ceiling;
}
- static void checkUnusedKey(NavigableMap m, Object k) {
+ static void checkUnusedKey(NavigableMap m, Integer k) {
check(! m.containsKey(k));
equal(m.get(k), null);
if (maybe(2))
equal(m.remove(k), null);
}
- static void checkUnusedElt(NavigableSet s, Object e) {
+ static void checkUnusedElt(NavigableSet s, Integer e) {
if (maybe(2))
check(! s.contains(e));
if (maybe(2)) {
@@ -656,42 +661,32 @@
check(! s.remove(e));
}
- static Fun remover(final Iterator it) {
+ static Fun remover(final Iterator> it) {
return () -> it.remove();
}
- static MapFrobber randomRemover(NavigableMap m) {
+ static MapFrobber randomRemover(NavigableMap m) {
final Integer k = usedKey(m);
final MapFrobber[] randomRemovers = {
- new MapFrobber() {void frob(NavigableMap m) {
- Map.Entry e = m.firstEntry();
- equal(m.pollFirstEntry(), e);
- checkUnusedKey(m, e.getKey());}},
- new MapFrobber() {void frob(NavigableMap m) {
- Map.Entry e = m.lastEntry();
- equal(m.pollLastEntry(), e);
- checkUnusedKey(m, e.getKey());}},
- new MapFrobber() {void frob(NavigableMap m) {
- check(m.remove(k) != null);
- checkUnusedKey(m, k);}},
- new MapFrobber() {void frob(NavigableMap m) {
- m.subMap(k, true, k, true).clear();
- checkUnusedKey(m, k);}},
- new MapFrobber() {void frob(NavigableMap m) {
- m.descendingMap().subMap(k, true, k, true).clear();
- checkUnusedKey(m, k);}},
- new MapFrobber() {void frob(NavigableMap m) {
- final Iterator it = m.keySet().iterator();
- while (it.hasNext())
- if (it.next().equals(k)) {
- it.remove();
- if (maybe(2))
- THROWS(IllegalStateException.class,
- () -> it.remove());
- }
- checkUnusedKey(m, k);}},
- new MapFrobber() {void frob(NavigableMap m) {
- final Iterator it = m.navigableKeySet().descendingIterator();
+ map -> {
+ var e = map.firstEntry();
+ equal(map.pollFirstEntry(), e);
+ checkUnusedKey(map, e.getKey());},
+ map -> {
+ var e = map.lastEntry();
+ equal(map.pollLastEntry(), e);
+ checkUnusedKey(map, e.getKey());},
+ map -> {
+ check(map.remove(k) != null);
+ checkUnusedKey(map, k);},
+ map -> {
+ map.subMap(k, true, k, true).clear();
+ checkUnusedKey(map, k);},
+ map -> {
+ map.descendingMap().subMap(k, true, k, true).clear();
+ checkUnusedKey(map, k);},
+ map -> {
+ final var it = map.keySet().iterator();
while (it.hasNext())
if (it.next().equals(k)) {
it.remove();
@@ -699,54 +694,54 @@
THROWS(IllegalStateException.class,
() -> it.remove());
}
- checkUnusedKey(m, k);}},
- new MapFrobber() {void frob(NavigableMap m) {
- final Iterator it = m.entrySet().iterator();
+ checkUnusedKey(map, k);},
+ map -> {
+ final var it = map.navigableKeySet().descendingIterator();
+ while (it.hasNext())
+ if (it.next().equals(k)) {
+ it.remove();
+ if (maybe(2))
+ THROWS(IllegalStateException.class,
+ () -> it.remove());
+ }
+ checkUnusedKey(map, k);},
+ map -> {
+ final var it = map.entrySet().iterator();
while (it.hasNext())
if (it.next().getKey().equals(k)) {
it.remove();
if (maybe(2))
THROWS(IllegalStateException.class, remover(it));
}
- checkUnusedKey(m, k);}},
+ checkUnusedKey(map, k);},
};
return randomRemovers[rnd.nextInt(randomRemovers.length)];
}
- static SetFrobber randomRemover(NavigableSet s) {
+ static SetFrobber randomRemover(NavigableSet s) {
final Integer e = usedElt(s);
final SetFrobber[] randomRemovers = {
- new SetFrobber() {void frob(NavigableSet s) {
- Object e = s.first();
- equal(s.pollFirst(), e);
- checkUnusedElt(s, e);}},
- new SetFrobber() {void frob(NavigableSet s) {
- Object e = s.last();
- equal(s.pollLast(), e);
- checkUnusedElt(s, e);}},
- new SetFrobber() {void frob(NavigableSet s) {
- check(s.remove(e));
- checkUnusedElt(s, e);}},
- new SetFrobber() {void frob(NavigableSet s) {
- s.subSet(e, true, e, true).clear();
- checkUnusedElt(s, e);}},
- new SetFrobber() {void frob(NavigableSet s) {
- s.descendingSet().subSet(e, true, e, true).clear();
- checkUnusedElt(s, e);}},
- new SetFrobber() {void frob(NavigableSet s) {
- final Iterator it = s.iterator();
- while (it.hasNext())
- if (it.next().equals(e)) {
- it.remove();
- if (maybe(2))
- THROWS(IllegalStateException.class,
- () -> it.remove());
- }
- checkUnusedElt(s, e);}},
- new SetFrobber() {void frob(NavigableSet s) {
- final Iterator it = s.descendingSet().iterator();
+ set -> {
+ var fst = set.first();
+ equal(set.pollFirst(), fst);
+ checkUnusedElt(set, fst);},
+ set -> {
+ var lst = set.last();
+ equal(set.pollLast(), lst);
+ checkUnusedElt(set, lst);},
+ set -> {
+ check(set.remove(e));
+ checkUnusedElt(set, e);},
+ set -> {
+ set.subSet(e, true, e, true).clear();
+ checkUnusedElt(set, e);},
+ set -> {
+ set.descendingSet().subSet(e, true, e, true).clear();
+ checkUnusedElt(set, e);},
+ set -> {
+ final var it = set.iterator();
while (it.hasNext())
if (it.next().equals(e)) {
it.remove();
@@ -754,9 +749,9 @@
THROWS(IllegalStateException.class,
() -> it.remove());
}
- checkUnusedElt(s, e);}},
- new SetFrobber() {void frob(NavigableSet s) {
- final Iterator it = s.descendingIterator();
+ checkUnusedElt(set, e);},
+ set -> {
+ final var it = set.descendingSet().iterator();
while (it.hasNext())
if (it.next().equals(e)) {
it.remove();
@@ -764,94 +759,106 @@
THROWS(IllegalStateException.class,
() -> it.remove());
}
- checkUnusedElt(s, e);}}
+ checkUnusedElt(set, e);},
+ set -> {
+ final var it = set.descendingIterator();
+ while (it.hasNext())
+ if (it.next().equals(e)) {
+ it.remove();
+ if (maybe(2))
+ THROWS(IllegalStateException.class,
+ () -> it.remove());
+ }
+ checkUnusedElt(set, e);}
};
return randomRemovers[rnd.nextInt(randomRemovers.length)];
}
- static void lockStep(NavigableMap m1,
- NavigableMap m2) {
+ static void lockStep(NavigableMap m1,
+ NavigableMap m2) {
if (! (thorough || maybe(3))) return;
if (maybe(4)) m1 = serialClone(m1);
if (maybe(4)) m2 = serialClone(m2);
- List maps = Arrays.asList(m1, m2);
- for (NavigableMap m : maps) testEmptyMap(m);
+ var maps = Arrays.asList(m1, m2);
+ for (var m : maps) testEmptyMap(m);
final Set ints = new HashSet<>();
while (ints.size() < size)
ints.add(rnd.nextInt(1024));
final Integer[] elts = ints.toArray(new Integer[size]);
+ equal(elts.length, size);
for (int i = 0; i < size; i++) {
MapFrobber adder = randomAdder(m1);
- for (final NavigableMap m : maps) {
+ for (var m : maps) {
adder.frob(m);
equal(m.size(), i+1);
}
equalNavigableMaps(m1, m2);
}
- for (final NavigableMap m : maps) {
- final Object e = usedKey(m);
+ for (var m : maps) {
+ final var e = usedKey(m);
THROWS(IllegalArgumentException.class,
- () -> {m.subMap(e,true,e,false)
- .subMap(e,true,e,true);},
- () -> {m.subMap(e,false,e,true)
- .subMap(e,true,e,true);},
+ () -> m.subMap(e,true,e,false).subMap(e,true,e,true),
+ () -> m.subMap(e,false,e,true).subMap(e,true,e,true),
() -> m.tailMap(e,false).tailMap(e,true),
- () -> m.headMap(e,false).headMap(e,true));
+ () -> m.headMap(e,false).headMap(e,true),
+ () -> m.headMap(e, false).put(e, 0),
+ () -> m.tailMap(e, false).putIfAbsent(e, 0),
+ () -> m.headMap(e, false).computeIfAbsent(e, k -> 1),
+ () -> m.tailMap(e, false).compute(e, (k, v) -> 0));
}
//System.out.printf("%s%n", m1);
for (int i = size; i > 0; i--) {
MapFrobber remover = randomRemover(m1);
- for (final NavigableMap m : maps) {
+ for (var m : maps) {
remover.frob(m);
equal(m.size(), i-1);
}
equalNavigableMaps(m1, m2);
}
- for (NavigableMap m : maps) testEmptyMap(m);
+ for (var m : maps) testEmptyMap(m);
}
- static void lockStep(NavigableSet s1,
- NavigableSet s2) {
+ static void lockStep(NavigableSet s1,
+ NavigableSet s2) {
if (! (thorough || maybe(3))) return;
if (maybe(4)) s1 = serialClone(s1);
if (maybe(4)) s2 = serialClone(s2);
- List sets = Arrays.asList(s1, s2);
- for (NavigableSet s : sets) testEmptySet(s);
+ var sets = Arrays.asList(s1, s2);
+ for (var s : sets) testEmptySet(s);
final Set ints = new HashSet<>();
while (ints.size() < size)
ints.add(rnd.nextInt(1024));
final Integer[] elts = ints.toArray(new Integer[size]);
+ equal(elts.length, size);
for (int i = 0; i < size; i++) {
SetFrobber adder = randomAdder(s1);
- for (final NavigableSet s : sets) {
+ for (var s : sets) {
adder.frob(s);
equal(s.size(), i+1);
}
equalNavigableSets(s1, s2);
}
- for (final NavigableSet s : sets) {
- final Object e = usedElt(s);
+ for (var s : sets) {
+ final Integer e = usedElt(s);
THROWS(IllegalArgumentException.class,
- () -> {s.subSet(e,true,e,false)
- .subSet(e,true,e,true);},
- () -> {s.subSet(e,false,e,true)
- .subSet(e,true,e,true);},
+ () -> s.subSet(e,true,e,false).subSet(e,true,e,true),
+ () -> s.subSet(e,false,e,true).subSet(e,true,e,true),
() -> s.tailSet(e,false).tailSet(e,true),
() -> s.headSet(e,false).headSet(e,true));
}
//System.out.printf("%s%n", s1);
for (int i = size; i > 0; i--) {
SetFrobber remover = randomRemover(s1);
- for (final NavigableSet s : sets) {
+ for (var s : sets) {
remover.frob(s);
equal(s.size(), i-1);
}
equalNavigableSets(s1, s2);
}
- for (NavigableSet s : sets) testEmptySet(s);
+ for (var s : sets) testEmptySet(s);
}
//--------------------- Infrastructure ---------------------------
@@ -862,7 +869,7 @@
static void unexpected(Throwable t) { failed++; t.printStackTrace(); }
static void check(boolean cond) { if (cond) pass(); else fail(); }
static void equal(Object x, Object y) {
- if (x == null ? y == null : x.equals(y)) pass();
+ if (Objects.equals(x, y)) pass();
else {System.out.println(x + " not equal to " + y); fail();}}
static void equal2(Object x, Object y) {equal(x, y); equal(y, x);}
public static void main(String[] args) throws Throwable {
+ exit 0
export-jsr166 3665.78 user 282.10 system 319% cpu 1237.48 total
next ...