Потокобезопасный, не содержащий данных, совместно используемый контейнер без задержек (round_buffer)

Я сталкиваюсь со следующей ситуацией (которую я должен признать, что я слишком новичок, чтобы доверять себе в решении в одиночку …): у меня есть поток A, который иногда создает новые объекты cv :: Mat для потока B. Мне нужен потокобезопасный контейнер C (в этом случае boost :: round_buffer), в котором будут храниться объекты cv :: Mat, генерируемые потоком A. Затем поток B должен постоянно перебирать все элементы в C, чтобы создать анимацию. Поэтому мне нужен потокобезопасный C, который будет запрещать гонки данных, но также не будет вызывать (в идеале) или очень маленькое (если не возможно иначе) отставание анимации потока B -> Я хочу, чтобы поток B зависал, когда поток A обновляет C. Лучшее, что я мог придумать, это:

#include <boost/circular_buffer.hpp>
#include <opencv2/core.hpp>
#include <boost/core/noncopyable.hpp>
#include <memory>
#include <type_traits>
#include <algorithm>

using im_buf = boost::circular_buffer<cv::Mat>;
class ImageBuffer : private boost::noncopyable {
private:
im_buf buffer;
std::mutex mtx;
std::unique_lock<std::mutex> lock;
public:
// operator<< accepting cv::Mat, cv::Mat& and cv::Mat&&
template <class T,
class = typename std::enable_if
<std::is_same<cv::Mat, typename std::decay<T>::type>
::value>::type>
void operator<<(T&& mat) {
lock.lock();
buffer.push_back(std::forward<T>(mat));
lock.unlock();
}
template <typename Func> // excpect callable objects only
inline void iterate(Func func) {
lock.lock();
std::for_each(buffer.begin(),buffer.end(),func);
lock.unlock();
}
inline ImageBuffer():
buffer {settings::max_images_in_loop},
mtx {},
lock {mtx} {}
~ImageBuffer()=default;
ImageBuffer(const ImageBuffer&&)=delete;
ImageBuffer& operator=(const ImageBuffer&&)=delete;
};

(Обратите внимание, что даже если это не инвариант, поток B не предполагает мутировать C или любое его содержимое (я хотел бы использовать const_iterator здесь, но boost :: round_buffer не предоставляет один ..)

Тем не менее, с этим потоком кода B будет на некоторое время останавливать всю анимацию каждый раз, когда поток A добавляет новые элементы … так,
а. разве нет лучшего подхода?
б. действительно ли реализация действительно потокобезопасна?