Commit e1c5aa1

committed

HOMEWORK bobocode-projects#9 – CONCURRENCY

- refactor ForkJoin task, remove direct call of ForkJoin Common pool

1 parent 70ddffd commit e1c5aa1Copy full SHA for e1c5aa1

File tree

-2

lines changed

-2

lines changed

Lines changed: 1 addition & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -2,7 +2,6 @@`
`2`	`2`
`3`	`3`	`import java.util.concurrent.ForkJoinPool;`
`4`	`4`	`import java.util.concurrent.ThreadLocalRandom;`
`5`		`-import java.util.concurrent.TimeUnit;`
`6`	`5`	`import java.util.function.Supplier;`
`7`	`6`	`import java.util.stream.Stream;`
`8`	`7`
`@@ -47,7 +46,7 @@ public static void main(String[] args) {`
`47`	`46`	`var taskStat = Stream.generate(arraySupplier)`
`48`	`47`	`.limit(10)`
`49`	`48`	`.map(MergeSortTask::new)`
`50`		`- .mapToLong(forkJoinPool::invoke)`
	`49`	`+ .mapToLong(MergeSortTask::invoke)//implicitly run on ForkJoin Common pool don't need to call ForkJoin directly`
`51`	`50`	`.map(elapsedNanos -> MILLISECONDS.convert(elapsedNanos, NANOSECONDS))`
`52`	`51`	`.peek(elapsedTime -> System.out.println(elapsedTime + "ms"))`
`53`	`52`	`.summaryStatistics();`

Comments

(0)