потоки в цикле

[MasterSporta]

Здравствуйте!

написал небольшую программку, где в цикле вызывается один и тот же поток. Компилируется нормально, но при выполнении происходит ошибка.

Вот код:

#include "stdafx.h"
#include <iostream>
#include <vector>
#include <queue>
#include <windows.h>
#include <process.h>
#include <time.h>
#include <stdlib.h>
#include <fstream>
using namespace std;

HANDLE hMutex;

typedef struct tagTDATA
{
	BYTE cPriority;
	DWORD dwClientId;
} TDATA, *PTDATA;

ostream &operator<<(ostream& output, const TDATA& d)
{
	output<<"Priority: "<<(int)d.cPriority<<"; "
		<<"ClientId: "<<d.dwClientId<<endl;
	return output;
}

class Cless
{
public:
	bool operator()(TDATA d1, TDATA d2)
	{
		return d1.cPriority > d2.cPriority;
	}
};

priority_queue<TDATA, vector<TDATA>, Cless > Q;

void clientThread(PVOID pvoid)
{
	WaitForSingleObject(hMutex, INFINITE);
	PTDATA ptdata;
	ptdata = (PTDATA)pvoid;

	for(int i = 0; i < 10; i++)
	{
	ptdata->cPriority = rand();
	ptdata->dwClientId = rand()%100;
	Q.push(*ptdata);
	}
	ReleaseMutex(hMutex);
}

void serverThread(PVOID pvoid)
{
	WaitForSingleObject(hMutex, INFINITE);

	PTDATA ptdata;
	ptdata = (PTDATA)pvoid;
	
	ofstream data("data.log", ios::out);
	if(!data)
	{
		cerr<<"Epic fail"<<endl;
		exit(1);
	}

	while(!Q.empty())
	{
		*ptdata = Q.top();
		data<<*ptdata<<endl;
		Q.pop();
	}
	ReleaseMutex(hMutex);
}

void main()
{	
	srand(time(NULL));
	
	TDATA tdata;

	for(int i = 0; i < 10; i++)
		_beginthread(clientThread, NULL, &tdata);
	
	_beginthread(serverThread, NULL, &tdata);
	system("pause");
}

В чем ошибка?
Всем заранее спасибо!

[Stilet]

WaitForSingleObject(hMutex, INFINITE);

Я может слеп, но не вижу нигде инициализации мютекса...

[MasterSporta]

ой... точно, совсем забыл про его инициализацию.
Теперь все заработало, большое спасибо!!