//(c) 2016 by Authors
//This file is a part of ABruijn program.
//Released under the BSD license (see LICENSE file)

#include <vector>
#include <functional>
#include <atomic>
#include <thread>

#include "progress_bar.h"

//simple thread pool implementation
//updateFun should be thread-safe!
template <class T>
void processInParallel(const std::vector<T>& scheduledTasks,
					   std::function<void(const T&)> updateFun,
					   size_t maxThreads, bool progressBar)
{
	if (scheduledTasks.empty()) return;

	std::atomic<size_t> jobId(0);
	ProgressPercent progress(scheduledTasks.size());

	auto threadWorker = [&jobId, &scheduledTasks, &updateFun, 
						 &progress, progressBar]()
	{
		while (true)
		{
			size_t expected = 0;
			while(true)
			{
				expected = jobId;
				if (jobId == scheduledTasks.size()) 
				{
					return;
				}
				if (jobId.compare_exchange_weak(expected, expected + 1))
				{
					break;
				}
			}
			updateFun(scheduledTasks[expected]);
			if (progressBar) progress.advance();
		}
	};

	std::vector<std::thread> threads(std::min(maxThreads, 
											  scheduledTasks.size()));
	for (size_t i = 0; i < threads.size(); ++i)
	{
		threads[i] = std::thread(threadWorker);
	}
	for (size_t i = 0; i < threads.size(); ++i)
	{
		threads[i].join();
	}
}