JDK-8029452 : Fork/Join task ForEachOps.ForEachOrderedTask clarifications and minor improvements
  • Type: Bug
  • Component: core-libs
  • Sub-Component: java.util.stream
  • Priority: P4
  • Status: Closed
  • Resolution: Fixed
  • Submitted: 2013-12-03
  • Updated: 2016-06-13
  • Resolved: 2014-01-16
The Version table provides details related to the release that this issue/RFE will be addressed.

Unresolved : Release in which this issue/RFE will be addressed.
Resolved: Release in which this issue/RFE has been resolved.
Fixed : Release in which this issue/RFE has been fixed. The release containing this fix may be available for download as an Early Access Release or a General Availability Release.

To download the current JDK release, click here.
8u40Fixed 9 b02Fixed
The Fork/Join task ForEachOps.ForEachOrderedTask can be ...:

1) Instantiate the ConcurrentHashMap with a size of Math.max(16, AbstractTask.LEAF_TARGET << 1), to avoid resizing that can result in slower concurrent operation on the map

2) Evaluate whether the the reporting of elements needs to be within a synchronized block to guarantee a happens-before relationship, if so synchronization should be applied consistently and perhaps the code should be cleaned up as follows:

           if (task.getPendingCount() > 0) {
               Node.Builder<T> nb = task.helper.makeNodeBuilder(
                 size -> (T[]) new Object[size]);
               task.node = task.helper.wrapAndCopyInto(nb, rightSplit).build();
               task.spliterator = null;

       public void onCompletion(CountedCompleter<?> caller) {
           if (node != null) {
               Node<T> _node = node;
               node = null;
               // Dump any data from this leaf into the sink
               synchronized (lock) {
           else if (spliterator != null) {
               Spliterator<S> _spliterator = spliterator;
               spliterator = null;
               // Dump any data output from this leaf's pipeline into the sink
               synchronized (lock) {
                   helper.wrapAndCopyInto(action, _spliterator);
           ForEachOrderedTask<S, T> victim = completionMap.remove(this);
           if (victim != null)