#include <tbb/concurrent_queue.h>
-#include <boost/thread/mutex.hpp>
-
#include "semaphore.h"
namespace caspar {
size_type capacity_;
semaphore space_available_ { capacity_ };
semaphore elements_available_ { 0u };
- mutable boost::mutex capacity_mutex_;
+ mutable std::mutex capacity_mutex_;
public:
/**
* Constructor.
*/
void set_capacity(size_type capacity)
{
- boost::unique_lock<boost::mutex> lock(capacity_mutex_);
+ std::unique_lock<std::mutex> lock(capacity_mutex_);
if (capacity_ < capacity)
{
*/
size_type capacity() const
{
- boost::unique_lock<boost::mutex> lock (capacity_mutex_);
+ std::unique_lock<std::mutex> lock (capacity_mutex_);
return capacity_;
}