bugfix in mpmc.dequeue

This commit is contained in:
konstantin 2019-10-04 17:07:35 +02:00 committed by Jorge Aparicio
parent a6949b5439
commit baa5e620d4

View File

@ -494,7 +494,11 @@ unsafe fn dequeue<T>(buffer: *mut Cell<T>, dequeue_pos: &AtomicU8, mask: u8) ->
} else if dif < 0 {
return None;
} else {
pos = dequeue_pos.load(Ordering::Relaxed);
if pos == 255 && dif == 255{
return None;
} else {
pos = dequeue_pos.load(Ordering::Relaxed);
}
}
}