#include <QtCore/QCoreApplication>
#include <QtConcurrent/QtConcurrent>

auto const c_arrDim = 3;

using t_my_array = QVector<QVector <int>>; 

struct t_proc_elem
{
	int x;
	int y;
	int val;
	int trnval;
};
using t_proc_array = QVector<t_proc_elem>;

void init_src_array(t_my_array& a_arr)
{
	QRandomGenerator rg(QRandomGenerator::securelySeeded().generate());
	a_arr.resize(c_arrDim);
	for (auto i = 0; i < c_arrDim; i++) {
		a_arr[i].resize(c_arrDim);
		for (auto j = 0; j < c_arrDim; j++)
			//a_arr[i][j] = rg.generate();
			a_arr[i][j] = i * c_arrDim + j;
	};
};


void init_trg_array(t_my_array& a_arr)
{
	a_arr.resize(c_arrDim);
	for (auto& line : a_arr)
		line.resize(c_arrDim);

};

void init_proc_array(t_proc_array& a_proc_arr, const t_my_array& a_src_arr)
{
	a_proc_arr.resize(c_arrDim * c_arrDim);
	for (auto i = 0; i < c_arrDim; i++)
		for (auto j = 0; j < c_arrDim; j++)
		{
			a_proc_arr[i*c_arrDim + j].x = i;
			a_proc_arr[i*c_arrDim + j].y = j;
			a_proc_arr[i*c_arrDim + j].val = a_src_arr[i][j];
			a_proc_arr[i*c_arrDim + j].trnval = a_src_arr[j][i];
		}
};
t_proc_elem my_map(const t_proc_elem & a_elem)
{
	t_proc_elem localVal = a_elem;
	localVal.val  += a_elem.trnval / 2;
	return  localVal;
}

void my_reduce(t_my_array& a_result_arr, const t_proc_elem & a_proc_elem		)
{
	if (a_result_arr.size() == 0)
		init_trg_array(a_result_arr);
	a_result_arr[a_proc_elem.x][a_proc_elem.y] = a_proc_elem.val;
}


int main(int argc, char *argv[])
{
	QCoreApplication a(argc, argv);

	t_my_array srcArr;
	init_src_array(srcArr);
	qDebug() << endl << "Src array:" << endl << srcArr;


	t_proc_array procArr;
	init_proc_array(procArr, srcArr);


	qDebug() << "Prcessed array:";
	for (auto & elem : procArr)
		qDebug() <<  elem.x << " " << elem.y << " " << elem.val << " " << elem.trnval;


	t_my_array trg_arr = QtConcurrent::blockingMappedReduced(procArr, my_map, my_reduce);

	qDebug() << endl << "Trg array:" << endl << trg_arr;


	return a.exec();
}