add print

src/common/queue.hpp

@@ -64,6 +64,7 @@ public:
 
         // 检查队列是否已满，并根据策略处理
         if (queue_.size() >= max_size_) {
+            print("queue is full, size = %d\n" % queue_.size());
             switch (strategy_) {
                 case OverflowStrategy::Block:
                     // 阻塞策略：等待直到队列不再满

src/nodes/stream/streamNode.cpp

@@ -92,7 +92,7 @@ void StreamNode::work_gpu()
                 output_buffer.second->push(metaData);
                 // printf("Node %s push data to %s\n", name_.c_str(), output_buffer.first.c_str());
             }
-            std::this_thread::sleep_for(std::chrono::milliseconds(30));
+            // std::this_thread::sleep_for(std::chrono::milliseconds(30));
         }
     };
 	printf("Total frame : %d frames\n", frame_index);