chore: 修改间隔
This commit is contained in:
@@ -70,7 +70,7 @@ impl Mixer {
|
||||
if clients.is_empty() {
|
||||
drop(clients);
|
||||
// 没有客户端时,稍微等待,避免空转
|
||||
tokio::time::sleep(tokio::time::Duration::from_millis(1)).await;
|
||||
tokio::time::sleep(tokio::time::Duration::from_millis(10)).await;
|
||||
continue;
|
||||
}
|
||||
|
||||
@@ -117,7 +117,7 @@ impl Mixer {
|
||||
} else {
|
||||
// 如果所有客户端都断开了,继续等待新连接
|
||||
drop(clients);
|
||||
tokio::time::sleep(tokio::time::Duration::from_millis(1)).await;
|
||||
tokio::time::sleep(tokio::time::Duration::from_millis(10)).await;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -184,7 +184,7 @@ async fn handle_connection(role: ChannelRole) -> Result<()> {
|
||||
let len = codec.decode(&data, &mut pcm_buf)?;
|
||||
player.write(&pcm_buf[..len])?;
|
||||
} else {
|
||||
tokio::time::sleep(Duration::from_millis(1)).await;
|
||||
tokio::time::sleep(Duration::from_millis(10)).await;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user