-
Notifications
You must be signed in to change notification settings - Fork 3.5k
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
op-node: parallel events executor #11100
base: develop
Are you sure you want to change the base?
Conversation
f0b131e
to
833a55c
Compare
This PR is stale because it has been open 14 days with no activity. Remove stale label or comment or this will be closed in 5 days. |
This PR is stale because it has been open 14 days with no activity. Remove stale label or comment or this will be closed in 5 days. |
This PR is stale because it has been open 14 days with no activity. Remove stale label or comment or this will be closed in 5 days. |
Still hoping to pick this work back up once other interop related work cools down |
This PR is stale because it has been open 14 days with no activity. Remove stale label or comment or this will be closed in 5 days. |
Actually I see that you referenced this PR from #13752 as something you still want to get in. |
Description
This adds a new event executor: parallel deriver execution.
Events are queued up, with a customizable capacity per deriver.
A parallel go routine per deriver then dequeues events, and processes them.
Each deriver has its own thread, creating parallelism, but with local state per deriver we simplify a lot of interactions still; no need for locking per individual variable.
This depends on #11099
TODO:
Experimental
Tests
Work in progress.
Metadata
Fix #10864