diff --git a/apps/hello/src/stereo_core/mixer.rs b/apps/hello/src/stereo_core/mixer.rs index 180d81d..11a082b 100644 --- a/apps/hello/src/stereo_core/mixer.rs +++ b/apps/hello/src/stereo_core/mixer.rs @@ -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; } } } diff --git a/apps/hello/src/stereo_core/slave.rs b/apps/hello/src/stereo_core/slave.rs index d29cb50..a95122f 100644 --- a/apps/hello/src/stereo_core/slave.rs +++ b/apps/hello/src/stereo_core/slave.rs @@ -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; } } }