#include "../linq.h"
-#include <boost/thread.hpp>
-
#include <tbb/spin_mutex.h>
+#include <mutex>
#include <vector>
namespace caspar { namespace diagnostics {
}
typedef std::vector<spi::sink_factory_t> sink_factories_t;
-static boost::mutex g_sink_factories_mutex;
+static std::mutex g_sink_factories_mutex;
static sink_factories_t g_sink_factories;
std::vector<spl::shared_ptr<spi::graph_sink>> create_sinks()
{
- boost::lock_guard<boost::mutex> lock(g_sink_factories_mutex);
+ std::lock_guard<std::mutex> lock(g_sink_factories_mutex);
return cpplinq::from(g_sink_factories)
.select([](const spi::sink_factory_t& s){ return s(); })
void register_sink_factory(sink_factory_t factory)
{
- boost::lock_guard<boost::mutex> lock(g_sink_factories_mutex);
+ std::lock_guard<std::mutex> lock(g_sink_factories_mutex);
g_sink_factories.push_back(std::move(factory));
}
}
-}}
\ No newline at end of file
+}}