sql - 如何并行执行 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 线程也是一个非常坏主意(我不会详细说明原因)。

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

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

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