```C++
class MpgegStreamer : public Streamer {
public:
MpgegStreamer(const fs::path& path)
: path_(path) {
for (int i = 0; i < 4; ++i) {
workers_.emplace_back(&MpgegStreamer::work, this, i);
}
}
~MpgegStreamer() override {
for (auto& th : workers_) {
th.join();
}
}
void stream() override {
for (const auto& entry : fs::directory_iterator(path_)) {
std::lock_guard lg(m_);
streamQueue_.push(entry.path());
}
}
virtual void stop() {
finishAction_ = true;
}
```
```C++
private:
void work(int id) {
while (!finishAction_) {
fs::path path;
{
std::lock_guard lg(m_);
// Ofc this will be better with condition variable
if (streamQueue_.empty()) {
continue;
}
path = std::move(streamQueue_.front());
streamQueue_.pop();
}
stream(path, id);
}
}
void stream(const fs::path path, int id) const {
std::fstream fileToStream(path);
std::transform(
std::istream_iterator(fileToStream),
{},
std::ostream_iterator(std::cout),
[id](const std::string& str) {
std::stringstream ss;
ss << "Streamer: " << id << " | data: " << str << '\n';
return ss.str();
});
}
mutable std::mutex m_;
std::vector workers_;
std::queue streamQueue_;
fs::path path_;
std::atomic finishAction_{false};
};
```
___
We can create temporary direcotories (yes we can create them recursive!) and cleanup at the end. We don't need to be afraid of removing sth neccessary because we will work only with tmoprary directories.
```C++
int main() {
const auto tmp_path = fs::temp_directory_path();
const auto mpegDir = tmp_path.string() + "Test/MpgegFiles";
const auto mp4Dir = tmp_path.string() + "Test/MP4Files";
// Create test directory
fs::create_directories(mpegDir);
fs::create_directory(mp4Dir);
// Add files
for (int i = 0; i < 10; ++i) {
std::ofstream file(mpegDir + "/File" + std::to_string(i));
file << "this is some text in the new file\n" << i;
}
for (int i = 0; i < 10; ++i) {
std::ofstream file(mp4Dir + "/File" + std::to_string(i));
file << "this is some text in the new file\n" << i;
}
std::cout << "Start streaming" << std::endl;
std::unique_ptr