CHECK => ASSERT for WorkerThread::IsRunning()

This commit is contained in:
Alex Zolotarev 2015-06-01 21:43:46 +03:00
parent ab0a54023f
commit 1e1328f85b

View file

@ -27,7 +27,7 @@ public:
ASSERT(m_threadChecker.CalledOnOriginalThread(), ());
if (IsRunning())
RunUntilIdleAndStop();
CHECK(!IsRunning(), ());
ASSERT(!IsRunning(), ());
}
/// Pushes new task into worker thread's queue. If the queue is
@ -37,7 +37,7 @@ public:
void Push(shared_ptr<Task> task)
{
ASSERT(m_threadChecker.CalledOnOriginalThread(), ());
CHECK(IsRunning(), ());
ASSERT(IsRunning(), ());
unique_lock<mutex> lock(m_mutex);
m_condNotFull.wait(lock, [this]()
{
@ -52,7 +52,7 @@ public:
void RunUntilIdleAndStop()
{
ASSERT(m_threadChecker.CalledOnOriginalThread(), ());
CHECK(IsRunning(), ());
ASSERT(IsRunning(), ());
{
lock_guard<mutex> lock(m_mutex);
m_shouldFinish = true;