Попытался сделать на WaitForMultipleObjects:
Конструктор Create
1.
2.
3.
4.
5.
6.
constructor CThread.Create(Bool: boolean);
begin
inherited Create(Bool);
. . .
TerminateEvent := CreateEvent(nil, True, False, 'TerminateEvent');
end;
Деструктор Destroy
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
destructor CThread.Destroy;
begin
try
{ if Suspended then begin
TerminateThread(Self.Handle, 0);
end;}
SetEvent(TerminateEvent);
except
on E : Exception do
SendEventBox(ETA_ERROR_METR+usedColor, 'Ошибка в : CThread.Destroy: '+E.Message);
end;
FreeAndNil(SenderClass);
inherited;
end;
Функция FGETMULT
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.
function FGETMULT(nIndex:Integer; pb_lInBox:Pointer; AE: ArrayEvents):Integer;
Var wLng:Word;
Begin
try
case WaitForMultipleObjects(2, @AE, False, 1) of
WAIT_OBJECT_0:
begin
Move(pHiBuff[nIndex].pb_mBoxCont[pHiBuff[nIndex].w_mBoxRead],wLng,2);
Move(pHiBuff[nIndex].pb_mBoxCont[pHiBuff[nIndex].w_mBoxRead],pb_lInBox^,wLng);
pHiBuff[nIndex].w_mBoxRead := pHiBuff[nIndex].w_mBoxRead + wLng;
pHiBuff[nIndex].w_mBoxSize := pHiBuff[nIndex].w_mBoxSize + wLng;
pHiBuff[nIndex].w_mBoxMesCt := pHiBuff[nIndex].w_mBoxMesCt - 1;
if(pHiBuff[nIndex].w_mBoxRead > pHiBuff[nIndex].w_mBoxCSize) then pHiBuff[nIndex].w_mBoxRead := 0;
if pHiBuff[nIndex].w_mBoxMesCt=0 then ResetEvent(AE[0]) // ResetEvent(pHiBuff[nIndex].w_mEvent)
else SetEvent(pHiBuff[nIndex].w_mEvent);
result := wLng;
end;
WAIT_OBJECT_0 + 1:
begin
ResetEvent(AE[1]);
Exit;
end;
end;
except
SClass.ToStringBox(ET_CRITICAL, 'Ошибка в utlbox.FGETMULT ');
end;
End;
Описание массива в Type
1.
ArrayEvents = array[0..1] of THandle;
и в классе
1.
2.
FEvents : ArrayEvents;
TerminateEvent : THandle;
Ну и собственно, сам вызов в Execute
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
procedure CL4Module.Execute;
Begin
FDEFINE(BOX_L4,BOX_L4_SZ,True);
while not Terminated do Begin
FEvents[0] := pHiBuff[BOX_L4].w_mEvent;
FEvents[1] := TerminateEvent;
FGETMULT(BOX_L4, @m_nMsg, FEvents);
if Terminated then Exit;
if m_nL4Synchronize = 1 then Synchronize(OnHandler)
. . .
и при закрытии программы
1.
2.
3.
pL4Module.Terminate;
if pL4Module <> nil then FreeAndNil(pL4Module);
. . .
В результате:
1. Намного дольше стала запускаться программа (раза в 2-3)
2. При закрытии программы долго скачет по WaitFor, в конце-концов выдает:
28.08.2021 14:19:59 : EThread: Thread Error: Неверный дескриптор (6)
(0002CD80){knsmodule.exe} [0042DD80] utlbox.TThread.CheckThreadError (Line 9453, "utlbox" + 2) + $37
(0002CDC4){knsmodule.exe} [0042DDC4] utlbox.TThread.CheckThreadError (Line 9459, "utlbox" + 2) + $A
(0002D0C5){knsmodule.exe} [0042E0C5] utlbox.TThread.WaitFor (Line 9722, "utlbox" + 17) + $16
(0002CCBB){knsmodule.exe} [0042DCBB] utlbox.TThread.Destroy (Line 9428, "utlbox" + 6) + $3
(0096945D){knsmodule.exe} [00D6A45D] utlbox.CThread.Destroy (Line 77, "utlThread.pas" + 14) + $9
(0090D872){knsmodule.exe} [00D0E872] utlbox.CL4Module.Destroy (Line 83, "knsl4module.pas" + 13) + $9
(0000341C){knsmodule.exe} [0040441C] utlbox.m_nSpeedList + $0
. . .
Где я мог опять накосячить%(
