Sqlserver
 sql >> Datenbank >  >> RDS >> Sqlserver

Threading und SqlFileStream. Der Prozess kann nicht auf die angegebene Datei zugreifen, da sie in einer anderen Transaktion geöffnet wurde

Die Transaktion fließt nicht in Parallel.ForEach ein , müssen Sie die Transaktion manuell eingeben.

//Switched to a thread safe collection.
var documents = new ConcurrentQueue<ExtractedContent>();
using (var ts = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled))
{
    var attachments = await dao.GetAttachmentsAsync();
    //Grab a reference to the current transaction.
    var transaction = Transaction.Current;
    Parallel.ForEach(attachments, a =>
    {
        //Spawn a dependant clone of the transaction
        using (var depTs = transaction.DependentClone(DependentCloneOption.RollbackIfNotComplete))
        {
            documents.Enqueue(a.ToDbDocument());
            depTs.Complete();
        }
    });

    ts.Complete();
}

Ich habe auch von List<ExtractedContent> gewechselt zu ConcurrentQueue<ExtractedContent> da Sie .Add( nicht aufrufen dürfen auf einer Liste aus mehreren Threads gleichzeitig.