diff --git a/paddle/fluid/operators/reader/ctr_reader.h b/paddle/fluid/operators/reader/ctr_reader.h index 6bcbaae38ecc96885cef37538dbe1c08e1f6726d..14c4809df2bdcf638dd06fe842856e2f2dfe866b 100644 --- a/paddle/fluid/operators/reader/ctr_reader.h +++ b/paddle/fluid/operators/reader/ctr_reader.h @@ -153,9 +153,9 @@ class CTRReader : public framework::FileReader { VLOG(3) << "reopen success"; VLOG(3) << "thread_num " << thread_num_; for (int thread_id = 0; thread_id < thread_num_; thread_id++) { - read_threads_.emplace_back(new std::thread( - std::bind(&ReadThread, file_groups_[thread_id], data_desc_, static_cast(thread_id), - &read_thread_status_, queue_))); + read_threads_.emplace_back(new std::thread(std::bind( + &ReadThread, file_groups_[thread_id], data_desc_, + static_cast(thread_id), &read_thread_status_, queue_))); } monitor_thread_.reset(new std::thread( std::bind(&MonitorThread, &read_thread_status_, queue_)));