关于逻辑/算法的想法以及如何防止对SqlServer的线程写入中的竞争

我有以下逻辑：

public void InQueueTable(DataTable Table) { int incomingRows = Table.Rows.Count; if (incomingRows >= RowsThreshold) { // asyncWriteRows(Table) return; } if ((RowsInMemory + incomingRows) >= RowsThreshold) { // copy and clear internal table // asyncWriteRows(copyTable) } internalTable.Merge(Table); } 

这个算法有一个问题：

但是如果??? 假设第二个线程旋转并调用asyncWriteRows（xxxTable）; 另外，拥有异步方法的每个线程都将写入SqlServer中的同一个表： SqlServer是否将这种multithreading写入function处理到同一个表中？

跟进
根据Greg D的建议：

 using (SqlBulkCopy bulkCopy = new SqlBulkCopy(connectionString, sqlBulkCopyOptions.KeepIdentity | SqlBulkCopyOptions.UseInternalTransaction)) { // perform bulkcopy } 

无论如何，我仍然有发信号通知asyncWriteRows（copyTable）的问题。 该算法需要确定是否需要继续复制internalTable，clear internalTable和asyncWriteRows（copyTable）。 我认为我需要做的是将internalTable.Copy()调用移动到它自己的方法：

 private DataTable CopyTable (DataTable srcTable) { lock (key) { return srcTable.Copy(); } } 

…然后对InQueue方法进行以下更改：

 public void InQueueTable(DataTable Table) { int incomingRows = Table.Rows.Count; if (incomingRows >= RowsThreshold) { // asyncWriteRows(Table) return; } if ((RowsInMemory + incomingRows) >= RowsThreshold) { // copy and clear internal table // asyncWriteRows(CopyTable(Table)) } internalTable.Merge(Table); } 

…最后，添加一个回调方法：

 private void WriteCallback(Object iaSyncResult) { int rowCount = (int)iaSyncResult.AsyncState; if (RowsInMemory >= rowCount) { asyncWriteRows(CopyTable(internalTable)); } } 

这就是我所确定的解决方案。 任何反馈？