-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathRectangleSpliterator.java
More file actions
executable file
·67 lines (54 loc) · 2.28 KB
/
RectangleSpliterator.java
File metadata and controls
executable file
·67 lines (54 loc) · 2.28 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
package spliterators.lesson7.exercise;
import java.util.Spliterator;
import java.util.Spliterators;
import java.util.function.IntConsumer;
public class RectangleSpliterator extends Spliterators.AbstractIntSpliterator {
private final int innerLength;
private final int[][] array;
private final int startOuterInclusive;
private final int endOuterExclusive;
private final int startInnerInclusive;
public RectangleSpliterator(int[][] array) {
this(array, 0, array.length, 0);
}
private RectangleSpliterator(int[][] array, int startOuterInclusive, int endOuterExclusive, int startInnerInclusive) {
super(Long.MAX_VALUE, Spliterator.IMMUTABLE | Spliterator.ORDERED | Spliterator.SIZED | Spliterator.SUBSIZED | Spliterator.NONNULL);
innerLength = array.length == 0 ? 0 : array[0].length;
this.array = array;
this.startOuterInclusive = startOuterInclusive;
this.endOuterExclusive = endOuterExclusive;
this.startInnerInclusive = startInnerInclusive;
}
private boolean isSplitterable(){
return endOuterExclusive-startInnerInclusive>=2;
}
@Override
public OfInt trySplit() {
final int aboutMiddleIndex = startInnerInclusive + (endOuterExclusive-startInnerInclusive)/2;
RectangleSpliterator rectangleSpliterator = new RectangleSpliterator(array,
startOuterInclusive,
endOuterExclusive,
aboutMiddleIndex);
this.startInnerInclusive = aboutMiddleIndex; //how???? its final
return isSplitterable()?rectangleSpliterator:null;
}
@Override
public long estimateSize() {
return ((long) endOuterExclusive - startOuterInclusive)*innerLength - startInnerInclusive;
}
private int currentX;
private int currentY;
@Override
public boolean tryAdvance(IntConsumer action) {
if (currentY>array.length && currentX>array[currentY].length)
if (startInnerInclusive<endOuterExclusive){
action.accept(array[currentY][currentX]);
currentX++;
if(currentX>=array[currentY].length){
currentX=0;
currentY++;
}
}
return true;
}
}