We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a1acc40 commit 7b1fdf6Copy full SHA for 7b1fdf6
src/shardedringbuf.rs
@@ -307,11 +307,13 @@ impl<T> ShardedRingBuf<T> {
307
}
308
309
310
- if matches!(acquire, Acquire::Dequeue) {
311
- self.job_post_shard_notifs[shard_ind].notified().await;
312
- } else {
313
- self.job_space_shard_notifs[shard_ind].notified().await;
314
- }
+ // You don't need this part; you only need to send a notif on release
+ // of the shard
+ // if matches!(acquire, Acquire::Dequeue) {
+ // self.job_post_shard_notifs[shard_ind].notified().await;
+ // } else {
315
+ // self.job_space_shard_notifs[shard_ind].notified().await;
316
+ // }
317
318
// current
319
0 commit comments