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
Blocking consumer queue silent offer #349
Comments
Wdyt @nitsanw ? Do you think is a valid/interesting use case? |
We are looking at 3 distinct API additions:
We already have a ‘fill’ that serves as a notification at the end of the batch. I see a conflict here between ‘take’ and ‘wakeup’ that can be confusing. |
I like the "sneaky*" name, nice one!
You mean re the words meaning? |
I mean that it's not clear how to return from |
Ah, you're right,I gotta refresh how the unblock thing work but I was
thinking more about a wakeup-if-not-empty semantic (not sure is feasible)
Il sab 8 mag 2021, 16:04 Nitsan Wakart ***@***.***> ha
scritto:
… I mean that it's not clear how to return from take on wakeup. take should
never return null, and the thread has not really been interrupted.
—
You are receiving this because you authored the thread.
Reply to this email directly, view it on GitHub
<#349 (comment)>,
or unsubscribe
<https://github.com/notifications/unsubscribe-auth/ADEENMZO2FXYN5AT3XJX723TMVAIXANCNFSM44JF4CAQ>
.
|
It would be nice to expose some "silent" version of offers that won't try to awake the consumer (it can both fail fast or just offer the element if not full): it can be beneficial when producers know upfront the offer batch size forcing to awake consumer just with a final "noisy" offer or delegating it to other producers that can sustain it. A "silent" fill can work too.
[OPTIONAL] In addition would be nice to expose some mechanism to awake the consumer without offering anything, to perform thread awaking on a separate thread that can sustain the awaking cost.
The text was updated successfully, but these errors were encountered: