| 162 | } |
| 163 | |
| 164 | void SpawnWorkers(vtkTypeUInt32 numberOfThreads) |
| 165 | { |
| 166 | this->Queue.reset(new TaskQueueType(::EncodeAndWrite, |
| 167 | /*strict_ordering=*/true, |
| 168 | /*buffer_size=*/-1, |
| 169 | /*max_concurrent_tasks=*/static_cast<int>(numberOfThreads))); |
| 170 | } |
| 171 | |
| 172 | void PushImageToQueue(vtkSmartPointer<vtkImageData>&& data, std::string&& filename) |
| 173 | { |