#include <tbb/atomic.h>
#include <tbb/concurrent_priority_queue.h>
-#include <boost/thread.hpp>
#include <boost/optional.hpp>
#include <functional>
#include <future>
+#include <thread>
namespace caspar {
enum class task_priority
const std::wstring name_;
tbb::atomic<bool> is_running_;
- boost::thread thread_;
+ std::thread thread_;
function_queue_t execution_queue_;
tbb::atomic<bool> currently_in_task_;
{
is_running_ = true;
currently_in_task_ = false;
- thread_ = boost::thread([this]{run();});
+ thread_ = std::thread([this]{run();});
}
~executor()
bool is_current() const
{
- return boost::this_thread::get_id() == thread_.get_id();
+ return std::this_thread::get_id() == thread_.get_id();
}
bool is_currently_in_task() const