Method runInMainSync

Source/Common/Async.cpp:99–139

}

void Async::runInMainSync(const std::function<void()>& worker) {
	if (_stopped.load(std::memory_order_acquire)) {
		return;
	}
	AssertUnless(SharedApplication.getLogicThread() == std::this_thread::get_id(), "Async runner should be invoked from logic thread");
	std::list<std::variant<WorkPtr, WorkDonePtr>> jobs;
	for (auto event = _workerEvent.poll();
		event != nullptr;
		event = _workerEvent.poll()) {
		switch (Switch::hash(event->getName())) {
			case "Work"_hash: {
				Own<std::function<void()>> worker;
				event->get(worker);
				jobs.push_back(std::move(worker));
				break;
			}
			case "WorkDone"_hash: {
				Own<WorkDone> workDone;
				event->get(workDone);
				jobs.push_back(std::move(workDone));
				break;
			}
		}
	}
	run([&]() {
		worker();
		_mainThreadSemaphore.post();
	});
	if (_stopped.load(std::memory_order_acquire)) {
		return;
	}
	_mainThreadSemaphore.wait();
	for (auto& job : jobs) {
		if (std::holds_alternative<WorkPtr>(job)) {
			_workerEvent.post("Work"_slice, std::move(std::get<WorkPtr>(job)));
		} else {
			_workerEvent.post("WorkDone"_slice, std::move(std::get<WorkDonePtr>(job)));
		}
	}
	notifyWorker();
}

int Async::work(bx::Thread* thread, void* userData) {
	DORA_UNUSED_PARAM(thread);