加入少量轮询
This commit is contained in:
@@ -105,11 +105,16 @@ fn start_simple0(
|
|||||||
if event.token() == STOP {
|
if event.token() == STOP {
|
||||||
return Ok(());
|
return Ok(());
|
||||||
}
|
}
|
||||||
|
let mut retries = 0;
|
||||||
loop {
|
loop {
|
||||||
let len = match fd.read(&mut buf[start..]) {
|
let len = match fd.read(&mut buf[start..]) {
|
||||||
Ok(len) => len + start,
|
Ok(len) => len + start,
|
||||||
Err(e) => {
|
Err(e) => {
|
||||||
if e.kind() == io::ErrorKind::WouldBlock {
|
if e.kind() == io::ErrorKind::WouldBlock {
|
||||||
|
retries += 1;
|
||||||
|
if retries < 8 {
|
||||||
|
continue;
|
||||||
|
}
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
Err(e)?
|
Err(e)?
|
||||||
|
|||||||
Reference in New Issue
Block a user