当前位置：首页 > news >正文

C#过 SemaphoreSlim 实现高效的数据库并发控制和资源管理(多线程)

news 来源：原创 2025/5/1 15:13:05

优点：

并发控制：通过设定 SemaphoreSlim 的计数值为 3，代码确保在任何时刻只有三个线程可以同时访问数据库。这有效地避免了因过多线程同时操作数据库而引发的性能瓶颈或死锁问题。
稳定性提升：合理的并发控制减少了数据库连接竞争的机会，降低了出现数据冲突或连接超时的风险，从而提高了系统的稳定性和可靠性。
性能优化：SemaphoreSlim 提供了轻量级的并发控制，相较于传统的锁机制，它对系统资源的占用更少，能够更好地应对高并发的场景，提高了整体性能。
资源管理：通过控制同时访问数据库的线程数，可以避免过度加载数据库服务器，从而更有效地管理数据库资源。
简化代码维护：使用 SemaphoreSlim 进行并发控制使代码逻辑更加清晰，有助于简化多线程环境下的数据库操作代码的维护和管理。

using System;
using System.Data.SqlClient;
using System.Threading;

class DatabaseAccess
{
    // 创建一个 SemaphoreSlim 实例，允许最多3个线程同时访问数据库
    private static readonly SemaphoreSlim semaphore = new SemaphoreSlim(3);

    static void Main(string[] args)
    {
        // 创建多个线程进行数据库操作
        Thread[] threads = new Thread[10];
        for (int i = 0; i < threads.Length; i++)
        {
            threads[i] = new Thread(PerformDatabaseOperation);
        }

        // 启动所有线程
        foreach (var thread in threads)
        {
            thread.Start();
        }

        // 等待所有线程完成
        foreach (var thread in threads)
        {
            thread.Join();
        }
    }

    private static void PerformDatabaseOperation()
    {
        try
        {
            // 请求信号量，确保最多只有3个线程可以同时访问数据库
            semaphore.Wait();
            
            // 执行数据库操作
            using (SqlConnection connection = new SqlConnection("连接字符串"))
            {
                connection.Open();
                SqlCommand command = new SqlCommand("UPDATE YourTable SET YourColumn = YourValue", connection);
                command.ExecuteNonQuery();
            }
        }
        catch (Exception ex)
        {
            Console.WriteLine($"数据库操作出错: {ex.Message}");
        }
        finally
        {
            // 释放信号量，使其他等待的线程能够进入
            semaphore.Release();
        }
    }
}