我有一个 TThread 的后代和一个对象列表,每个对象都有自己的此类线程的副本以及使用 CreateEvent() API 创建的 Event 对象。
不同的对象通过事件触发相互交互。即每个线程必须等到某个其他线程将触发它的事件。当然,有一个“主”线程,它永久工作,因此永远不会发生自阻塞。该系统在每个对象中的 Execute 方法结束之前都可以正常工作。
当我试图中断所有线程时出现问题,例如通过应用程序关闭。在这种情况下,我需要一些调用每个线程的 Terminate 方法的外部函数:
for i := 0 to FLayers.Count - 1 do
begin
FLayers.Layer[i].FTerminating := true;
f := true;
while f do
begin
f := FLayers.Layer[i].IsActive;
if f then
begin
Sleep(100);
Application.ProcessMessages;
end;
end;
FLayers.Layer[i].FTerminating := false;
end;
此函数位于 Form.OnClose() 事件中。
问题是大约两个线程正常终止,但其他所有线程都在 WaitForSingleObject() 调用中停止:
procedure TLayerThread.Execute;
begin
FLayer.FIsActive := true;
...............
repeat
//
if Terminated or
FLayer.FTerminating or
(FLayer.FEvent = INVALID_HANDLE_VALUE) then
begin
break;
end;
//
Fres := WaitForSingleObject(FLayer.FEvent, 100); <<<<<<<<<<<<<<<<<<<<<<<<
until Fres <> WAIT_TIMEOUT;
...........
FLayer.FIsActive := false;
end;
所有线程都在该行停止(挂起)。上面标记,尽管设置了超时值。
有任何想法吗?
我正在使用 Delphi 7 和 Win XP。
提前致谢。
跟进 -
我发现问题已在 Execute() 方法中的 Synchronize() 调用中得到解决。我不明白这里有什么问题。Synchronize() 调用通常的东西,比如视觉控件更新,仅此而已。
正如调试器所示,我的线程中没有一个挂在某个 WaitForSingleObject() 调用上,但这不是我在 Execute() 方法中用来协调不同线程的方法,而是另一个调用。我可以假设它在这里:
class procedure TThread.Synchronize(ASyncRec: PSynchronizeRecord);
.................
LeaveCriticalSection(ThreadLock);
try
WaitForSingleObject(SyncProc.Signal, INFINITE);<<<<<<<<<<<<<<<<<<<<<<
finally
EnterCriticalSection(ThreadLock);
end;
..................
有没有人可以告诉我我的代码有什么问题?我从来没有听说过不允许从 Execute() 方法中调用 Synchronize() ......