We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 17dd2e4 commit 3670b50Copy full SHA for 3670b50
src/lib.rs
@@ -150,7 +150,7 @@ impl<T> Producer<T> {
150
target_arch = "x86",
151
all(target_arch = "x86_64", target_feature = "sse")
152
))]
153
- {
+ unsafe {
154
let next_index = next_head & self.queue.mask.0;
155
let next_slot = self.queue.buffer.0.add(next_index);
156
prefetch_write(next_slot as *const u8);
@@ -222,7 +222,7 @@ impl<T> Consumer<T> {
222
223
224
225
226
let next_index = (tail + 1) & self.queue.mask.0;
227
228
prefetch_read(next_slot as *const u8);
0 commit comments