1 use super::{Data, Empty, Inconsistent, Queue}
;
2 use crate::sync
::mpsc
::channel
;
8 let q
: Queue
<Box
<_
>> = Queue
::new();
16 let nmsgs
= if cfg
!(miri
) { 100 }
else { 1000 }
;
20 Inconsistent
| Data(..) => panic
!(),
22 let (tx
, rx
) = channel();
25 for _
in 0..nthreads
{
28 thread
::spawn(move || {
37 while i
< nthreads
* nmsgs
{
39 Empty
| Inconsistent
=> {}
44 for _
in 0..nthreads
{