[*] update normally

Author: heng30

lib/recorder/src/h264_writer.rs

@@ -22,7 +22,7 @@ use std::{
 ///
 /// let writer = H264Writer::new("output.h264".into(), MAX_H264_WRITER_QUEUE_SIZE);
 /// ```
-pub const MAX_H264_WRITER_QUEUE_SIZE: usize = 512;
+pub const MAX_H264_WRITER_QUEUE_SIZE: usize = 64;
 
 /// H.264 file writer that handles frame queuing and file output.
 ///

lib/recorder/src/recorder.rs

@@ -1,8 +1,7 @@
 use crate::{
     AudioError, AudioRecorder, CombineTracksConfig, EncodedFrame, Frame, FrameUser, H264Writer,
-    MAX_H264_WRITER_QUEUE_SIZE, ProgressState, RecorderConfig, RecorderError, Resolution,
-    SimpleFpsCounter, SpeakerRecorder, StatsUser, StreamingAudioRecorder, VideoEncoder,
-    combine_tracks,
+    ProgressState, RecorderConfig, RecorderError, Resolution, SimpleFpsCounter, SpeakerRecorder,
+    StatsUser, StreamingAudioRecorder, VideoEncoder, combine_tracks,
 };
 use capture::{Capture, CaptureIterConfig, capture_output_iter};
 use crossbeam::channel::{Receiver, Sender, bounded};
@@ -32,7 +31,7 @@ const TMP_OUTPUT_VIDEO_EXTENSION: &str = "tmp.mp4";
 
 const USER_CHANNEL_SIZE: usize = 3;
 const RESIZE_WORKER_CHANNEL_SIZE: usize = 16;
-const ENCODER_WORKER_CHANNEL_SIZE: usize = 32;
+pub const ENCODER_WORKER_CHANNEL_SIZE: usize = 32;
 
 static CAPTURE_MEAN_TIME: Lazy<Mutex<Option<Duration>>> = Lazy::new(|| Mutex::new(None));
 
@@ -347,7 +346,7 @@ impl RecordingSession {
         } else {
             Some(H264Writer::new(
                 self.config.output_path.with_extension(RAW_VIDEO_EXTENSION),
-                MAX_H264_WRITER_QUEUE_SIZE,
+                ENCODER_WORKER_CHANNEL_SIZE,
             ))
         };
 
@@ -705,7 +704,7 @@ impl RecordingSession {
                                 frame: frame.clone(),
                             };
                             if let Err(e) = sender.try_send(frame_user) {
-                                log::warn!("try send frame failed: {e}");
+                                log::warn!("try send frame to user frame channel failed: {e}");
                             }
                         }
 

wayshot/src/logic/recorder.rs

@@ -174,7 +174,7 @@ fn init_desktop_speaker(ui: &AppWindow) -> Result<()> {
     let ui_weak = ui.as_weak();
 
     thread::spawn(move || {
-        let (sender, receiver) = bounded(1024);
+        let (sender, receiver) = bounded(3);
 
         let ui_weak_clone = ui_weak.clone();
         thread::spawn(move || {