Function DirScan_CompareItems

Src/DirScan.cpp:458–490

* @brief Compare DiffItems in list and add results to compare context. * * @param myStruct [in] A structure containing compare-related data. * @param parentdiffpos [in] Position of parent diff item * @return >= 0 number of diff items, -1 if compare was aborted */

 * @return >= 0 number of diff items, -1 if compare was aborted
 */
int DirScan_CompareItems(DiffFuncStruct *myStruct, DIFFITEM *parentdiffpos)
{
	const int compareMethod = myStruct->context->GetCompareMethod();
	int nworkers = 1;

	if (compareMethod == CMP_CONTENT || compareMethod == CMP_QUICK_CONTENT)
	{
		nworkers = myStruct->nThreadCount;
		if (nworkers <= 0)
			nworkers += Environment::processorCount();
		nworkers = std::clamp(nworkers, 1, static_cast<int>(Environment::processorCount()));
	}

	ThreadPool threadPool(nworkers, nworkers);
	std::vector<DiffWorkerPtr> workers;
	NotificationQueue queue;
	myStruct->context->m_pCompareStats->SetCompareThreadCount(nworkers);
	workers.reserve(nworkers);
	for (int i = 0; i < nworkers; ++i)
	{
		workers.emplace_back(std::make_shared<DiffWorker>(queue, myStruct->context, i));
		threadPool.start(*workers[i]);
	}

	int res = CompareItems(queue, myStruct, parentdiffpos);

	myStruct->context->m_pCompareStats->SetIdleCompareThreadCount(0);
	Thread::sleep(100);
	queue.wakeUpAll();
	threadPool.joinAll();

	return res;
}

static int CompareItems(NotificationQueue& queue, DiffFuncStruct *myStruct, DIFFITEM *parentdiffpos)
{