Доброго Всем.
Собственно ситуация программа для статистики. Делается выборка из блока данных по определенным правилам.
есть тип запись обьедененная в массив обьявляю так:
Код:
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)) в принципе для моей задачи подходит....