diff --git a/apps/hello/src/stereo_core/mixer.rs b/apps/hello/src/stereo_core/mixer.rs index 11a082b..180d81d 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(10)).await; + tokio::time::sleep(tokio::time::Duration::from_millis(1)).await; continue; } @@ -117,7 +117,7 @@ impl Mixer { } else { // 如果所有客户端都断开了,继续等待新连接 drop(clients); - tokio::time::sleep(tokio::time::Duration::from_millis(10)).await; + tokio::time::sleep(tokio::time::Duration::from_millis(1)).await; } } } diff --git a/apps/hello/src/stereo_core/slave.rs b/apps/hello/src/stereo_core/slave.rs index a95122f..d29cb50 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(10)).await; + tokio::time::sleep(Duration::from_millis(1)).await; } } }