Распаралелить программу

[MaxDDT]

Здравствуйте уважаемые форумчане!

Нужно распаралелить программу которая меняет местами столбцы 2-х мерного массива. Массив размером 10*10
Количество потоков - 5.
ОС- WindowsXP
IDE - MS Visual Studio 2008 C++

Вот я сделал её, но не приложу ума как распаралелить.

#include <iostream>
#include <windows.h>
using namespace std;

int main()
{
SetConsoleOutputCP (1251);
	
int mas[10][10];
int i,j,n=10,stolbec_a,stolbec_b,buf;

cout << "Массив случайных чисел 10*10\n";
cout << endl;


/*-----------------------------Ввод массива------------------------------------*/
	for (i=0; i<n; i++) //строки
	for (j=0; j<n; j++) //столбцы  
	{mas[i][j]=rand()%50;}


/*--------------------------Вывод массива на экран-------------------------------*/
	for (i=0; i<n; i++) //строки
	{
	for (j=0; j<n; j++) //столбцы
	{cout << "a[" << i <<j << "]= " << mas[i][j] << "\t";}	
	cout << endl;
	}

/*------------------------Выбор столбцов для перемещения------------------------*/
cout << "\nВведите номер столбца 'A' который вы хотите поменять местами с столбцом В\n";
	cin >> stolbec_a;
cout << "Введите номер столбца 'B' (на место которого вы хотите поставить столбец А)\n";
	cin >> stolbec_b;
		if (stolbec_a >n && stolbec_b >n) 
		{
			cout << "Вы ввели недопустимые значения \n"; 
		}
cout << "Вы хотите поменять местами столбец номер " << stolbec_a <<" с столбцом номер " << stolbec_b << endl;


/*------------------------Перемещиние столбцов------------------------*/
for (i=0; i<n; i++)
{
buf = mas[i][stolbec_a];
mas[i][stolbec_a] = mas[i][stolbec_b];
mas[i][stolbec_b] = buf;
}

/*--------------------------Вывод результата на экран-------------------------------*/
	for (i=0; i<n; i++) //строки
	{
	for (j=0; j<n; j++) //столбцы
	{cout << "a[" << i <<j << "]= " << mas[i][j] << "\t";}	
	cout << endl;
	}


cin.get();
cin.get();
}

Пожалуйста, кто разбирается в ПАРАЛЛЕЛЬНОМ программировании, дайте совет, или хотябы ссылкой пните). Заранее Благодарен!

[pproger]

2MaxDDT

Количество процессоров - 5.

может потоков?
реализация зависит от ос

[MaxDDT]

2pproger

Да, потоков. Я там в сообщении всё уточнил.

[pproger]

честно - идеотское задание на параллелизм. тут и распараллеливать то нечего. была ба какая нить сортировка хотяб...
ну что вижу. пусть каждый поток вполнит свою часть перестановки столбцов.
например:

первый поток:
for (i=0; i<2; i++) {
buf = mas[i][stolbec_a];
mas[i][stolbec_a] = mas[i][stolbec_b];
mas[i][stolbec_b] = buf;
}

...

пятый поток:
for (i=8; i<10; i++) {
buf = mas[i][stolbec_a];
mas[i][stolbec_a] = mas[i][stolbec_b];
mas[i][stolbec_b] = buf;
}

по работе с потоками смотри в msdn createThread. В твоем случае хватит только этой функции. в функцию потока передашь указатель на массив и номера строк колонки, которые Энный поток должен переставить. дальше просто создаешь 5 потоков с нужными параметрами. все.

но опять же скажу, что это все бредятина, ибо вполнение потока закончится практически моментально.

[MaxDDT]

Согласен что бредятина! Но "приказ" есть "приказ"! Я примерно так и думал. Но мне сказали что может возникнуть проблема с доступом к памяти. Типа одновременно к массиву будут подключатся 5 потоков, хотя я лично не пойму в чём проблемма.

Спасибо большое попробую помучится, когда будет какой-то результат, отпишусь.

[MaxDDT]

Оказывается что использовать функция CreateThread() есть смысл лишь тогда, когда в коде не используются стандартные функции библиотеки С, такие как например printf() или strcmp(). Проблемма в том что функции стандартной библиотеки С не предназначены для использования в Win32 АРІ, и для того чтобы создать поток необходимо во время создания и завершения потока выполнять некоторые действия, все эти действия уже включены в функцию _beginthreadex() для создания потока и _endthreadex() – для завершения потока. эти функции описаны в ргосеss.h (информация из методички)

[m0nax]

эмм, у меня тут тоже есть вопросик небольшой(потоки особо не изучал, но интересно же)
вот допустим обычный тупо-поток я создаю так (в MFC)

UINT proc2(LPVOID Param)
{
	AfxMessageBox("proc2!");
	return 0;
}

void CMyDlg::OnBnClickedOk() 
{
 AfxMessageBox("main proc");
 AfxBeginThread(proc2,this);
}

а что делать если нужен поток-член класса? того же диалога например(чтоб доступ получить ко всем данным)

[netrino]

для оных целей метод должен быть статическим, что по сути сразу исключает возможность доступа к полям, принадлежащим какому-то конкретному объекту(так как в статические методы не передаётся this). С другой стороны можно собственноручно передать в него this и тогда через него получать доступ к приватным полям класса

[MaxDDT]

Кто может взяться за это задание, и за какую сумму?

Интересует вариант с подробными комментариями.

[m0nax]

вот так вроде работает
не очень красиво правда - пока не получилось передать в поток указатель на двумерный массив как предложил pproger, пришлось чуток схалтурить )

#include "windows.h"
#include "Process.h"
#include <iostream> 
using namespace std;

const int n = 10;
int mas[n][n];

int stolbec_a=0, stolbec_b=0, 
buf=0, i=0, j=0;

void Print();

unsigned __stdcall proc(void* pParam)
{	
	//int temp = i + 2 ;	
	for (int i = (int)pParam; i < (int)pParam + 2; i++)
	{
		buf = mas[i][stolbec_a];
		mas[i][stolbec_a] = mas[i][stolbec_b];
		mas[i][stolbec_b] = buf;
	}
	return 0;
}

void main(){
	//setlocale(LC_ALL, ".1251");

	cout << "Массив случайных чисел 10*10\n";
	cout << endl;
	/*-----------------------------Ввод массива------------------------------------*/
	for (i=0; i<n; i++) //строки
		for (j=0; j<n; j++) //столбцы  
		{mas[i][j]=rand()%50;}
		/*--------------------------Вывод массива на экран-------------------------------*/
		Print();
		/*------------------------Выбор столбцов для перемещения------------------------*/
		cout << "\nВведите номер столбца 'A' который вы хотите поменять местами с столбцом В\n";
		cin >> stolbec_a;
		cout << "Введите номер столбца 'B' (на место которого вы хотите поставить столбец А)\n";
		cin >> stolbec_b;
		if (stolbec_a >n && stolbec_b >n) 
		{
			cout << "Вы ввели недопустимые значения \n"; 
		}
		cout << "Вы хотите поменять местами столбец номер " 
			<< stolbec_a <<" с столбцом номер " << stolbec_b << endl;

		//////////////////////////////////////////////////////////////////////////
		HANDLE ArrayThreads[5];
		
		for (int i=0, k=0; i < n; i+=2, ++k )
		{
			//Sleep(250);
			ArrayThreads[k] = (HANDLE)_beginthreadex(0,0,proc, (void*)i, 0,0) ;
		}

		WaitForMultipleObjects(5, ArrayThreads, TRUE, INFINITE);
		for (i=0; i<5; ++i)
			CloseHandle(ArrayThreads[i]) ;
		//////////////////////////////////////////////////////////////////////////

		/*--------------------------Вывод результата на экран-------------------------------*/
		Print();


		system("PAUSE");
}

void Print()
{
	for (i=0; i< n; i++) //строки
	{
		for (j=0; j< n; j++) //столбцы
		{
			cout << mas[i][j] << "\t" ;
			//cout << "a[" << i <<j << "]= " << mas[i][j] << "\t";
		}	
		cout << endl;
	}
}