[stalkernet]

Доброго Всем.

Собственно ситуация программа для статистики. Делается выборка из блока данных по определенным правилам.

есть тип запись обьедененная в массив обьявляю так:

Код:

type
 TDataSection = record
   Data: TBytes;
   MD5: RecMD5uint64;
   PRuleN: uint32;
   NumBlock: byte;
   BtLen: word; //byte;
   SectUse: byte;
 end;

type
  TForm1 = class(TForm)
....

  public
   FDDataSect: TArray<TArray<TDataSection>>;
   OutFDDataSect: TArray<TArray<TDataSection>>;

есть поток в нем обьявляю так

Код:

type
  TFindTr = class(TThread)
  private
    { Private declarations }
  public
   DataArr: TArray<TArray<TDataSection>>;
   RuleArr: TArray<TArray<TDataSection>>;

// исполняемая часть
procedure TFindTr.Execute;

 while CloseTR = 0 do begin // закрыть поток по внешнему требованию
  StatWork := 1;
  StopFind := 0;
  for NumRule := FStart to FEnd do begin
   Move((Pointer(DataArr[NumBlock,NumData].Data))^, n1arrB[0], SectLen);
   Move((Pointer(RuleArr[NumBlock,NumRule].Data))^, n2arrB[0], SectLen);
   NOutarr[0] := N1arr[0] xor N2arr[0];
   NOutarr[1] := N1arr[1] xor N2arr[1];
   NOutarr[2] := N1arr[2] xor N2arr[2];
   Move(nOutarrB, (Pointer(OutxorArr))^, SectLen);

   PacLenSect := 0;
   BsectSet := [];
    for nBt := 0 to SectLen - 1 do begin
     if OutxorArr[nBt] in BSectSet = false then begin
      include(BSectSet, OutxorArr[nBt]);
      inc(PacLenSect, 1);
     end;
    end;

//   првоверка на условия
    if (PacLenSect <= MinLenUse) then begin
     FindResult := 1;
     break;
    end;
    if StopFind = 1 then break;
  end;
  suspend; // ждем обновления данных из формы.
end;

обработка данных в форме

Код:

 // create potok
 x := 0;
 FindTR1 := TFindTr.Create(true);
 FindTR1.Priority := tpNormal;
 FindTR1.DataArr := FDDataSect;
 FindTR1.RuleArr := OutFDDataSect;

 for n := 0 to Ndata -1 do begin
 FindTR1.NumData := n;  // задаем блок для обработки из иассива FDDataSect [x,n]
 FindTR1.Resume; // запускаем поток

  tmp1 := 0;
  while FindTR1.Suspended = false do begin // ждем окончания работы потока
    if (tmp1 mod 300) = 0 then begin
      tmp1 := 0;
      application.ProcessMessages;
    end;
   inc(tmp1, 1);
  end;

  if (FindTR1.FindResult = 1) then begin // если блок найдем в масиве OutFDDataSect 
   inc(NMinLen, 1);
   FindTR1.StatWork := 0;
  end;

// если блок ненайдем в масиве OutFDDataSect добовляем блок FDDataSect[x,n]

  if (FindTR1.FindResult = 0) and (n > 0) then begin 
   OutFDLen := length(OutFDDataSect[x]);
   Setlength(OutFDDataSect[x], OutFDlen + 1);
   OutFDDataSect[x, OutFDLen] := FDDataSect[x, n];
   inc(allFindNMinLen, 1);
   Nrule := length(OutFDDataSect[x]);
   FindTR1.FEnd := Nrule - 1;
  end;

Теперь собственно грабли.
Все Вычесления проходят в форме - результат правильный. повторяемость 100% - но ОЧЕНЬ медленно.
вычисления проходят в потоке БЕЗ ИЗМЕНЕНИЯ массива OutFDDataSect - результат правильный. повторяемость 100%
вычисления проходят в потоке С ИЗМЕНЕНИЯ массива OutFDDataSect - и тут начинаются грабли.
правильного результата нет. часто дожодит до зависания потока намертво.
при дебаге выяснилось что изменения длинны OutFDDataSect не доходят до потока.

Вобщем чтото сделал не правильно, при попытке выяснить с помощь гугля и глубокого курения RTFM где именно результата не дало.
Причем такоеже обьявление прекрасно и стабильно работает в паралелльной сортировке массива OutFDDataSect методом инжекции.

Вобще буду рад любым подсказкам, желательно с кодом.

Ужк начал посматривать в сторону стандартной библиотеки System.Threading (Parallel Programming Library (PPL)) в принципе для моей задачи подходит....