delphi - 如何使用 Omni Thread Library 的线程池控制内存使用？

Question

我一直在使用gabr's OmniThreadLibrary构建一个线程池。

对于多线程，我是个新手，这就是为什么我发现 OTL 如此有趣。

在演示应用程序“app_11_ThreadPool.exe”之后，我在应用程序中设置了一个线程池。我的应用程序的目的是获取 URL 列表，并尝试连接到它们并下载自动返回的任何文件(我正在测试潜在的恶意软件站点的有效负载，以便可以阻止它们)。

通常我会有 500 - 1000 个网站的列表。我有一个 TMemo，它在我的主表单上保存 URL。这是我的相关代码。请注意，此代码是从我的“开始”按钮单击事件执行的。

  iNumTasks := memoSiteList.Lines.Count - 1;
  GlobalOmniThreadPool.MaxQueued := 16;
  GlobalOmniThreadPool.MonitorWith(OmniEventMonitor1);
  GlobalOmniThreadPool.MaxExecuting := 16;
  GlobalOmniThreadPool.MaxQueued := 0;

    for iTask := 1 to iNumTasks + 1 do
    begin

      if iTask mod 4 = 0 then
        Application.ProcessMessages;

      CreateTask(
        TSiteQuery.Create(
        url,
        full_url,
        sProxyServer,
        sProxyPort,
        sSaveLocation,
        bVerboseHeaders)
        ).MonitorWith(OmniEventMonitor1).Schedule;
     end;

这是 TSiteQuery:

type
  TSiteQuery = class(TOmniWorker)
  strict private
    { Private declarations }
    FTaskID: int64;
    furl: string;
    f_full_url: string;
    fsProxyServer: string;
    fsProxyPort: string;
    fbVerboseHeaders: boolean;
    fsSaveLocation: string;
  private // [..]

现在，一切都很好。运行 1000 个 URL 会使应用程序的内存使用量从 10mb 增加到约 130mb。这没什么大不了的，我理解这一点。

但问题是，每次我单击“开始”时，应用程序的内存使用量都会增加约 130mb。也许我只是不知道我在做什么，但我的印象是使用线程池意味着我不必每次运行都创建新线程。

我希望池中先前创建的线程可以在后续执行中重用。我预计无论我单击“开始”1 次还是随后 10 次，我的应用程序的内存使用量都会保持在 ~130 mb 左右。

有什么建议吗？

问候

Answer 1

这是线程问题还是内存泄漏问题？尝试使用调试器的线程状态窗口来确定分配的线程数是否确实在增加。如果没有，那么您可能在线程内创建对象而不是释放它们。