Многопоточные приложения

[MaTBeu]

Спасибо за информацию! Будем разбираться А насчет примера, я думаю, если у меня возникнут сложности при написании программы, я обращусь к Вам.

[MaTBeu]

Многопоточные приложения Дубль 2
Здравствуйте. У меня вот возник вопрос. Он возможно сликом ламерский, но я действительно в ступоре. Есть схема синхронизации под названием Read/Write Lock. Но... есть одно "но", и это "но" не дает мне покоя. Где в данном примере потоки? Я просто не знаю с чем работать и как эти потоки создавать. Помогите разобраться, код ниже.

#include <windows.h>
#include <assert.h>
#include <string.h>


class CRWLock
{
protected:
	HANDLE					hExitEvent;
	CRITICAL_SECTION		cs;
	DWORD volatile			hExclusiveOwner;
	long volatile			nReaders;
	long volatile			nExclusiveRecursion;
public:
	CRWLock()
	{
		this->hExitEvent = CreateEvent(NULL, FALSE, FALSE, NULL);
		InitializeCriticalSection(&this->cs);
		this->nReaders = 0;
		this->hExclusiveOwner = NULL;
		this->nExclusiveRecursion = 0;

		assert(this->hExitEvent);
	};
	~CRWLock()
	{
		CloseHandle(this->hExitEvent);
		DeleteCriticalSection(&this->cs);
	};
	void AcquireLockShared()
	{
		// Здесь пытаемся получить право на чтение
		// Ждём входа в критическую секцию и, как только попадаем в неё,
		// увеличиваем счётчик "читателей" и сразу же выходим из критической секции.

		EnterCriticalSection(&this->cs);
		this->nReaders ++;
		LeaveCriticalSection(&this->cs);
	};
	void AcquireLockExclusive()
	{
		// Здесь пытаемся получить уже право на запись
		// Аналогично ждём критическую секцию

		EnterCriticalSection(&this->cs);

		// Но уже не покидаем её сразу же, а, во-первых, увеличиваем счётчик 

рекурсивных
		// входов в критичекую секцию, (на тот случай, если Мы уже вошли в в неё в 

этом же 
		// потоке) и, во-вторых, если это первый вход потока в критическую секцию, 

ждём
		// когда с данными закончат работать все читающие потоки - проверяем 

количество 
		// читателей и, если они присутствуют, ждём сигнала о выходе очередного 

читателя 
		// из режима чтения. Новые "читатели" получить доступ пока не смогут - 

критическую 
		// секцию мы заняли.

		this->nExclusiveRecursion ++;
		if(this->hExclusiveOwner != GetCurrentThreadId())
		{
			// Будем ждать, когда "выйдут" все "читатели" только если уже не 

владеем защёлкой
			// иначе это уже было выполнено раньше.

			this->hExclusiveOwner = GetCurrentThreadId();

			while(this->nReaders > 0)
			{
				// Ждём сигнала о выходе очередного читателя
				WaitForSingleObject(this->hExitEvent, INFINITE);
			}
		}
	}
	void ReleaseLock()
	{
		// А здесь освобождаем нашу защелку.
		if(this->hExclusiveOwner == GetCurrentThreadId())
		{
			// Если мы выходим из эксклюзивного режима, то уменьшаем число 

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

владельца в NULL
			this->nExclusiveRecursion --;
			if(0 == this->nExclusiveRecursion)
			{
				this->hExclusiveOwner = NULL;
			}

			// и только теперь "отпускаем" критическую секцию. Число входов в неё 

должно 
			// быть равно числу выходов, так что в случае рекрсивного входа, 

раньше времени 
			// она не освободится.
			LeaveCriticalSection(&this->cs);
		}
		else
		{
			// Если же мы - "читатель", то просто уменьшаем количество 

"читателей" (поскольку
			// мы, являясь читателем, уже вышли из критической секции, ещё в 

AcquireLockShared, 
			// то вынуждены во избежание проблем делать это атомарно - через 

InterlockedDecrement.
			
			InterlockedDecrement(&this->nReaders);
			
			

			SetEvent(this->hExitEvent);
		}
	}
};

В msdn я читал о потоках... Но... там такие яркие примеры, что я в них понял чуть меньше, чем ничего.

[B_N]

MaTBeu, потоки создаются элементарно:

#include <windows.h>
#include <stdio.h>

typedef struct _THREAD_PARAM
{
	DWORD dwParam;
	//........................
	//........................
}THREAD_PARAM, *LPTHREAD_PARAM;


//Функция первого потока
DWORD WINAPI Thread1(LPTHREAD_PARAM lpParameter)
{
	printf("Thread 1 reporting: Execution started, parameter=%d\n", lpParameter->dwParam);
	// Некий код потока
	Sleep(8000);
	puts("Thread 1 reporting: Work done.");
	return 0;
}

//Функция второго потока
DWORD WINAPI Thread2(LPTHREAD_PARAM lpParameter)
{
	printf("Thread 2 reporting: Execution started, parameter=%d\n", lpParameter->dwParam);
	// Некий код потока
	Sleep(3000);
	puts("Thread 2 reporting: Work done.");
	return 0;
}

//Функция третьего потока
DWORD WINAPI Thread3(LPTHREAD_PARAM lpParameter)
{
	printf("Thread 3 reporting: Execution started, parameter=%d\n", lpParameter->dwParam);
	// Некий код потока
	Sleep(5000);
	puts("Thread 3 reporting: Work done.");
	return 0;
}

int main()
{
	HANDLE			hThreads[3];
	THREAD_PARAM	Params[3];

	// Запускаем первый поток
	Params[0].dwParam = 100;
	hThreads [0] = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)Thread1, &Params[0], 0, NULL);
	puts("main reporting: Thread 1 created");

	// Запускаем второй поток
	Params[1].dwParam = 200;
	hThreads [1] = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)Thread2, &Params[1], 0, NULL);
	puts("main reporting: Thread 2 created");

	// Запускаем третий поток
	Params[2].dwParam = 300;
	hThreads [2] = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)Thread3, &Params[2], 0, NULL);
	puts("main reporting: Thread 3 created");

	// И теперь ждём, когда они все завершатся
	puts("Waiting for threads....");
	WaitForMultipleObjects(3, hThreads, TRUE, INFINITE);

	puts("main reporting: done");
	getchar();
	return 0;
}

[MaTBeu]

Спасибо на этом. Немного разобрался. А если вот создавать класс UserThread, к примеру, то какие, помимо DWORD dwParam;, поля должны у него присутствовать? Или есть уже готовый класс Thread и его можно унаследовать?

[B_N]

Сообщение от MaTBeu

..........какие, помимо DWORD dwParam;, поля должны у него присутствовать? Или есть уже готовый класс Thread и его можно унаследовать?

Да какие угодно, хоть большую советскую энциклопедию. Функция потока может принять один параметр, а уж что туда передавать зависит от нашей фантазии, как правило, это указатель на что-нибудь. А насчёт классов - можно конечно. Только не помню, на Борланде Вы творите, или на MS. Реализации классов потоков у них довольно сильно отличаются, к тому жеу Борланда она какая-то дурацкая, лучше не скажешь. В принципе, этот единственный параметр позволяет замечательно передавать в поток указатель this. Вот здесь я приводил такой вариант на дельфи.

[MaTBeu]

Я, как Вы выражаетесь "творю" на MSVS 2008 TS Кстати о том примере на Делфи... Короче о создании потоков я понял (это наверное, единственное, что я понял из кода на Делфи, потому как Делфи никогда не учил). Но в целом задумка мне понятна.

ПС: еще один вопрос. Чтобы связать Вашу схему синхронизации с массивом потоков, к примеру, которые представляют также отдельный класс, нужно просто создать обьект класса CRWLock, а потоки сами к нему привяжутся? Просто вызывать методы этого класса, когда нужно и все?

[B_N]

Сообщение от MaTBeu

Чтобы связать Вашу схему синхронизации с массивом потоков, к примеру, которые представляют также отдельный класс, нужно просто создать обьект класса CRWLock, а потоки сами к нему привяжутся? Просто вызывать методы этого класса, когда нужно и все?

Ну в принципе - да. Объявляете какой-то глобальный объект данных, к которому привязываете этот Lock, а потом в любом потоке можете читать/писать эти данные - получаете соттветствующий доступ через AcquireLockExclusive/AcquireLockShared, пишете/читаете и отпускаете после этого защелку через ReleaseLock.

[MaTBeu]

Премного благодарен. На этом мои вопросы ПОКА исчерпаны