Многопоточность С++, VisualStudio2008

[EvaGrey]

Уважаемые программисты! Передо мной стоит задача: написать программу, использую WinAPI, в которой 5 потоков генерируют случайные числа, а один поток суммирует их, не пропуская ни одного.

Пока что у меня получилось следующее:

//Генерация n  потоками случайных чисел и суммирование их отдельным  (n+1)-м потоком
#include <windows.h>
#include <stdio.h>
#include <iostream> 
#include <stdlib.h> 
#define n 2


int Rand_num (int &a, CRITICAL_SECTION &cs/*, FILE *fl_thrd, int num*/)//стартовая функция потока-генератора
{	
	//Генерируем число и записывем его в файл
	while(1)
	{
		EnterCriticalSection(&cs);
		a = rand()%100;
		LeaveCriticalSection(&cs);
	}
	return 0;
}
int Total(int *a, int &sum, CRITICAL_SECTION &cs)//стартовая функция потока-"сумматора"
{
	while(1)
	{
		for(int i = 0; i < n; i++)
		{
			EnterCriticalSection(&cs);
			sum += a[i];
			LeaveCriticalSection(&cs);
		}
	}
	return 0;
}
void main()
{
	setlocale(LC_ALL,"Russian");

	int i, *a, sum = 0; //а - матрица, каждому потоку соотвествует своя ячейка
	HANDLE *Thread; //массив потоков, генерирующих сл.числа (от 0 до n) и поток, суммирующий числа (n+1)-й
	
	Thread = new HANDLE [n+1];
	a = new int [n];

	CRITICAL_SECTION cs;
	InitializeCriticalSection(&cs);

	puts("клавиша enter: остановить вычисления, space: возобновить");

	for(i = 0; i < n+1; i++)
		if(i == n)
			Thread[i] = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)Total(a, sum, cs), NULL, 0, NULL);
		else
			Thread[i] = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)Rand_num(a[i], cs/*, fl_thrd[i], i*/), NULL, 0, NULL);
	
	while(1)
	{
		while(1)
			if(GetAsyncKeyState(VK_RETURN)) 
				for(i = 0; i < n+1; i++)
					SuspendThread(Thread[i]);
			if(GetAsyncKeyState(VK_SPACE))
				for(i = 0; i < n+1; i++)
					ResumeThread(Thread[i]);
	}
	
	for(i = 0; i < n+1; i++)
		CloseHandle(Thread[i]);
}

Подскажите, как мне подступиться к этой задаче

[Rififi]

EvaGrey

5 потоков генерируют случайные числа, а один поток суммирует их, не пропуская ни одного.

наверное как-то так:
такого старья как vs2008 у меня нет, использую 2012

#include <atlsync.h>
#include <concurrent_queue.h>
#include <iostream>
#include <future>
#include <conio.h>
#include <stdlib.h>

Concurrency::concurrent_queue<int> q;
ATL::CEvent ping(FALSE, FALSE), done(TRUE, FALSE);

class Generator
{
public:
	void operator()() const
	{
		for (size_t i = 0; i < 10; i++)
		{
			q.push(rand() % 1000);
			ping.Set();
		}
	}			
};

class Summator
{
public:
	int operator()() const
	{
		const HANDLE h[] = { ping, done };
		int sum = 0;

		do
		{
			auto res(WaitForMultipleObjects(_countof(h), h, FALSE, INFINITE));
				
			if (res == WAIT_OBJECT_0)
			{
				int i;
				while (q.try_pop(i))
					sum += i;						
			}
			else
				break;
		} while (true);

		return sum;
	}
};

int main()
{
	auto summator(std::async(Summator()));

	Concurrency::task_group gr;
	for (size_t i=0; i<5; i++)
		gr.run(Generator());
	gr.wait();

	done.Set();
	std::cout << summator.get() << std::endl;
	_getch();

	return 0;
}