• 15 апреля стартует «Курс «SQL-injection Master» ©» от команды The Codeby

    За 3 месяца вы пройдете путь от начальных навыков работы с SQL-запросами к базам данных до продвинутых техник. Научитесь находить уязвимости связанные с базами данных, и внедрять произвольный SQL-код в уязвимые приложения.

    На последнюю неделю приходится экзамен, где нужно будет показать свои навыки, взломав ряд уязвимых учебных сайтов, и добыть флаги. Успешно сдавшие экзамен получат сертификат.

    Запись на курс до 25 апреля. Получить промодоступ ...

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

  • Автор темы Vadik(R)
  • Дата начала
V

Vadik(R)

Всё-таки осталась ещё проблемка с мнопоточностью в делфи. Хочу сделать так, чтобы поток получал уникальное число, затем обрабатывал как-то его, но не получается раздавать потокам уникальные числа для обработки. Подскажите, в чём может быть проблема?
Вот код:
Код:
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.
И результат его работы:
d557e8f3c6c9.png
 
V

Vadik(R)

И снова, стоило только отписаться о проблеме на форуме, как пришло озарение:
Код:
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.
Дело всё в том, что я многопоточно пытаюсь вывести в стандартный поток вывода, вот он и глючит. Сами потоки получают нужные числа:
644d4317bd98.png
 
Мы в соцсетях:

Обучение наступательной кибербезопасности в игровой форме. Начать игру!