We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 2faea47 commit aea3ad4Copy full SHA for aea3ad4
README.md
@@ -21,7 +21,7 @@ If enqueuer and dequeuer tasks are done with a limited number of enqueue/dequeue
21
22
let rb = Arc::new(ShardedRingBuf::new(max_items, shards));
23
24
- let mut deq_tasks = Vec::with_capacity(shards);
+ let mut deq_tasks = Vec::with_capacity(task_count);
25
let mut enq_tasks = Vec::with_capacity(task_count);
26
27
// spawn enq tasks with shift by policy
@@ -44,7 +44,7 @@ If enqueuer and dequeuer tasks are done with a limited number of enqueue/dequeue
44
max_items,
45
ShardPolicy::ShiftBy {
46
initial_index: Some(i),
47
- shift: shards,
+ shift: task_count,
48
},
49
|_| {
50
// can put a function here optionally
0 commit comments