关键部分会帮助解决这个问题吗？答案

【问题标题】：Will a Critical Section help solve this?关键部分会帮助解决这个问题吗？
【发布时间】：2012-10-11 04:01:16
【问题描述】：

使用 Indy 10 TCP 命令处理程序，每次收到命令时，我都会在数据库中插入一行，然后从数据库中读取整个故事以更新字符串网格。

我正在使用 AnyDac 数据库组件，他们的文档说“一个连接对象和所有与之关联的对象（如 TADQuery、TADTransaction 等）在每个时刻都必须由单个线程使用”。

如果我“缓慢”发送 TCP 命令，则没有问题。如果我“快速”发送它们（当 AnyDac 仍在显示 SQL 光标时，我会收到异常 EDatabaseError "field not found" - 但它当然存在。

当我收到 TCP 命令时，我的代码使用 PostMEssage 将 UM_ 发送到我的主窗体。

我认为正在发生的事情是，由于第一个 TCP 命令，主要形式是从表中读取所有行，而 TCP 命令处理程序在插入新行的过程中途作为第二个命令的结果 - 因此当我调用 ADQuery1.FieldByName() 时“找不到字段”。

这听起来像问题吗？

如果是这样，我该如何预防？可以使用关键部分（在哪里，主线程？）？还是有其他方法？

[更新] 我刚刚意识到 - 这不可能是线程问题（我认为）。当我收到一个 TCP 命令时，我使用 PostMessage() 将一个 UM_ 发送到我的主窗体。因此，无论 TCP 命令来得有多快，我的主窗体一次只能通过其消息队列处理一个 UM_。 TCP 命令处理程序只需一行即可发送该消息 - 没有 d/b 访问权限。

但是-我不明白的是，如果在 TCP 命令之间留出“一段时间”一切都很好，但是如果我“快速”发送它们，那么我会收到异常说在那一行中没有这样的字段桌子。

[更新] 事实上，我终于解决了这个问题，问题是使用了更新速度相当慢的 TStringGrid。有一些方法可以让它更快，但我决定将它转换为 TDbGrid，它的更新速度非常快。

【问题讨论】：

在同时访问数据库的每个线程中，您应该使用专用的 TADConnection，或者您应该序列化从多个线程对 TADConnection 和相关对象的访问。首先是更简单和推荐。更多信息：da-soft.com/anydac/docu/Multi_Threading.html
+1 但是，请查看我的更新。我不认为这可能是线程问题。我认为我这样想是错误的。
“字段未找到”可能有多种原因： 1）数据集已关闭。 2) 为没有该字段的 SELECT 打开了一个数据集，然后在另一个期望该字段存在的上下文中使用。 3) 对数据集的多线程访问杀死了内部结构。 4) 只是您的代码中的一个错误，它需要该字段，但 SELECT 不返回该字段。 5) 数据库结构被即时更改，因此表中不再存在该字段。
+1 但是......它是 100% 一致的 - 如果我“慢慢地”这样做它总是成功，但如果我“快速”地这样做它会失败（并且快速意味着可能 0.5 到 1 秒
这看起来像一个同步问题。

标签： delphi thread-safety critical-section indy10

【解决方案1】：

听起来您正在从后台线程中运行的 TCP 命令处理程序更新 AnyDac 数据库，并从主线程中读取 AnyDac 数据库。由于 AnyDac 表示他们不支持多线程访问，这会产生问题。

一种选择是尝试让所有参与的线程排队等待访问 AnyDac 数据库。这违背了使用多个线程开始的目标 - 如果您要做的只是让它们排列并按顺序执行，为什么还要使用多个线程？添加互斥锁（如临界区）会增加您创建死锁情况的机会，尤其是如果您计划在应用程序的重绘逻辑中获取该锁。您绝对不希望在重绘逻辑中锁定。

另一种方法是将数据库更新移动到主线程中。执行此操作仍涉及一些线程同步，但责任在于后台线程，而不是您的主线程。

将数据库更新移动到主线程中的一种相对简单的方法是让 TCP 命令处理程序将自定义 UM_ 消息发布到主窗口（正如您已经在做的那样）并附加数据到消息。消息处理程序从消息中提取数据，使用数据更新数据库，并处理附加到消息的数据。

使用这种方法，对 AnyDac 数据库对象的所有访问都发生在主线程中，因此不存在多线程问题。除非有人在做一些愚蠢的事情，比如在重绘周期中间调用 Application.ProcessMessages，否则这应该可以解决重绘期间发生的数据库更新问题。

【讨论】：

+1 但是，请查看我的更新。我不认为这可能是线程问题。我认为我这样想是错误的。

【解决方案2】：

如果您通过调用 PostMessage() 传递数据，则必须确保在主线程中处理消息期间数据仍然有效。最简单的方法是在您的 Handler 中执行以下操作：

创建一个新对象
将必要的数据复制到新创建的对象中
调用 PostMessage 以将新对象作为参数的消息发送到消息中

 

    procedure ...
    var MsgData: TMsgData;
    begin
      MsgData := TMsgData.Create(ACommand);
      PostMessage(MainFormHWND, WM_MYMSG, Integer(MsgData), 0);  
    end

在消息的处理程序中

处理消息
释放对象

 

    procedure MainForm.HandleMsg(var M: TMessage);
    var MsgData: TMsgData;
    begin
      MsgData := TMsgData(M.WParam);
      // Process command
      MsgData.Free();  
    end;

【讨论】：