Review CQuery and prepare for correct parallelization.
Please remember about all atomic variables from #63.
Be prepared for derived classes which:
use internally parallel stream if possible
use internally parallel spliterator if possible
API for:
turn on/off query parallelization
check parallelization feature
Implement parallel processing for:
CQList
CQListSupplier
CQArray
CQArraySupplier
CQCollection
CQCollectionSupplier
CQAppend ?
Implement parallel processing for derived streams: prefer parallel if parent stream supports it.
Review CQuery and prepare for correct parallelization.
Please remember about all atomic variables from #63.
Be prepared for derived classes which:
- use internally parallel stream if possible
- use internally parallel spliterator if possible
API for:
- turn on/off query parallelization
- check parallelization feature
Implement parallel processing for:
- CQList
- CQListSupplier
- CQArray
- CQArraySupplier
- CQCollection
- CQCollectionSupplier
- CQAppend ?
Implement parallel processing for derived streams: prefer parallel if parent stream supports it.
todo: we should mark additional feature: "hasFastParallelEach" - it should be returned if implementation of "each" is paralell sensitive and can use internally more than one thread.
In such situations, when fast-parallel-each is supported, we should prefer direct #each call instead of some other generic methods from support package.
Maybe, but this is really maybe: write additional method forEachParallel & whileEachParallel?
todo: we should mark additional feature: "hasFastParallelEach" - it should be returned if implementation of "each" is paralell sensitive and can use internally more than one thread.
In such situations, when fast-parallel-each is supported, we should prefer direct #each call instead of some other generic methods from `support` package.
Maybe, but this is *really* maybe: write additional method `forEachParallel` & `whileEachParallel`?
Review CQuery and prepare for correct parallelization.
Please remember about all atomic variables from #63.
Be prepared for derived classes which:
API for:
Implement parallel processing for:
Implement parallel processing for derived streams: prefer parallel if parent stream supports it.
todo: we should mark additional feature: "hasFastParallelEach" - it should be returned if implementation of "each" is paralell sensitive and can use internally more than one thread.
In such situations, when fast-parallel-each is supported, we should prefer direct #each call instead of some other generic methods from
supportpackage.Maybe, but this is really maybe: write additional method
forEachParallel&whileEachParallel?Please note: our coverage tests should not profile performance problems which are known and delegated to #68