@ -52,12 +52,10 @@ class DoubleBufferReader : public framework::DecoratedReader {
void ReadNextImpl(std::vector<framework::LoDTensor>* out) override;
~DoubleBufferReader() { EndPrefetcher(); }
private:
void ShutdownImpl() override {
EndPrefetcher();
reader_->Shutdown();
}
void StartImpl() override {
@ -48,9 +48,9 @@ class ShuffleReader : public framework::DecoratedReader {
buffer_.clear();
iteration_pos_ = 0;
@ -36,8 +36,6 @@ class MultiFileReader : public framework::ReaderBase {
~MultiFileReader() { EndScheduler(); }
void ShutdownImpl() override { EndScheduler(); }