Method work

Source/Common/Async.cpp:141–171

}

int Async::work(bx::Thread* thread, void* userData) {
	DORA_UNUSED_PARAM(thread);
	Async* worker = r_cast<Async*>(userData);
	while (true) {
		if (worker->isPoolWorker()) {
			Async* source = nullptr;
			Own<QEvent> event;
			if (worker->_pool->popTask(worker->_poolIndex, source, event)) {
				source->processWorkerEvent(std::move(event), source);
				continue;
			}
			if (worker->_pool->isStopping()) {
				return 0;
			}
			worker->_pool->waitForTask();
			continue;
		}
		for (auto event = worker->pollWorkerEvent();
			event != nullptr;
			event = worker->pollWorkerEvent()) {
			if (worker->processWorkerEvent(std::move(event), worker)) {
				return 0;
			}
		}
		if (worker->_stopped.load(std::memory_order_acquire)) {
			return 0;
		}
		worker->_workerSemaphore.wait();
	}
	return 0;
}

void Async::cancel() {
	for (auto event = _workerEvent.poll();