-
Notifications
You must be signed in to change notification settings - Fork 24
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Add unordered transduce for channels #112
Conversation
Codecov Report
@@ Coverage Diff @@
## master #112 +/- ##
==========================================
- Coverage 88.68% 88.57% -0.11%
==========================================
Files 18 19 +1
Lines 1131 1173 +42
==========================================
+ Hits 1003 1039 +36
- Misses 128 134 +6
Continue to review full report at Codecov.
|
@spawn begin | ||
acc = acc′′ | ||
for _ in 1:basesize | ||
x = maybe_popfirst!(input) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Maybe interleaving I/O (popfirst!(::Channel)
) and computation (next(xf, ...)
) is bad for performance (e.g., SIMD cannot be used this way)? This should probably be done outside the reduction loop?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Implemented in #123
https://github.com/tkf/Transducers.jl/blob/1f8d35d287d5d773da836b3abfe4054bf0d012e0/src/unordered.jl#L115-L141