.NET 多线程同步时钟与监视器

Question

我正在为一个多线程服务构建一个稍微更高效的连接池，我正在写信来在我的服务与其 SQL 数据库之间进行对话。基本上归结为，我在我的类中得到了这段代码：

Public Class DBMC
Private Connections As New ArrayList

  Private Function GetConnection() As Object
    Dim conCounter As Integer = 0

    While True
        If Connections.Count > conCounter Then
            If System.Threading.Monitor.TryEnter(Connections(conCounter), 10) Then
                Return Connections(conCounter)
            Else
                conCounter += 1
            End If

        ElseIf conCounter > 98 Then
            'keep looping until an open connection is found
            conCounter = 0

        ElseIf conCounter < 98 Then
            Dim connection As Object = NewCon()

            If connection Is Nothing Then
                conCounter = 0
            Else
                Connections.Add(connection)

                Return connection
            End If
        End If
    End While
    'below line should never run
    Return Nothing
  End Function

  Public Function DBSelect(ByVal SQL As String) As DataSet
    Dim connection As Object = GetConnection()

    SyncLock (connection)
        'Run the select vs database and do a bunch of other stuff
    End SyncLock

    Try
        System.Threading.Monitor.Exit(connection)
    Catch ex As Exception
    End Try

    Return DataSet
  End Function
End Class

所以这段代码工作得非常好，我可以在不同的线程中运行 500 个 select 语句，就像计算机可以运行它们一样快，并且它将打开 8 个不同的连接（可能是由于我的计算机的速度，较慢的计算机可能会打开更多）。问题是，在 DBSelect 函数中，我有一行用 Try/Catch 包围来释放监视器 Enter，因为有时结束同步锁会释放对象上的锁（在这种情况下，不需要该行并引发异常），有时该对象仍然被锁定，并且将保持永久锁定而不运行该行（在这种情况下，它使用它并成功通过）。我一生都无法弄清楚为什么有时它会释放它，有时却不会。有什么想法吗？

Answer 1

您收到异常的原因是，当您没有可用连接时，您创建一个新连接并返回它，而不对其调用 Monitor.Enter() 。这意味着您将对该对象引用采用非递归 SyncLock，释放该锁，然后尝试对您从未采用过的附加锁调用 Monitor.Exit()。

在向池中添加连接的方式上还存在潜在的竞争条件。在您自己将其设置为 SyncLock 块之前，另一个线程很可能会锁定您刚刚创建的连接（通过 Monitor.TryEnter() 调用）。如果您在将连接返回到池之前关闭连接（这是一个好主意），那么当您的创建线程实际开始使用它时，您将拥有一个处于不良状态的连接。

我实际上建议您不要尝试编写自己的连接池。您当前的代码中没有任何内容表明您不能只使用 System.Data.SqlClient.SqlConnection，它已经为您处理连接池。