Method main_loop

utility/task_manager.cpp:543–584

}

void TaskManager::DownloadQueueThread::main_loop() {
	while (running) {
		DownloadTaskID item;
		if (!queue.try_pop(item)) {
			// if (!waiting) {
			// 	TaskManager::get_singleton()->update_progress_bg();
			// }
			OS::get_singleton()->delay_usec(10000);
			continue;
		}
		std::shared_ptr<DownloadTaskData> task;
		tasks.if_contains(item, [&](auto &v) {
			task = v.second;
			if (task) {
				MutexLock lock(worker_mutex);
				running_task = task;
				worker_cv.notify_all();
			}
		});
		ERR_CONTINUE_MSG(!task, "Download task ID " + itos(item) + " not found");
		while (!task->is_done() && !task->is_waiting) {
			task->update_progress();
			OS::get_singleton()->delay_usec(10000);
		}
		while (!task->is_done()) {
			OS::get_singleton()->delay_usec(10000);
		}
		if (!task->is_waiting) {
			task->finish_progress();
		}
		if (task->is_canceled()) {
			// pop off the rest of the queue
			MutexLock lock(write_mutex);
			tasks.for_each_m([&](auto &v) {
				v.second->cancel();
			});
			tasks.clear();
			while (queue.try_pop(item)) {
			}
		}
	}
}

TaskManager::DownloadTaskID TaskManager::DownloadQueueThread::add_download_task(const String &p_download_url, const String &p_save_path, bool silent) {
	MutexLock lock(write_mutex);