bugfix

src/nodes/base/base.hpp

@@ -42,7 +42,6 @@ public:
 
     inline void add_output_buffer(const std::string& name, std::shared_ptr<SharedQueue<std::shared_ptr<meta::MetaData>>> buffer)
     {
-        std::unique_lock<std::mutex> lock(mutex_);
         std::unique_lock<std::mutex> lock(mutex_);
         // 设置回调，当数据push时通知当前节点
         buffer->set_push_callback([this]() { cond_var_->notify_one(); });