| 282 | } |
| 283 | |
| 284 | void ParallelReadBuffer::finishAndWait() |
| 285 | { |
| 286 | emergency_stop = true; |
| 287 | |
| 288 | size_t active_readers = active_working_readers.load(); |
| 289 | while (active_readers != 0) |
| 290 | { |
| 291 | active_working_readers.wait(active_readers); |
| 292 | active_readers = active_working_readers.load(); |
| 293 | } |
| 294 | } |
| 295 | |
| 296 | std::unique_ptr<ParallelReadBuffer> wrapInParallelReadBufferIfSupported( |
| 297 | ReadBuffer & buf, ThreadPoolCallbackRunnerUnsafe<void> schedule, size_t max_working_readers, |