@@ -124,23 +124,24 @@ class thread_pool_t
124124 * This class makes sure all pool threads will be joined when
125125 * the pool is destructed.
126126 */
127- class thread_joiner
127+ class thread_joiner_t
128128 {
129129
130130 std::vector<std::thread> *m_threads;
131131
132132 public:
133- explicit thread_joiner (std::vector<std::thread> *threads)
133+ explicit thread_joiner_t (std::vector<std::thread> *threads)
134134 : m_threads(threads)
135- {}
135+ {
136+ }
136137
137- thread_joiner (thread_joiner const &) = delete ;
138- thread_joiner &operator =(thread_joiner const &) = delete ;
138+ thread_joiner_t ( thread_joiner_t const &) = delete ;
139+ thread_joiner_t &operator =(thread_joiner_t const &) = delete ;
139140
140- thread_joiner (thread_joiner &&) = delete ;
141- thread_joiner &operator =(thread_joiner &&) = delete ;
141+ thread_joiner_t ( thread_joiner_t &&) = delete ;
142+ thread_joiner_t &operator =(thread_joiner_t &&) = delete ;
142143
143- ~thread_joiner ()
144+ ~thread_joiner_t ()
144145 {
145146 for (auto &thread : *m_threads) {
146147 if (thread.joinable ()) {
@@ -149,13 +150,13 @@ class thread_pool_t
149150 }
150151 }
151152
152- }; // class thread_joiner
153+ }; // class thread_joiner_t
153154
154155 static constexpr std::size_t MAX_QUEUE_SIZE = 32 ;
155156
156157 osmium::thread::Queue<osmium::thread::function_wrapper> m_work_queue;
157158 std::vector<std::thread> m_threads;
158- thread_joiner m_joiner;
159+ thread_joiner_t m_joiner;
159160
160161 /* *
161162 * This is the function run in each worker thread. It will loop over
0 commit comments