43 lines
769 B
C++
43 lines
769 B
C++
|
#pragma once
|
||
|
|
|
||
|
|
#include "./frame_stream2.hpp"
|
||
|
|
|
||
|
|
#include <mutex>
|
||
|
|
#include <deque>
|
||
|
|
|
||
|
|
// threadsafe queue frame stream
|
||
|
|
// protected by a simple mutex lock
|
||
|
|
// prefer lockless queue implementations, when available
|
||
|
|
template<typename FrameType>
|
||
|
|
struct LockedFrameStream2 : public FrameStream2I<FrameType> {
|
||
|
|
std::mutex _lock;
|
||
|
|
|
||
|
|
std::deque<FrameType> _frames;
|
||
|
|
|
||
|
|
~LockedFrameStream2(void) {}
|
||
|
|
|
||
|
|
int32_t size(void) { return -1; }
|
||
|
|
|
||
|
|
std::optional<FrameType> pop(void) {
|
||
|
|
std::lock_guard lg{_lock};
|
||
|
|
|
||
|
|
if (_frames.empty()) {
|
||
|
|
return std::nullopt;
|
||
|
|
}
|
||
|
|
|
||
|
|
FrameType new_frame = std::move(_frames.front());
|
||
|
|
_frames.pop_front();
|
||
|
|
|
||
|
|
return std::move(new_frame);
|
||
|
|
}
|
||
|
|
|
||
|
|
bool push(const FrameType& value) {
|
||
|
|
std::lock_guard lg{_lock};
|
||
|
|
|
||
|
|
_frames.push_back(value);
|
||
|
|
|
||
|
|
return true;
|
||
|
|
}
|
||
|
|
};
|
||
|
|
|