Skip to content

Ensure mapParallelOrdered runs in parallel#846

Merged
Avasil merged 1 commit into
monix:masterfrom
lukestephenson:map-parallel-ordered-force-async
Mar 21, 2019
Merged

Ensure mapParallelOrdered runs in parallel#846
Avasil merged 1 commit into
monix:masterfrom
lukestephenson:map-parallel-ordered-force-async

Conversation

@lukestephenson
Copy link
Copy Markdown
Contributor

@lukestephenson lukestephenson commented Mar 12, 2019

See #841

Is there a guarantee with the waiting for the semaphore permit that there will not be multiple permits blocked at once? If so, the ordering might not be guaranteed with this approach.

@lukestephenson
Copy link
Copy Markdown
Contributor Author

The build is failing with 1 failed test:

monix.execution.internal.AsyncSchedulerSuite
- scheduleWithFixedRate should compensate for scheduling inaccuracy *** FAILED ***
  AssertionException: Error <= 20ms (AsyncSchedulerSuite.scala:108)
    $c_Lminitest_api_AssertionException.$c_jl_Throwable.fillInStackTrace__jl_Throwable(/home/travis/build/monix/monix/monix-execution/js/target/scala-2.12/monix-execution-test-fastopt.js:21093:14)
    $c_Lminitest_api_AssertionException.$c_jl_Throwable.init___T__jl_Throwable__Z__Z(/home/travis/build/monix/monix/monix-execution/js/target/scala-2.12/monix-execution-test-fastopt.js:21201:10)
    minitest.api.AssertionException.<init>(/home/travis/build/monix/monix/monix-execution/js/target/scala-2.12/monix-execution-test-fastopt.js:85046:58)
    {anonymous}()(/home/travis/build/monix/monix/monix-execution/js/target/scala-2.12/monix-execution-test-fastopt.js:48822:63)
    scala.scalajs.runtime.AnonFunction1.apply(/home/travis/build/monix/monix/monix-execution/js/target/scala-2.12/monix-execution-test-fastopt.js:31427:23)
    scala.util.Success.map(/home/travis/build/monix/monix/monix-execution/js/target/scala-2.12/monix-execution-test-fastopt.js:93652:47)
    {anonymous}()(/home/travis/build/monix/monix/monix-execution/js/target/scala-2.12/monix-execution-test-fastopt.js:11065:18)
    scala.scalajs.runtime.AnonFunction1.apply(/home/travis/build/monix/monix/monix-execution/js/target/scala-2.12/monix-execution-test-fastopt.js:31427:23)
    scala.concurrent.impl.Promise.liftedTree1$1(/home/travis/build/monix/monix/monix-execution/js/target/scala-2.12/monix-execution-test-fastopt.js:30532:31)
    {anonymous}()(/home/travis/build/monix/monix/monix-execution/js/target/scala-2.12/monix-execution-test-fastopt.js:30524:22)

I can't see how this is related to the change I made. I've also seen this test failing on other branches (eg https://travis-ci.org/monix/monix/jobs/504177945), so I think the test is flakey

@Avasil
Copy link
Copy Markdown
Collaborator

Avasil commented Mar 21, 2019

I'll merge it, would be nice to add test for it so I'll leave #841 open

Thank you once again :)

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants