Утечка памяти в потоках + указатели.

[Masam]

Добрый день.

Дано:

Описание типов:

//Динамический массив
type
  TErrorsLog = array of string;

//Рабочий поток
type
  TThreadTest = class(TThread)
  private
    text: string;
    procedure SetLog;
  protected
    procedure Execute; override;
  public
    PErrorsLog: ^TErrorsLog; //Как корректно передать массив, что бы несколько потоков его могли заполнять?
    PSection: ^TCriticalSection;
    id: integer;
end;

//Управляющий поток
type
  TThreadMain = class(TThread)
  private
    ErrorsLog: TErrorsLog;
    Section: TCriticalSection;
    Tests : array of TThreadTest;
    procedure SetLog;
  protected
    procedure Execute; override;
  public
    id, n: integer;
end;

Тело рабочего потока:

//Тело рабочего потока
procedure TThreadTest.Execute;
var
  i: integer;
begin
  try
    i := 0;
    while not Terminated do
      begin
        i := i + 1;
        text := 'id: ' + inttostr(id) + ' # test: ' + IntToStr(i);
        SetLog;
        Sleep(1);
      end;
  finally
    //Dispose(PErrorsLog); - //если очищаю указатель, в управляющем потоке переменная "ErrorsLog" - становится пустой.
    //Dispose(PSection);
  end;
end;

procedure TThreadTest.SetLog;
var
  n : integer;
begin
  PSection^.Enter;
  n := Length(PErrorsLog^);
  SetLength(PErrorsLog^, n + 1);
  PErrorsLog^[n] := text;
  PSection^.Leave;
end;

Тело управляющего потока:

//Тело управляющего потока
procedure TThreadMain.Execute;
var
  i: integer;
begin
  try
    Section := TCriticalSection.Create;

    SetLength(ErrorsLog, 0);
    SetLength(Tests, n);
    for i := 0 to n - 1 do
      begin
        Tests[i] := TThreadTest.Create(true);
        Tests[i].Priority := tpNormal;

        Tests[i].id := i;
        Tests[i].PSection := @Section;
        Tests[i].PErrorsLog := @ErrorsLog;

        Tests[i].Resume;
      end;

    while not Terminated do
      begin
        Sleep(50);
      end;

    for i := 0 to n - 1 do
      begin
        Tests[i].Terminate;
        if Tests[i].Suspended then
          Tests[i].Resume;
        Tests[i].WaitFor;
      end;

    Synchronize(SetLog);

  finally
    for i := 0 to n - 1 do
      Tests[i].Free;

    SetLength(ErrorsLog, 0);
    SetLength(Tests, 0);

    Section.Destroy;
  end;
end;

procedure TThreadMain.SetLog;
var
  i, n: integer;
begin
  n := Length(ErrorsLog);
  for i := 0 to n - 1 do
    Form1.Memo1.Lines.Add(ErrorsLog[i]);
end;

Форма:

var
  Form1: TForm1;
  ThreadMain: TThreadMain;

implementation

{$R *.dfm}

//Кнопка старт записи в массив
procedure TForm1.Button1Click(Sender: TObject);
var
  i, n: integer;
begin
  Memo1.Lines.Clear;
  if ThreadMain = nil then
    begin
      ThreadMain := TThreadMain.Create(true);
      ThreadMain.Priority := tpNormal;
      ThreadMain.n := 1;
      ThreadMain.id := 1;
      ThreadMain.Resume;
    end;
end;

//Кнопка завершение записи в массив
procedure TForm1.Button2Click(Sender: TObject);
begin
  if ThreadMain <> nil then
    begin
      ThreadMain.Terminate;
      if ThreadMain.Suspended then
        ThreadMain.Resume;
      ThreadMain.WaitFor;
      ThreadMain.Free;
      ThreadMain := nil;
    end;
end;

При много кратном нажатии кнопок старта управляющего потока и его завершения с различными интервалами программа отъедает места под максимальный массив и не выгружает его, подскажите пожалуйста как правильно организовать передачу массива в дополнительные потоки и его наполнение и очистку?

Дополнительно: Если в дополнительных потоках устанавливаю очищаю указатель "Dispose(PErrorsLog);" на массив, то почему то переменная в управляющем потоке становится пустой?

[evg_m]

    PErrorsLog: ^TErrorsLog; //Как корректно передать массив, что бы несколько потоков его могли заполнять?
    PSection: ^TCriticalSection;

все объекты и динамические массивы уже указатели.
поэтому просто

    ErrorsLog: TErrorsLog; //Как корректно передать массив, что бы несколько потоков его могли заполнять?
    Section: TCriticalSection;

        Tests[i].id := i;
        Tests[i].Section := Section;
        Tests[i].ErrorsLog := ErrorsLog;

это и так будет один и тот же объект/массив хотя и записанный в множестве разных переменных.
и теперь никаких здесь Dispose;
передавать можно как угодно ЕСЛИ заполнять в критической секцией.

есть хорошее правило удалять должен тот кто создавал.
т.е. управляющий поток.
и тогда когда она ему больше не нужна.

[Masam]

Спасибо большое за ответ.

Тогда у меня еще ряд вопросов:
1) Имеет ли место тут утечка памяти или это такое поведение менеджера памяти?
К примеру я создаю отдельную кнопку:

procedure TForm1.Button3Click(Sender: TObject);
var
  ErrorsLog: TErrorsLog;
  i, n: integer;
begin
  Memo1.Lines.Clear;

  for i := 0 to 10000 do
    begin
      SetLength(ErrorsLog, i + 1);
      ErrorsLog[i] := 'test: ' + IntToStr(i + 1);
    end;

  n := Length(ErrorsLog);
  for i := 0 to n - 1 do
    Form1.Memo1.Lines.Add(ErrorsLog[i]);

  SetLength(ErrorsLog, 0);
end;

Тогда при запуске программы она занимает место 2МБ, после нажатия кнопки и до выполнения "SetLength(ErrorsLog, 0);" она занимает 3МБ, и после выполнения "SetLength(ErrorsLog, 0);", объем памяти не уменьшился.

2) Если я у рабочего потока создам дополнительные поля "массивы / объекты", нужно ли их очищать по завершению потока и достаточно ли будет из управляющего потока просто выполнить "Tests[i].Free;", не будет ли в данном случае утечки памяти?

Пример:

//Рабочий поток
type
  TThreadTest = class(TThread)
  private
    text: string;
    Array1: array of string;
    Array2: array of string;
    ....

[Pavia]

ThreadMain.Resume;

Почему пишете на старом Delphi?

CriticalSection:TCriticalSection - следует создавать глобально, а не в объекте. Она патчит код и при деструкторе восстанавливает, то что там было.

Critical sections must be global in scope so that they are available to all threads.

if ThreadMain.Suspended then
ThreadMain.Resume;

лишняя пара строчек Suspended и resume применяется отладчиком. Так что после первого запуска resume больше дёргать его не следует. Это архитектурный баг дельфи.
Вместо суспендит и ресуме вам надо будет менять в своем коде приоритет
ThreadMain.Priority
В данном примере это не критично. Просто на будщее.

[Pavia]

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

Тогда при запуске программы она занимает место 2МБ, после нажатия кнопки и до выполнения "SetLength(ErrorsLog, 0);" она занимает 3МБ, и после выполнения "SetLength(ErrorsLog, 0);", объем памяти не уменьшился.

Это нормально строки для memo1 отпочковались(инстацирповались) и записались на верх кучи. А вы освободили те что посерёдке.

[Pavia]

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

1) Имеет ли место тут утечка памяти или это такое поведение менеджера памяти?

Утечки следует смотреть в EurekaLog или madExcept или аналогичной программе.

[Pavia]

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

Спасибо большое за ответ.

Тогда у меня еще ряд вопросов:


2) Если я у рабочего потока создам дополнительные поля "массивы / объекты", нужно ли их очищать по завершению потока и достаточно ли будет из управляющего потока просто выполнить "Tests[i].Free;", не будет ли в данном случае утечки памяти?

Пример:

//Рабочий поток
type
  TThreadTest = class(TThread)
  private
    text: string;
    Array1: array of string;
    Array2: array of string;
    ....

Строки и массивы в Delphi автоматически освобождаются.

А вот объекты и динамическая переменные сколько раз их создал столько и надо удалить. Колличество конструкторов должно уравнять колличество деструкиеров. Free в переводе очистка. Она вызывает деструкторы и тот сам подчищает переменные управляемого рода такие как строки и динамические массивы.

Ещё раз повторю где память выделили в том объекте и освобождаете. Так ошибки проще искать.

[Masam]

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

все объекты и динамические массивы уже указатели.
поэтому просто

    ErrorsLog: TErrorsLog; //Как корректно передать массив, что бы несколько потоков его могли заполнять?
    Section: TCriticalSection;

        Tests[i].id := i;
        Tests[i].Section := Section;
        Tests[i].ErrorsLog := ErrorsLog;

это и так будет один и тот же объект/массив хотя и записанный в множестве разных переменных.
и теперь никаких здесь Dispose;
передавать можно как угодно ЕСЛИ заполнять в критической секцией.

есть хорошее правило удалять должен тот кто создавал.
т.е. управляющий поток.
и тогда когда она ему больше не нужна.

К сожалению ответ не верный.

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

[Masam]

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

Утечки следует смотреть в EurekaLog или madExcept или аналогичной программе.

Спасибо за ответ. Очень полезно.

[Masam]

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

Почему пишете на старом Delphi?

CriticalSection:TCriticalSection - следует создавать глобально, а не в объекте. Она патчит код и при деструкторе восстанавливает, то что там было.




лишняя пара строчек Suspended и resume применяется отладчиком. Так что после первого запуска resume больше дёргать его не следует. Это архитектурный баг дельфи.
Вместо суспендит и ресуме вам надо будет менять в своем коде приоритет
ThreadMain.Priority
В данном примере это не критично. Просто на будщее.

Хм.. по вопросу версии делфи, у меня делфи XE3, да не новая версия, просто так сложилась что использую именно эту версию.

А по приоритетам не понял, судя по описанию самого низкого приоритета, поток продолжает работать, мне же важно что бы выполнение цикла приостанавливалось:

    while not Terminated do
      begin
        i := i + 1;
        text := 'id: ' + inttostr(id) + ' # test: ' + IntToStr(i);
        SetLog;
        Sleep(1);
      end;

Как более корректно это должно быть реализовано?