We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 597c845 commit b94f24dCopy full SHA for b94f24d
paddle/fluid/operators/reader/create_double_buffer_reader_op.cc
@@ -66,6 +66,9 @@ class DoubleBufferReader : public framework::DecoratedReader {
66
void ReadNext(std::vector<framework::LoDTensor>* out) override;
67
void ReInit() override;
68
69
+ ~DoubleBufferReader() { EndPrefetcher(); }
70
+
71
+ private:
72
void StartPrefetcher() {
73
channel_ = framework::MakeChannel<Item>(kChannelSize);
74
prefetcher_ = std::thread([this] { PrefetchThreadFunc(); });
@@ -80,9 +83,6 @@ class DoubleBufferReader : public framework::DecoratedReader {
80
83
channel_ = nullptr;
81
84
}
82
85
- ~DoubleBufferReader() { EndPrefetcher(); }
-
- private:
86
void PrefetchThreadFunc();
87
88
std::thread prefetcher_;
0 commit comments