Method WorkerThread

shadercompiler/WorkQueue.h:243–279

	}

	void WorkerThread()
	{
#if CCP_TELEMETRY_ENABLED
		tracy::SetThreadName( "Compile Worker Thread" );
#endif

		{
			std::unique_lock scope( m_startMutex );
			m_waitToStart.wait( scope, [this] { return started; } );
		}

		AquireSemaphore();

		while( true )
		{
			T* item = nullptr;
			{
				std::unique_lock scope( m_queueMutex );
				if( m_queue.empty() )
				{
					break;
				}
				item = m_queue.front();
				m_queue.pop();
			}

			if( !m_processor( *item, this ) )
			{
				// some terrible failure?
				delete item;
				break;
			}
			delete item;
		}

		FreeSemaphore();
	}

	Processor m_processor;
	std::queue<T*> m_queue;