-
-
Notifications
You must be signed in to change notification settings - Fork 352
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
feature: add support for parallel processor #3280
Conversation
I think it's really cool! |
i think the feature is finished if no one sees any problems? |
Great progress. In Spoon, each time we add a feature, we document it in the In Spoon, we try to add a line Thanks! |
* @param numberOfProcessors number of concurrent running processors. | ||
* @throws IllegalArgumentException if numberOfProcessors is less than 1. | ||
*/ | ||
public AbstractParallelProcessor(Consumer<E> processFunction, int numberOfProcessors) { |
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.
neat API!
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.
thanks
For both failing test cases see #3289 (?) and wait with merges till it is resolved? |
Thanks a lot @MartinWitt |
For the record, #1111 is related to this. |
Fix #2659
The new class allows parallel processing for stateless processors. Subtyping processor allows easy usage in launcher and keeps it simple for the user.
Currently the are still some problems and needed changes:
wdyt about it?