You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Benchmarking the new groupedWithin operator showed that cancelling CancellableFork that hasn't started yet can be optimized. CancellableFork.cancelNow creates InterruptedException. I replaced that exception with no-stack-trace variant and observed an improvement.
Benchmark code:
supervised {
for (i <-1 to 15) {
valc=Source.range(1, 1000000, 1)
valstart=System.nanoTime()
c.groupedWithin(3, 1.second).drain()
valdur=System.nanoTime() - start
println(dur /1000000)
}
Results (median):
current solution: 2627 ms
no-stack-trace variant: 1261 ms
The text was updated successfully, but these errors were encountered:
Benchmarking the new
groupedWithin
operator showed that cancellingCancellableFork
that hasn't started yet can be optimized.CancellableFork.cancelNow
createsInterruptedException
. I replaced that exception with no-stack-trace variant and observed an improvement.Benchmark code:
Results (median):
The text was updated successfully, but these errors were encountered: