Проблема Синхронизации Winapi Потоков

Vadik(R)

Well-Known Member
12.12.2007
469
0
#1
Всё-таки осталась ещё проблемка с мнопоточностью в делфи. Хочу сделать так, чтобы поток получал уникальное число, затем обрабатывал как-то его, но не получается раздавать потокам уникальные числа для обработки. Подскажите, в чём может быть проблема?
Вот код:
Код:
program MultiThread;

{$APPTYPE CONSOLE}

uses
Classes, SysUtils, Windows;

var
Finish, i, Number, Start, ThreadsCount: Integer;
Mutex: THandle;
ThreadId: Cardinal;
Threads: Array [1..100] of THandle;

function GetNext: Integer;
begin
WaitForSingleObject(Mutex, INFINITE);
Result := Number;
if Number <= Finish then
begin
Number := Number + 1;
end;
ReleaseMutex(Mutex);
Writeln('Current number is: ', Result);
end;

function GrabbingThread(Parameter: Pointer): Cardinal; stdcall;
var
Number: Integer;
begin
Number := GetNext;
while Number <= Finish do
begin
Number := GetNext;
end;
Result := 0;
end;

begin
IsMultiThread := True;
Write('From id: ');
Readln(Start);
Write('To id: ');
Readln(Finish);
Write('Number of threads: ');
Readln(ThreadsCount);
Mutex := CreateMutex(nil, False, nil);
Number := Start;
for i := 1 to ThreadsCount do
begin
Threads[i] := CreateThread(nil, 0, @GrabbingThread, nil, 0, ThreadId);
end;
WaitForMultipleObjects(ThreadsCount, @Threads, True, INFINITE);
for i := 1 to ThreadsCount do
begin
CloseHandle(Threads[i]);
end;
CloseHandle(Mutex);
Readln;
end.
И результат его работы:
 

Vadik(R)

Well-Known Member
12.12.2007
469
0
#2
И снова, стоило только отписаться о проблеме на форуме, как пришло озарение:
Код:
program MultiThread;

{$APPTYPE CONSOLE}

uses
Classes,
SysUtils,
Windows;

var
Finish, i, Number, Start, ThreadsCount: Integer;
Mutex: THandle;
Records: Array [1..100] of Integer;
ThreadId: Cardinal;
Threads: Array [1..100] of THandle;

function GetNext: Integer;
begin
WaitForSingleObject(Mutex, INFINITE);
Result := Number;
if Number <= Finish then
begin
Number := Number + 1;
end;
ReleaseMutex(Mutex);
Writeln('Current number is: ', Result);
end;

function GrabbingThread(Parameter: Pointer): Cardinal; stdcall;
var
Number: Integer;
begin
Number := GetNext;
while Number <= Finish do
begin
Records[Number] := Number;
Number := GetNext;
end;
Result := 0;
end;

begin
IsMultiThread := True;
Write('From id: ');
Readln(Start);
Write('To id: ');
Readln(Finish);
Write('Number of threads: ');
Readln(ThreadsCount);
Mutex := CreateMutex(nil, False, nil);
Number := Start;
for i := 1 to ThreadsCount do
begin
Threads[i] := CreateThread(nil, 0, @GrabbingThread, nil, 0, ThreadId);
end;
WaitForMultipleObjects(ThreadsCount, @Threads, True, INFINITE);
for i := 1 to ThreadsCount do
begin
CloseHandle(Threads[i]);
end;
CloseHandle(Mutex);
Readln;
for i := 1 to Finish - Start + 1 do
begin
Writeln(Records[i]);
end;
Readln;
end.
Дело всё в том, что я многопоточно пытаюсь вывести в стандартный поток вывода, вот он и глючит. Сами потоки получают нужные числа: