C++ Карусель(Round Robin)

[ШеФФ]

Всем доброго времени суток!
Имеется задание: реализовать дисциплину планирования потоков "Карусель" через WinAPI. Использовать таймеры и события.
Не могу четко себе представить схему работы программы=( Прошу помощи у более опытного народа. И если можно, то наброски кода по этому делу. Буду очень благодарен.

[Tony Parker]

Есть реализации на чистом С, надо только добавить таймер с событиями:

http://www.daniweb.com/software-deve...c/threads/8091

http://www.indiastudychannel.com/pro...gorithm-C.aspx

[ШеФФ]

Вопрос в том, как именно добавить. А еще там потоки не реальные, а представлены в виде структур. А здесь нужно создать именно реальные потоки и крутить их в карусели.

[ШеФФ]

Немного поразмыслив и почитав Рихтера, написал вот такой код:

#include <iostream.h>
#include <windows.h>

using namespace std;

const int n = 10;
const int TimeInt = 2;

int pars[n];

HANDLE hTimer;
LARGE_INTEGER li;

struct RR
{
	HANDLE hThread;
	RR* next;
	DWORD dwThread;
};

RR *HEAD = NULL,*TAIL = NULL;

void DelThread();

DWORD WINAPI thread(LPVOID par)
{
	int *k = (int*)par;

	for(int i = 0;i<5*n;i++)
	{
		cout<<*k;
		Sleep(1);
	}
	return 0;
}

void NewThread(int i)
{
	if (HEAD == NULL)
	{
		HEAD = new RR;
		TAIL = HEAD;
		HEAD->next = HEAD;
	}
	else
	{		
		TAIL->next = new RR;
		TAIL = TAIL->next;
		TAIL->next = HEAD;
	}
	TAIL->hThread = CreateThread(NULL,0,thread,&pars[i],CREATE_SUSPENDED,&(HEAD->dwThread));
	return;
}

void DelThread()
{
	CloseHandle(HEAD->hThread);

	if (HEAD == TAIL)
	{
		delete HEAD;
		TAIL = NULL;
	}
	else
	{
		HEAD = HEAD->next;
		delete TAIL->next;
		TAIL->next = HEAD;
	}
	
}

void main()
{
	HANDLE handles[2];

	for(int i = 0;i<n;i++)
	{
		pars[i] = i;
		NewThread(i);
	}

	hTimer = CreateWaitableTimer(NULL, FALSE, NULL); 

	li.QuadPart = -1;

	SetWaitableTimer(hTimer, &li, TimeInt, NULL, NULL, FALSE);

	handles[1] = hTimer;

	while(HEAD != NULL)
	{
		handles[0] = HEAD->hThread;
		ResumeThread(HEAD->hThread);
		DWORD dw = WaitForMultipleObjects(2,handles,FALSE, INFINITE); 
		switch(dw)
		{
		case WAIT_OBJECT_0: 
			cout<<"DELETED";
			DelThread();						    
			break;
		case WAIT_OBJECT_0+1:
			cout<<".";
			SuspendThread(HEAD->hThread);
			HEAD = HEAD->next;
			TAIL = TAIL->next;
			break;
		default: cout<<"ERROR";
			break;
		}
	}

	CloseHandle(hTimer);

	system("PAUSE");

	return;
}

Эта программа некоторое время работает, а потом "умирает" - останавливается и ничего не выводит=(
Может быть, я что-то неправильно делаю?=( Подскажите бедному неопытному студенту.

[Rififi]

ШеФФ

Эта программа некоторое время работает, а потом "умирает" - останавливается и ничего не выводит=(

добавь отладочный вывод в программу и проанализируй его.

[ШеФФ]

Добавил, проанализировал.
Умирает либо на функции SuspendThread(HEAD->hThread);
либо на DWORD dw = WaitForMultipleObjects(2,handles,FA LSE, INFINITE);
Не могу понять, в чем дело=(