如何并行执行 SQL 过程中的子任务

Question

我有一个流程可以分析一个系统的审计数据，为另一个系统构建报告数据。有一个管理过程，它循环分析每一天，并使用当前迭代的日期调用特定于实体的过程。有些实体的处理时间不到一秒，而其他实体则可能需要几分钟。像在 t-sql 中那样连续运行，CPU 利用率在 16 核服务器上永远不会超过 8%。每个实体特定过程都不依赖于其他过程，只是当天的所有实体在第二天开始之前完成。

我的想法是有一个 CLR 管理过程，并启动当天运行时间较长的过程在自己的线程上运行，然后一旦快速过程完成，Thread.Join() 长时间运行的线程等待所有实体完成该过程继续下一天之前。

下面是我的尝试，作为仅适用于一个工作线程的最简单的事情，并且在该线程上调用 Start 不会导致调用静态方法。我在 HelloWorld 方法中设置了一个断点，但它从未被击中。

我在控制台应用程序中尝试了非常类似的方法，并且它的工作方式与在 AsyncHelloWorld 开头的注释行中的同一线程上调用它一样。 SQL CLR 过程中的线程处理有什么不同吗？

using System.Threading;
using Microsoft.SqlServer.Server;

public partial class StoredProcedures
{
    [SqlProcedure]
    public static void AsyncHelloWorld()
    {
        // HelloWorld(SqlContext.Pipe);

        var worker = new Thread(HelloWorld);
        worker.Start(SqlContext.Pipe);
        worker.Join();
    }

    public static void HelloWorld(object o)
    {
        var pipe = o as SqlPipe;

        if (pipe != null)
            pipe.Send("Hello World!");
    }
}

Answer 1

你绝对不能这么做。 SqlPipe 与您调用的线程的上下文紧密相关。虽然从技术上讲，您可以从 SQLCRL 启动线程，但这些线程必须从原始线程与调用者进行所有交互。但即便如此，在 SQL 托管环境中启动 CLR 线程也是一个非常坏主意（我不会详细说明原因）。

相反，将逻辑分离为可以并行调用的过程，并从客户端并行调用这些过程。您可以使用异步过程执行作为调度过程的模式以异步方式启动，并且基于队列的激活通过 MAX_QUEUE_READERS 设置内置了对并行性的支持。

但很可能您的程序不需要显式并行性。可以从显式用户控制的并行性中受益的 T-SQL 负载非常罕见，根本不值得一提（更不用说在并行任务中正确提取事务语义超出了凡人的能力）。 T-SQL 可以利用内部语句并行性来并行处理数据，因此不需要显式并行性。

因此，您最好解释一下您真正想要解决的问题是什么，也许我们可以提供帮助。