r05 04 (11)

[ Pobierz całość w formacie PDF ]
.Nietrudno si� wi�c domy�li�, i� warto��lMaximumCount okre�la maksymal�n� liczb� zasobów, które zostan� �przepuszczone�przez semafor, czyli � w momencie u�ycia semafora jako parametru wywo�aniafunkcji synchronizuj�cej (np.WaitForSin�gleObject()) zastan� go z dodatni�warto�ci� licznika.Wyja�nia to jednocze�nie ty�powe zastosowanie semafora �s�u�y on do synchronizacji dost�pu do zasobu, który mo�e by� wspó�dzielonyprzez co najwy�ej zadan� a priori liczb� procesów; liczba ta jest jednocze�niewarto�ci� pocz�tkow� licznika semafora.Powracaj�c do naszego przyk�adu z inicjowaniem tablicy � mo�e by� ona�obs�ugiwa�na� w danej chwili przez co najwy�ej jeden w�tek � je�eli wi�cu�yjemy do synchroni�zacji semafora, jego warto�� pocz�tkowa (lInitialCount)powinna wynosi� w�a�nie 1.Poni�szy wydruk, pochodz�cy z projektu Sema4.dpr, przedstawia ostatni� ju�wersj� dwuw�tkowego inicjowania tablicy, oczy�wi�cie z wykorzystaniemsemafora.Wydruk 5.7.Synchronizacja dost�pu do tablicy za pomoc� semaforaunit Main;interfaceusesWindows, Messages, SysUtils, Classes, Graphics, Controls, Forms, Dialogs,StdCtrls;typeTMainForm = class(TForm)Button1: TButton;ListBox1: TListBox;procedure Button1Click(Sender: TObject);privateprocedure ThreadsDone(Sender: TObject);end;TFooThread = class(TThread)protectedprocedure Execute; override;end;varMainForm: TMainForm;implementation{$R *.DFM}constMaxSize = 128;varNextNumber: Integer = 0;DoneFlags: Integer = 0;GlobalArray: array[1.MaxSize] of Integer;hSem: THandle = 0;function GetNextNumber: Integer;beginResult := NextNumber; // zwró� warto�� zmiennej globalnejInc(NextNumber); // zwi�ksz zmienn� globaln�end;procedure TFooThread.Execute;vari: Integer;WaitReturn: DWORD;beginOnTerminate := MainForm.ThreadsDone;WaitReturn := WaitForSingleObject(hSem, INFINITE);if WaitReturn = WAIT_OBJECT_0 thenbeginfor i := 1 to MaxSize dobeginGlobalArray[i] := GetNextNumber; // ustaw element tablicySleep(3 + Random(12)); // pozwól dzia�a� innym w�tkomend;end;ReleaseSemaphore(hSem, 1, nil);end;procedure TMainForm.ThreadsDone(Sender: TObject);vari: Integer;beginInc(DoneFlags);if DoneFlags = 2 then // upewnij si�, �e obydwa w�tki zosta�y zwolnionebeginfor i := 1 to MaxSize do{ wype�nij list� zawarto�ci� tablicy }Listbox1.Items.Add(IntToStr(GlobalArray[i]));CloseHandle(hSem);end;end;procedure TMainForm.Button1Click(Sender: TObject);beginhSem := CreateSemaphore(nil, 1, 1, nil);// utwórz i uruchom obydwa w�tkiTFooThread.Create(False);TFooThread.Create(False);end;end.Utworzenie semafora nast�puje bezpo�rednio przed utworzeniem obydwu w�tków(war�to�ci� pocz�tkow� licznika semafora jest 1, co przed chwil� ju�wyja�nili�my):hSem := CreateSemaphore(nil, 1, 1, nil);TFooThread.Create(False);TFooThread.Create(False);Przed rozpocz�ciem krytycznej p�tli inicjuj�cej elementy tablicy wywo�ywanajest funk�cja synchronizuj�ca WaitForSingleObject(), odwo�uj�ca si� do semaforaza po�red�nictwem jego uchwytu hSem:WaitReturn := WaitForSingleObject(hSem, INFINITE);Rozpocz�cie realizacji p�tli odbywa si� tylko wtedy, gdy oczekiwanie zako�czy�osi� na skutek stanu sygnalnego semafora:if WaitReturn = WAIT_OBJECT_0then�W�tek, opuszczaj�c krytyczn� p�tl� (stanowi�c� w tym wypadku rodzaj zasobu osynchronizo�wanym dost�pie) sygnalizuje ten fakt przez wywo�anie funkcjiReleaseSemaphore():Function ReleaseSemaphore(hSEmaphore: THandle; lReleaseCount: Longint;lpPreviousCount: Pointer): BOOL; stdcall;Pierwszym parametrem wywo�ania jest oczywi�cie uchwyt semafora u�ywanego dosyn�chronizacji.Parametr lReleaseCount okre�la, o ile nale�y zwi�kszy� warto��licznika semafora � musi to by� warto�� dodatnia, niekoniecznie równa 1 (cho�akurat w tym przypadku jest).Mo�liwo�� zwi�kszenia licznika semafora o wi�cej ni� 1 w pojedynczym wywo�aniufunkcji ReleaseSemaphore() okazuje si� czasem niezwykle przydatna.Jakoprzyk�ad rozpatrzmy aplikacj�, w ramach której wi�ksza liczba w�tkówdrugorz�dnych wykorzy�stuje wspó�bie�nie jaki� zasób, zdolny �obs�u�y�jednocze�nie co najwy�ej 10 z nich.Je�denasty w�tek, zg�aszaj�c ��daniedost�pu do zasobu, napotka na zerow� warto�� semafo�ra i b�dzie musia�poczeka�.Za�ó�my teraz, i� podczas tego oczekiwania wszystkie 10 w�tkówzako�czy�o si� w sposób awaryjny i �aden z nich nie zd��y� �podnie��semafo�ra, tj.wywo�a� funkcji ReleaseSemaphore().Efekt jest taki, i�aktualnie �aden w�tek z zasobu nie korzysta, lecz dost�p do niego jest wdalszym ci�gu zablokowany, gdy� licz�nik semafora ma warto�� 0.W tej sytuacjiw�tek g�ówny móg��by (po wykonaniu ewentualnych czynno�ci �naprawczych�)zadecydowa� o ponownym udost�pnieniu zasobu � musia�by w tym celu zwi�kszy�odpowiednio warto�� licznika, w�a�nie o 10.Z powy�szego opisu wynikajednocze�nie �kosmopolityczny� charakter semaforów � �aden semafor nie jestprzynale�ny do �adnego szczególnego w�tku, a wi�c wszystkie w�tki mog� u�ywa�go bez ogranicze�.Innym ciekawym wykorzystaniem procedury ReleaseSemaphore() � sugerowanym przezsystem pomocy Delphi � jest zablokowanie dost�pu do chronionego zasobu na czaswykonywania przez w�tek lub aplikacj� pewnych czynno�ci inicjuj�cych.Semaforjest tworzony z zerow� warto�ci� pocz�tkow� licznika, co chwilowo blokujedost�p do zasobu; ostateczne nadanie licznikowi semafora ��danej (dodatniej)warto�ci pocz�tkowej nast�puje w�a�nie za pomoc� funkcji ReleaseSemaphore().Próba zwi�kszenia licznika semafora ponad ustalony limit (okre�lony przeztrzeci parametr funk�cji CreateSemaphore()) nie powiedzie si� � funkcjaReleaseSemaphore() zwróci warto�� FALSE.Ostatni parametr wywo�ania funkcji ReleaseSemaphore() � lpPreviousCount �umo�liwia wskazanie zmiennej typu longint, do której wpisana zostaniepoprzednia warto�� licznika � tj.ta sprzed wywo�ania funkcji; podanie warto�ciNIL oznacza rezy�gnacj� z tej mo�liwo�ci [ Pobierz całość w formacie PDF ]

Search

Podstrony