Как правильно передать динамич. массив в поток и обновить его при изменении
Собственно ситуация программа для статистики. Делается выборка из блока данных по определенным правилам.
есть тип запись обьедененная в массив обьявляю так:
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;
FindTR1.FStart := 0;
FindTR1.FEnd := Nrule - 1;
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)) в принципе для моей задачи подходит...
но поле RuleArr осталось прежним.
Это я понимаю. Специально убрал все попытки переинициализации FindTR1.RuleArr, чтобы подсказали вот здесь надо сделать так...
попытка добавить переинициализацию FindTR1.RuleArr после изменения массива результата не дала.
......
setlength(FindTR1.RuleArr, 0);
FindTR1.RuleArr := OutFDDataSect;
пока блок OutFDDataSect[x] находится в одном сегменте памяти - работает. как только сегмент сменился - грабли....
Вот и спрашиваю - Как ПРАВИЛЬНО провести переинициализацию дин. массива.
Писал софт в основном для АСУтп - а в нем не точто за указатели. за динамические массивы с работы вылететь можно.
