TParallel.For循环非常简单:
TParallel.For(0,inImage.Height -1,Procedure(ty : integer) begin SomeProcedure(ty); end);
如果我创建一个具有完全相同的代码的Delphi应用程序,一切都可以正常工作.
经过大量的研究和调试,看起来似乎有一个死锁,这是在调用FreeLibrary时阻止C应用程序退出,但是我找不到TParallel中的问题.
总结情况:
> TParallel.For循环全部完成并产生正确的结果.
>完全相同的TParallel.For在Delphi .exe中的代码工作正常.
> DLL被加载并且这些函数被调用并且在C应用程序内正确执行.
>如果没有TParallel.For循环,C应用程序将正确退出.
>如果有TParallel.For循环,C应用程序将挂起.
>我猜测当FreeLibrary被调用时会发生死锁.
>如果我使用OTL线程库,一切都可以正常工作.
我的问题是:
有没有人经历过这种行为?
在这种情况下,找到一个僵局是什么好的调试策略?
任何建议非常感谢.
UPDATE
好的,所以如果你想要最小,完整和可验证的例子,这里你去(谢谢斯蒂芬·鲍尔):
library ADelphiDLL; uses System.SysUtils,System.Classes,Threading,SyncObjs; function IsPrime (N: Integer): Boolean; var Test: Integer; begin IsPrime := True; for Test := 2 to N - 1 do if (N mod Test) = 0 then begin IsPrime := False; break; {jump out of the for loop} end; end; function Prime(Max : integer) : boolean; var tot : integer; begin tot := 0; TParallel.For(1,Max,procedure (I: Integer) begin if IsPrime (I) then TInterlocked.Increment (Tot); end); return true; end; exports Prime; begin IsMultiThread := True; end.
在C:
#include "stdafx.h" typedef bool(__stdcall *primesf)(int); void main() { HINSTANCE hGetDLL = LoadLibrary(L"ADelphiDLL.dll"); primesf primes = (primesf)GetProcAddress(hGetProcIDDLL,"Primes"); bool result = primes(100); FreeLibrary(hGetDLL);// <-- Hangs here forever }
为了回应“有帮助”的意见,“代码中有缺陷”和“自己调试”,谢谢,这是我一直在做的一段时间.所以,如果这里没有任何帮助,我将尝试获得许可,以切换到OTL,这在所讨论的DLL中起作用.
更新2
OTL与预期完全一致.所以,是的,有一个“代码缺陷”.我放弃.我会建议完全放弃Delphi,然后我们可以将所有内容移到C和C#上.这必须是一个更好的短期(和长期)解决方案.
解决方法
无论如何,我想出的解决方案如下:
>在您的Delphi DLL中,首先创建自己的线程池.
>使用重载版本的TParallel.For它将一个线程池对象作为其最后一个参数,并提供您自己的线程池对象.
在卸载Delphi DLL之前,确保释放你的线程池对象.
TParallel.For文档:
http://docwiki.embarcadero.com/Libraries/Berlin/en/System.Threading.TParallel.For
示例伪代码:
MyPool: TThreadPool; MyPool := TThreadPool.Create; TParallel.For(1,procedure (I: Integer) begin if IsPrime (I) then TInterlocked.Increment (Tot); end,MyPool ); MyPool.Free;