Skip to content

Fix AsyncConsumerWorkService #775

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

Merged

Conversation

danielmarbach
Copy link
Collaborator

Proposed Changes

Split out of #772 that only contains async changes

@danielmarbach danielmarbach mentioned this pull request Mar 24, 2020
@michaelklishin michaelklishin merged commit a11303e into rabbitmq:master Mar 24, 2020
@michaelklishin michaelklishin added this to the 6.0.0 milestone Mar 24, 2020
@michaelklishin
Copy link
Contributor

Thank you!

@@ -45,7 +45,7 @@ class WorkPool
readonly ModelBase _model;
CancellationTokenRegistration _tokenRegistration;
volatile TaskCompletionSource<bool> _syncSource = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
private Task _task;
private Task _worker;
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@danielmarbach _worker is not really used anywhere, though. What does keeping it in an instance variable accomplish?

Copy link
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Nothing until we reimplement the graceful shutdown as discussed in your PR

lukebakken pushed a commit that referenced this pull request Mar 25, 2020
Fix AsyncConsumerWorkService

(cherry picked from commit a11303e)
@danielmarbach danielmarbach deleted the fix-async-consumer-loop branch August 16, 2020 18:28
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.

3 participants