Потоки... Потоки? Потоки!, FPC Опции

[Archon]

Сел переписывать движок Doomed Game под потоки и... понял, что мои знания о потокобезопасности оставляют желать лучшего. Может быть кто-нибудь (volvo?) проведет несколько лекций на эту тему? Думаю, это не только меня может заинтересовать. Или может я просто задам свои вопросы?

[Archon]

Вот !!! Все, что нужно, ты уже сказал... Тебе надо просто гарантировать атомарность (неделимость) операции изменения значения переменной. Для этого вместо Inc() используй InterlockedIncrement() или InterlockedExchangeAdd(), обе функции описаны в System... Все Interlocked... функции гарантируют монопольное изменение значения переменной (к тому же, они и выполняются быстрее, Рихтер говорит о примерно 50 тактах против 1000, которые требуются для перехода в Kernel-mode из User-mode)

А неделимость чтения кто гарантировать будет? Вдруг запись произойдет в середине процесса чтения? К тому же, Inc - это только пример. Да и на месте Integer может стоять какой-нибудь TList.
Я набросал примерно вот что в псевдокоде:

unit u_test;
{$mode objfpc}

interface

type
	TTest = class
	private
		FData: Integer;
		{Объявляем Mutex;}
		function GetData: Integer;
		procedure SetData(Value: Integer);
	public
		constructor Create;
		destructor Destroy; override;
		procedure OutputData;
		procedure IncData(Value: Integer);
		procedure RandomData;
		property Data: Integer read GetData write SetData;
	end;

var
	Test: TTest = nil;

implementation

// private

function TTest.GetData: Integer;
begin
	try
		{Пытаемся захватить Mutex в течении N секунд.}
		if {получилось} then
			Result := FData
		else begin
			Result := 0;
			WriteLn('Error reading.');
		end;
	finally
		{Освобождаем Mutex.}
	end;
end;

procedure TTest.SetData(Value: Integer);
begin
	try
		{Пытаемся захватить Mutex в течении N секунд;}
		if {получилось} then
			FData := Value;
		else
			WriteLn('Error writing.');
	finally
		{Освобождаем Mutex;}
	end;
end;

// public

constructor TTest.Create;
begin
	FData := 0;
	{Создаем Mutex;}
end;

destructor TTest.Destroy;
begin
	WriteLn('I''m dying!');
end;

procedure TTest.OutputData;
begin
	WriteLn('Data: ', Data);
end;

procedure TTest.IncData(Value: Integer);
begin
	Data := Data + Value;
end;

procedure TTest.RandomData;
var
	Temp: Integer;
begin
	Temp := Random(10);
	Data := Temp;
end;

initialization
	Test := TTest.Create;
finalization
	Test.Destroy;
end.

Добавлено через 1 мин.
Кстати, еще ведь есть и прямой доступ к полю через property , так что там не только Inc.

Исправил: добавил else в условиях.

Сообщение отредактировано: Archon - 28.06.2009 3:05