File tree Expand file tree Collapse file tree 2 files changed +7
-7
lines changed Expand file tree Collapse file tree 2 files changed +7
-7
lines changed Original file line number Diff line number Diff line change @@ -95,15 +95,15 @@ void ThreadPool::TaskLoop() {
95
95
}
96
96
}
97
97
98
- std::unique_ptr<ThreadPool> MultiStreamThreadPool ::io_threadpool_ (nullptr );
99
- std::once_flag MultiStreamThreadPool ::io_init_flag_;
98
+ std::unique_ptr<ThreadPool> ThreadPoolIO ::io_threadpool_ (nullptr );
99
+ std::once_flag ThreadPoolIO ::io_init_flag_;
100
100
101
- ThreadPool* MultiStreamThreadPool ::GetInstanceIO () {
102
- std::call_once (io_init_flag_, &MultiStreamThreadPool ::InitIO);
101
+ ThreadPool* ThreadPoolIO ::GetInstanceIO () {
102
+ std::call_once (io_init_flag_, &ThreadPoolIO ::InitIO);
103
103
return io_threadpool_.get ();
104
104
}
105
105
106
- void MultiStreamThreadPool ::InitIO () {
106
+ void ThreadPoolIO ::InitIO () {
107
107
if (io_threadpool_.get () == nullptr ) {
108
108
// TODO(typhoonzero1986): make this configurable
109
109
io_threadpool_.reset (new ThreadPool (FLAGS_io_threadpool_size));
Original file line number Diff line number Diff line change @@ -135,7 +135,7 @@ class ThreadPool {
135
135
std::condition_variable completed_;
136
136
};
137
137
138
- class MultiStreamThreadPool : ThreadPool {
138
+ class ThreadPoolIO : ThreadPool {
139
139
public:
140
140
static ThreadPool* GetInstanceIO ();
141
141
static void InitIO ();
@@ -156,7 +156,7 @@ std::future<void> Async(Callback callback) {
156
156
157
157
template <typename Callback>
158
158
std::future<void > AsyncIO (Callback callback) {
159
- return MultiStreamThreadPool ::GetInstanceIO ()->Run (callback);
159
+ return ThreadPoolIO ::GetInstanceIO ()->Run (callback);
160
160
}
161
161
162
162
} // namespace framework
You can’t perform that action at this time.
0 commit comments