C#实现控制并发数的多线程执行sql队列

在C#中实现多线程执行SQL队列并控制并发数量，可以采用以下步骤：

1.定义一个任务队列，使用线程安全的队列实现。

ConcurrentQueue<SqlTask> taskQueue = new ConcurrentQueue<SqlTask>();

2.创建一个或多个工作线程，从任务队列中获取任务并执行，并控制并发数量。

void WorkerThread(int maxConcurrent) {
    int count = 0;
    while (true) {
        if (count >= maxConcurrent) {
            // 如果已经达到最大并发数，则等待一段时间再继续执行
            Thread.Sleep(100);
            continue;
        }
        if (taskQueue.TryDequeue(out SqlTask task)) {
            Interlocked.Increment(ref count); // 增加当前并发数
            try {
                // 根据任务信息创建 SqlConnection 和 SqlCommand 对象，并执行 SQL 语句
                using (var connection = new SqlConnection(task.ConnectionString)) {
                    connection.Open();
                    using (var command = new SqlCommand(task.SqlCommandText, connection)) {
                        command.ExecuteNonQuery();
                    }
                }
            } finally {
                Interlocked.Decrement(ref count); // 减少当前并发数
            }
        } else {
            // 如果没有任务了，可以退出循环
            break;
        }
    }
}

3. 启动多个工作线程，开始执行任务。

int maxConcurrent = 10; // 设置最大并发数为 10
int threadCount = Environment.ProcessorCount; // 获取可用处理器核心数
Thread[] workerThreads = new Thread[threadCount];
for (int i = 0; i < threadCount; ++i) {
    workerThreads[i] = new Thread(() => WorkerThread(maxConcurrent));
    workerThreads[i].Start();
}

4.将需要执行的 SQL 任务添加到任务队列中。

taskQueue.Enqueue(new SqlTask() {
    ConnectionString = "your connection string",
    SqlCommandText = "your SQL command text"
});

5.等待任务队列中的所有任务执行完成。

foreach (var thread in workerThreads) {
    thread.Join(); // 等待线程结束
}

注意事项：

• 在执行 SQL 任务时，需要使用 using 关键字释放 SqlConnection 和 SqlCommand 对象，避免资源泄露。
• 在控制并发数量时，可以使用 Interlocked 类提供的原子操作方法增加和减少当前并发数，以保证线程安全性。
• 在实际使用时，需要根据情况设置适当的最大并发数。如果并发数过大，可能会导致数据库压力过大、锁竞争等问题；如果并发数过小，则可能不能充分利用 CPU 资源，影响系统性能。
• 在执行 SQL 任务时，需要考虑数据库的连接池和事务处理等问题，以便提高性能和保证数据一致性等方面的要求。