-
Notifications
You must be signed in to change notification settings - Fork 2.4k
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
queue.remove() with filter function #1391
Comments
We expose the underlying tasks as @megawac what do you think is the best solution for removing an item from the queue? Add a |
I think this is reasonable, I prefer the name |
Now, I've done it with collecting the tasks first and then remove them in a second step. I wasn't sure what would happen if I remove them immediately. You could implement both: filter and remove, though I needed only the remove function. Compared to the kill function I wouldn't remove the drain function when remove is called. |
I'm currently finding a way to remove certain unprocessed entries in a queue/priorityQueue. I don't know how to do it, so I would appreciate if anyone could give me a hint.
Feature suggestion: add another method with which entries gets removed like that:
Or with the priority queue:
The text was updated successfully, but these errors were encountered: