777 |
|
public void testReduceKeysToIntSequentially() { |
778 |
|
ConcurrentHashMap<Long, Long> m = longMap(); |
779 |
|
int ir = m.reduceKeysToIntSequentially((Long x) -> x.intValue(), 0, Integer::sum); |
780 |
< |
assertEquals(ir, (int)SIZE * (SIZE - 1) / 2); |
780 |
> |
assertEquals(ir, SIZE * (SIZE - 1) / 2); |
781 |
|
} |
782 |
|
|
783 |
|
/* |
804 |
|
public void testReduceValuesToIntSequentially() { |
805 |
|
ConcurrentHashMap<Long, Long> m = longMap(); |
806 |
|
int ir = m.reduceValuesToIntSequentially((Long x) -> x.intValue(), 0, Integer::sum); |
807 |
< |
assertEquals(ir, (int)SIZE * (SIZE - 1)); |
807 |
> |
assertEquals(ir, SIZE * (SIZE - 1)); |
808 |
|
} |
809 |
|
|
810 |
|
/* |
831 |
|
public void testReduceKeysToIntInParallel() { |
832 |
|
ConcurrentHashMap<Long, Long> m = longMap(); |
833 |
|
int ir = m.reduceKeysToIntInParallel((Long x) -> x.intValue(), 0, Integer::sum); |
834 |
< |
assertEquals(ir, (int)SIZE * (SIZE - 1) / 2); |
834 |
> |
assertEquals(ir, SIZE * (SIZE - 1) / 2); |
835 |
|
} |
836 |
|
|
837 |
|
/* |
858 |
|
public void testReduceValuesToIntInParallel() { |
859 |
|
ConcurrentHashMap<Long, Long> m = longMap(); |
860 |
|
int ir = m.reduceValuesToIntInParallel((Long x) -> x.intValue(), 0, Integer::sum); |
861 |
< |
assertEquals(ir, (int)SIZE * (SIZE - 1)); |
861 |
> |
assertEquals(ir, SIZE * (SIZE - 1)); |
862 |
|
} |
863 |
|
|
864 |
|
/* |
1043 |
|
assertEquals(lr, (long)SIZE * (SIZE - 1) / 2); |
1044 |
|
ir = ConcurrentHashMap.ForkJoinTasks.reduceKeysToInt |
1045 |
|
(m, (Long x) -> x.intValue(), 0, Integer::sum).invoke(); |
1046 |
< |
assertEquals(ir, (int)SIZE * (SIZE - 1) / 2); |
1046 |
> |
assertEquals(ir, SIZE * (SIZE - 1) / 2); |
1047 |
|
dr = ConcurrentHashMap.ForkJoinTasks.reduceKeysToDouble |
1048 |
|
(m, (Long x) -> x.doubleValue(), 0.0, Double::sum).invoke(); |
1049 |
|
assertEquals(dr, (double)SIZE * (SIZE - 1) / 2); |
1056 |
|
assertEquals(lr, (long)SIZE * (SIZE - 1)); |
1057 |
|
ir = ConcurrentHashMap.ForkJoinTasks.reduceValuesToInt |
1058 |
|
(m, (Long x) -> x.intValue(), 0, Integer::sum).invoke(); |
1059 |
< |
assertEquals(ir, (int)SIZE * (SIZE - 1)); |
1059 |
> |
assertEquals(ir, SIZE * (SIZE - 1)); |
1060 |
|
dr = ConcurrentHashMap.ForkJoinTasks.reduceValuesToDouble |
1061 |
|
(m, (Long x) -> x.doubleValue(), 0.0, Double::sum).invoke(); |
1062 |
|
assertEquals(dr, (double)SIZE * (SIZE - 1)); |