Method queue_remove_all

ytdlp-interface/queue.cpp:820–888

void GUI::queue_remove_all(size_t cat)
{
	if(!thr_queue_remove.joinable())
	{
		bottoms.show(L"");
		qurl.clear();
		l_url.update_caption();
		auto *pfm {fm_alert("Shutting down active yt-dlp instances", "Please wait...", false).release()};
		activate();
		thr_queue_remove = std::thread([this, cat, pfm]
		{
			if(active_info_threads || bottoms.joinable_dl_threads())
			{
				pfm->show();
				PostMessage(hwnd, WM_REFRESH, reinterpret_cast<WPARAM>(pfm->handle()), 0);
				subclass::eat_mouse = true;
			}
			for(auto &item : lbq.at(cat))
			{
				auto url {item.value<lbqval_t>().url};
				auto &bottom {bottoms.at(url)};
				bottom.working_info = false;
				bottom.working = false;
			}
			lbq.auto_draw(false);
			auto item {lbq.at(cat).begin()};
			while(item != lbq.at(cat).end() && !g_exiting)
			{
				auto url {item.value<lbqval_t>().url};
				auto &bottom {bottoms.at(url)};
				if(bottom.timer_proc.started())
					bottom.timer_proc.stop();

				if(bottom.info_thread.joinable())
				{
					bottom.info_thread.join();
				}
				if(bottom.dl_thread.joinable())
				{
					//fm_alert_text.caption(url);
					bottom.dl_thread.join();
				}
				item = lbq.listbox::erase(item);
				bottoms.erase(url);
				outbox.erase(url);
			}
			if(cat)
			{
				lbq.erase(cat);
				if(lbq.at(cat - 1).size())
					lbq_url_to_select = lbq.at(cat - 1).back().value<lbqval_t>();
			}
			else
			{
				auto vis {lbq.visibles()};
				if(!vis.empty())
					lbq_url_to_select = lbq.at(vis.front().cat).at(0).value<lbqval_t>();
			}