Как определить закончил ли работу поток?

@fredwriter · Регистрация: 17.10.2009

Студворк — интернет-сервис помощи студентам

Здравствуйте, как определить закончил ли работу поток?

Delphi
1
2
3
4
5
6
7
8
 begin
    Potok1 := ParallelObj.Create(true);
    Potok2 := Potok2Obj.Create(true);
    Potok1.Priority := tpNormal;
    Potok2.Priority := tpNormal;
    Potok1.Resume;
    Potok2.Resume;
  end;

@Пытливый · 03.02.2023, 13:48

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

А не проще использовать счетчик потоков и ждать его обнуления в цикле ожидания в основной программе?

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

@vrum · 03.02.2023, 18:20

Сообщение от Пытливый

Так устроит?

Например так, только код ещё не рабочий. Не могу понять, что ему ещё не хватает?
Затыкаетися на Synchronize.

Delphi
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
program Project9;
 
{$APPTYPE CONSOLE}
 
{$R *.res}
 
uses
  System.SysUtils,
  System.Classes,
  System.SyncObjs,
  System.Types;
 
type
  TConsoleThread = class(TThread)
  private
  public
    NThreadsCount: PInteger;
    procedure Execute; override;
  end;
 
var
  CS: TCriticalSection;
 
{ TConsoleThread }
procedure TConsoleThread.Execute;
var
  i :Integer;
begin
  i := 0;
  Synchronize(procedure begin WriteLn('Start ', ThreadID); end);
  while not Terminated do begin
    Inc(i);
    Sleep(50 + Random(500));
    Synchronize(procedure begin WriteLn('Work ', ThreadID); end);
    if i > 5 then Break;
  end;
  Synchronize(procedure begin WriteLn('Finish ', ThreadID); end);
  CS.Enter;
  dec(NThreadsCount^);
  CS.Leave;
end;
 
var
  CT:TConsoleThread;
  Nth, i: Integer;
  NthCount: Integer;
begin
  WriteLn('Run');
  NthCount:=3;
  CS := TCriticalSection.Create;
  Nth:=0; // счетчик потоков
  for i := 0 to NthCount-1 do begin
    CT:=TConsoleThread.Create(True);
    CT.FreeOnTerminate := True;
    CT.NThreadsCount:=Addr(Nth);
    inc(Nth);
  end;
 
  for i := 0 to NthCount-1 do begin
    CT.Start;
  end;
 
  repeat
    Sleep(5);
  until (Nth=0);
 
  CS.Free;
  WriteLn('Done');
  ReadLn;
end.

Добавлено через 10 минут
написал (выше) что попало :-)

Сообщение от Пытливый

Так устроит?

Например так, только код ещё не рабочий. Не могу понять, что ему ещё не хватает?
Затыкаетися на Synchronize.

Delphi
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
program Project9;
 
{$APPTYPE CONSOLE}
 
{$R *.res}
 
uses
  System.SysUtils,
  System.Classes,
  System.SyncObjs,
  System.Types;
 
type
  TConsoleThread = class(TThread)
  private
  public
    NThreadsCount: PInteger;
    procedure Execute; override;
  end;
 
var
  CS: TCriticalSection;
 
{ TConsoleThread }
procedure TConsoleThread.Execute;
var
  i :Integer;
begin
  i := 0;
  Synchronize(procedure begin WriteLn('Start ', ThreadID); end);
  while not Terminated do begin
    Inc(i);
    Sleep(50 + Random(500));
    Synchronize(procedure begin WriteLn('Work ', ThreadID); end);
    if i > 5 then Break;
  end;
  Synchronize(procedure begin WriteLn('Finish ', ThreadID); end);
  CS.Enter;
  dec(NThreadsCount^);
  CS.Leave;
end;
 
var
  CT:TConsoleThread;
  Nth, i: Integer;
  NthCount: Integer;
begin
  WriteLn('Run');
  NthCount:=3;
  CS := TCriticalSection.Create;
  Nth:=0; // счетчик потоков
  for i := 0 to NthCount-1 do begin
    CT:=TConsoleThread.Create(True);
    CT.FreeOnTerminate := True;
    CT.NThreadsCount:=Addr(Nth);
    inc(Nth);
    CT.Start;
  end;
 
  repeat
    Sleep(5);
  until (Nth=0);
 
  CS.Free;
  WriteLn('Done');
  ReadLn;
end.

@Rayvenor · 04.02.2023, 18:59

vrum, синхронайз не даёт зайти в процедуру. Вероятно общий ресурс используется. Если синхронайз заменить на критическую секцию, то работает, вроде даже верно. Как правильно - не знаю.
Без отладки запускал 1000 потоков - отрабатывает быстро. С отладкой больше 170 потоков начинает сильно тормозить.

Delphi
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
program Project1;
{$APPTYPE CONSOLE}
{$R *.res}
 
uses
 System.SysUtils,
 System.Classes,
 System.SyncObjs,
 System.Types;
 
type
 TConsoleThread = class(TThread)
 private
 public
  NThreadsCount: PInteger;
  procedure Execute; override;
 end;
 
var
 CSVar, CSDisp: TCriticalSection;
 
 { TConsoleThread }
procedure TConsoleThread.Execute;
var
 i: Integer;
begin
 i := 0;
 CSDisp.Enter;
 WriteLn('Start ', ThreadID);
 CSDisp.Leave;
 while not Terminated do
 begin
  Inc(i);
  Sleep(50 + Random(500));
  CSDisp.Enter;
  WriteLn('Work ', ThreadID);
  CSDisp.Leave;
  if i > 5 then
   Break;
 end;
 CSDisp.Enter;
 WriteLn('Finish ', ThreadID);
 CSDisp.Leave;
 CSVar.Enter;
 dec(NThreadsCount^);
 CSVar.Leave;
end;
 
var
 CT: TConsoleThread;
 Nth, i: Integer;
 NthCount: Integer;
 
begin
 WriteLn('Run');
 NthCount := 3;
 CSVar := TCriticalSection.Create;
 CSDisp := TCriticalSection.Create;
 Nth := 0; // счетчик потоков
 for i := 0 to NthCount - 1 do
 begin
  CT := TConsoleThread.Create(true);
  CT.FreeOnTerminate := true;
  CT.NThreadsCount := Addr(Nth);
  Inc(Nth);
  CT.Start;
 end;
 
 repeat
  Sleep(5);
 until (Nth = 0);
 
 CSVar.Free;
 CSDisp.Free;
 WriteLn('Done');
 ReadLn;
 
end.

@Пытливый · 04.02.2023, 20:22

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

Без отладки запускал 1000 потоков - отрабатывает быстро.

И какой смысл в таком количестве, ведь поток работает на реальном ядре и если свободных ядер нет, то он будет просто висеть в ожидании и ничего в нем ни синхронно ни асинхронно выполнятся не будет. Так что много не всегда - хорошо.

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

синхронайз не даёт зайти в процедуру. Вероятно общий ресурс используется. Если синхронайз заменить на критическую секцию, то работает, вроде даже верно.

Это две разные языковые конструкции и они никак заменить друг друга не могут. Если вы весь код потока завернете в критическую секцию, то он заблокирует работу остальных потоков и только после его завершения следующий поток сможет начать работать, а с ним произойдет то-же самое. Т.е. у вас будет работать основной поток и параллельно какой-то один из вашей тысячи.
Если же вы завернете код потока в синхрониз, то вообще никакой параллельности не будет, код потока сработает в основном потоке как обычная процедура.

@vrum · 04.02.2023, 20:36

Что тогда? Посоветуйте решение.
вытащить CT.Start из первого цикла и запустить отдельно? Почему затык на Synchronize?
В вашем (Пытливый) первом варианте ведь работало.

@Rayvenor · 04.02.2023, 20:49

Сообщение от Пытливый

И какой смысл в таком количестве

В данном случае без критических секций при большом количестве потоков вывод ломался.

Сообщение от Пытливый

Если вы весь код потока завернете в критическую секцию, то он заблокирует работу остальных потоков и только после его завершения следующий поток сможет начать работать, а с ним произойдет то-же самое. Т.е. у вас будет работать основной поток и параллельно какой-то один из вашей тысячи.
Если же вы завернете код потока в синхрониз, то вообще никакой параллельности не будет, код потока сработает в основном потоке как обычная процедура.

Не понял для чего вы это написали. Если посмотрите внимательно, то увидите, что критические секции не мешают параллельной работе потоков. Более того параллельность есть. Чем больше потоков одновременно запущены, тем быстрее всё отрабатывает. При запуске потоков включал ограничитель если потоков больше заданного числа.

@vrum · 05.02.2023, 10:38

Сообщение от Пытливый

Цитата Сообщение от Rayvenor Посмотреть сообщение
Без отладки запускал 1000 потоков - отрабатывает быстро.
И какой смысл в таком количестве, ведь поток работает на реальном ядре и если свободных ядер нет, то он будет просто висеть

В качестве примера вышесказанного:
это график зависимости затраченного времени счета от количества потоков. Задача: фильтрация изображения 6k*6k на i9-9900K (8 ядер + hiper threading). Четко видно, что после 16 потоков все сильно затормаживается/останавливается.

@Пытливый · 07.02.2023, 13:53

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

Что тогда? Посоветуйте решение.
вытащить CT.Start из первого цикла и запустить отдельно? Почему затык на Synchronize?
В вашем (Пытливый) первом варианте ведь работало.

Тут вся магия в методе:

Delphi
1
ThreadList.WaitFor;

По смыслу он похож на ваш код:

Delphi
1
2
3
repeat
  Sleep(5);
until (Nth = 0);

Но делает это несколько иначе. Если хотите себе мозг взорвать, то можете посмотреть его реализацию

И потому мой код, который использует один контролирующий поток и кучу пчел-потоков работает, а у вас нет.

@vrum · 07.02.2023, 17:07

Сообщение от Пытливый

И потому мой код, который использует один контролирующий поток и кучу пчел-потоков работает, а у вас нет.

Мне ваш первый код тоже понравился. Спасибо, я им воспользовался. Просто, я думал его упростить и сделать вариант без запуска контролирующего потока, но получил затыкание на Synchronize. Не могу понять чего ему не хватает.
Есть вариант с CriticalSection от Rayvenor, тоже рабочий.

@Пытливый · 07.02.2023, 17:33

Можно без контролирующего потока, но тогда прицепляться надо к какому-то экземпляру TThread для вызова WaitFor, использовать FreeOnNerminate нельзя. Единственное, что он точно сделает это дождется завершения всех потоков и CS там тоже не потребуется. Нужен ли такой калека-контроллер сильно сомневаюсь.

Добавлено через 8 минут
Вот так он будет выглядеть.

Кликните здесь для просмотра всего текста

Delphi
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
program Project0;
 
{$APPTYPE CONSOLE}
 
{$R *.res}
 
uses
  System.SysUtils, System.Classes, System.SyncObjs, System.Types;
 
type
  TConsoleThread = class(TThread)
  public
    constructor Create;
    procedure Execute; override;
  end;
 
var
  CS: TCriticalSection;
 
{ TConsoleThread }
 
constructor TConsoleThread.Create;
begin
  inherited Create(True);
end;
 
procedure TConsoleThread.Execute;
begin
  var i := 0;
  Synchronize(procedure begin WriteLn('Start ', ThreadID); end);
  while not Terminated do begin
    Inc(i);
    Sleep(50 + Random(500));
    Synchronize(procedure begin WriteLn('Work ', ThreadID); end);
    if i > 5 then Break;
  end;
  Synchronize(procedure begin WriteLn('Finish ', ThreadID); end);
end;
 
var
  ConsoleThread: TConsoleThread;
begin
  WriteLn('Run');
  for var i := 1 to 3
  do begin
     ConsoleThread := TConsoleThread.Create;
     ConsoleThread.Start;
     end;
  ConsoleThread.WaitFor;
  WriteLn('Done');
  ReadLn;
end.

@vrum · 07.02.2023, 18:05

Пытливый, Да, этот вариант "не очень". Здесь последний поток будет ждать своего завершения. А если предыдущий ещё не завершился, то уже не завершится.

@vrum · 08.02.2023, 23:08

Если заменить Sleep на CheckSynchronize получим рабочий код, который и хотел.

Кликните здесь для просмотра всего текста

Delphi
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
program Project9;
 
{$APPTYPE CONSOLE}
 
{$R *.res}
 
uses
  SysUtils,
  Classes,
  SyncObjs,
  Types;
 
type
  TConsoleThread = class(TThread)
  private
  public
    NThreadsCount: PInteger;
    procedure Execute; override;
  end;
 
var
  CS: TCriticalSection;
 
{ TConsoleThread }
procedure TConsoleThread.Execute;
var
  i :Integer;
begin
  i := 0;
  Synchronize(procedure begin WriteLn('Start ', ThreadID); end);
  while not Terminated do begin
    Inc(i);
    Sleep(50 + Random(500));
    Synchronize(procedure begin WriteLn('Work ', ThreadID); end);
    if i > 5 then Break;
  end;
  Synchronize(procedure begin WriteLn('Finish ', ThreadID); end);
  CS.Enter;
    dec(NThreadsCount^);
  CS.Leave;
end;
 
var
  CT:TConsoleThread;
  Nth, i: Integer;
  NthCount: Integer;
  b: Boolean;
begin
  WriteLn('Run');
  NthCount:=3;
  CS := TCriticalSection.Create;
  Nth:=0; // счетчик потоков
  for i := 0 to NthCount-1 do begin
    CT:=TConsoleThread.Create(True);
    CT.FreeOnTerminate := True;
    CT.NThreadsCount:=Addr(Nth);
      inc(Nth);
    CT.Resume;
  end;
 
  repeat
    b:=CheckSynchronize(5);
  until (Nth=0);
 
  CS.Free;
  WriteLn('Done');
  ReadLn;
end.

Новые блоги и статьи Все статьи Все блоги /
Debian 13: Установка Lazarus QT5 ВитГо 09.05.2026 Эта инструкция моя компиляция инструкций volvo https:/ / www. cyberforum. ru/ blogs/ 203668/ 10753. html и его же старой инструкции по установке Lazarus с gtk2. . .	Нейросеть на алгоритме "эстафета хвоста" как перспектива. Hrethgir 06.05.2026 На десерт, когда запущу сервер. Статья тут https:/ / habr. com/ ru/ articles/ 1030914/ . Автор я сам, нейросеть только помогает в вопросах которые мне не известны - не знаю людей которые знали-бы. . .	Асинхронный приём данных из COM-порта Argus19 01.05.2026 Асинхронный приём данных из COM-порта Купил на aliexpress термопринтер QR701. Он оказался странным. Поключил к Arduino Nano. Был очень удивлён. Наотрез отказывается печатать русские буквы. Чтобы. . .	попытка написать игровой сервер на C++ pyirrlicht 29.04.2026 попытка написать игровой сервер на плюсах с открытым бесконечным миром. возможно получится прикрутить интерпретатор питон для кастомизации игровой логики. что есть на текущий момент:. . .
Контроль уникальности выбранного документа-основания при изменении реквизита Maks 28.04.2026 Алгоритм из решения ниже разработан на примере нетипового документа "ЗаявкаНаРемонтСпецтехники", разработанного в КА2. Задача: уведомлять пользователя, если указанная заявка (документ-основание). . .	Благородство как наказание Maks 24.04.2026 У хорошего человека отношения с женщинами всегда складываются трудно. А я человек хороший. Заявляю без тени смущения, потому что гордиться тут нечем. От хорошего человека ждут соответствующего. . .	Валидация и контроль данных табличной части документа перед записью Maks 22.04.2026 Алгоритм из решения ниже реализован на примере нетипового документа, разработанного в КА2. Задача: контроль и валидация данных табличной части документа перед записью с учетом регламента компании. . .	Отчёт о затраченных материалах за определенный период с макетом печатной формы Maks 21.04.2026 Отчёт из решения ниже размещён в конфигурации КА2. Задача: разработка отчёта по затраченным материалам за определённый период, с возможностью вывода печатной формы отчёта с шапкой и подвалом. В. . .

@vrum 2 / 2 / 0 Регистрация: 06.12.2022 Сообщений: 16
	04.02.2023, 20:36
	Что тогда? Посоветуйте решение. вытащить CT.Start из первого цикла и запустить отдельно? Почему затык на Synchronize? В вашем (Пытливый) первом варианте ведь работало. 0

@vrum 2 / 2 / 0 Регистрация: 06.12.2022 Сообщений: 16
	07.02.2023, 18:05
	Пытливый, Да, этот вариант "не очень". Здесь последний поток будет ждать своего завершения. А если предыдущий ещё не завершился, то уже не завершится. 0