C# 多线程应用程序和 SQL 连接帮助

Question

我需要一些关于我编写的应用程序的建议。我遇到的问题是由于我的 DAL 和与 SQL Server 2008 数据库的连接没有关闭，但是我查看了我的代码并且每个连接总是被关闭。

该应用程序是一个多线程应用程序，它检索一组记录，并在处理记录时更新有关记录的信息。

流程如下:

管理员可以设置要运行的线程数以及每个线程要提取的记录数。

这是点击开始后运行的代码:

适配器是对我的 DAL 的抽象，这里是它们外观的示例:

public class UserDetailsAdapter: IDataAdapter<UserDetails>
{
     private IUserDetailFactory _factory;

        public UserDetailsAdapter()
        {
            _factory = new CampaignFactory();
        }

        public UserDetails FindById(int id){
             return _factory.FindById(id);
        }
}

一旦 _factory 被调用，它就会处理 SQL 并立即关闭连接。

线程应用代码:

private int _recordsPerthread;


private int _threadCount;

    public void RunDetails()
    {
        //create an adapter instance that is an abstration
        //of the data factory layer
        var adapter = new UserDetailsAdapter();

        for (var i = 1; i <= _threadCount; i++)
        {
            //This adater makes a call tot he databse to pull X amount of records and 
            //set a lock filed so the next set of records that are pulled are differnt.
            var details = adapter.FindTopDetailsInQueue(_recordsPerthread);
            if (details != null)
            {
                var parameters = new ArrayList {i, details};
                ThreadPool.QueueUserWorkItem(ThreadWorker, parameters);
            }
            else
            {
                break;
            }
        }
    }

    private void ThreadWorker(object parametersList)
    {
        var parms = (ArrayList) parametersList;
        var threadCount = (int) parms[0];
        var details = (List<UserDetails>) parms[1];
        var adapter = new DetailsAdapter();


        //we keep running until there are no records left inthe Database
        while (!_noRecordsInPool)
        {
            foreach (var detail in details)
            {
                var userAdapter = new UserAdapter();
                var domainAdapter = new DomainAdapter();

                var user = userAdapter.FindById(detail.UserId);
                var domain = domainAdapter.FindById(detail.DomainId);

                //...do some work here......

                adapter.Update(detail);
            }

            if (!_noRecordsInPool)
            {
                details = adapter.FindTopDetailsInQueue(_recordsPerthread);


                if (details == null || details.Count <= 0)
                {
                    _noRecordsInPool = true;
                    break;
                }
            }
        }
    }

应用程序崩溃是因为似乎存在数据库连接问题。查看我的 DAL 日志文件，我看到了这个:

Timeout expired. The timeout period elapsed prior to obtaining a connection from the pool. This may have occurred because all pooled connections were in use and max pool size was reached

当我在一个线程中运行它时，它工作正常。我猜当我在多个线程中运行他时，我显然与数据库建立了太多连接。关于如何让它在多线程中运行并确保数据库不会给我任何错误的任何想法。

更新:我在想我的问题可能是我的数据库出现死锁。以下是出现死锁错误时正在运行的 SQL 代码:

WITH cte AS ( 
  SELECT TOP (@topCount) *
  FROM
  dbo.UserDetails WITH (READPAST) 
WHERE
  dbo.UserDetails where IsLocked = 0)

UPDATE cte 
  SET 
  IsLocked = 1

  OUTPUT INSERTED.*;

我以前从未遇到过此代码的问题(在其他应用程序中)。我重新组织了我的索引，因为它们 99% 是零散的。那没有帮助。我在这里不知所措。

Answer 1

我对你的代码连接在哪里打开感到困惑，但你可能希望你的数据适配器实现 IDispose(确保在你离开 using 作用域时关闭池连接)并包装您在 using block 中的代码:

using (adapter = new UserDetailsAdapter())
{
    for (var i = 1; i <= _threadCount; i++)
    {
        [..]
    }
} // adapter leaves scope here; connection is implicitly marked as no longer necessary

ADO.NET 使用连接池，因此无需(而且可能适得其反)显式打开和关闭连接。