exception très unique pour BlockingCollection sur .net 4.0

Question

J'utilise le BlockingCollection pour un modèle de Producteur Consommateur et j'ai eu une excecption je pense à écrire un brevet dessus-seulement deux résultats dans google! le expection est « CompleteAdding ne peut pas être utilisé en même temps avec des ajouts à la collection » et il arrive quand je TryAdd sur e BlockingCollection comme suit:

public void EnqueueTask(T item) 
    { 
     if (!_cancellationTokenSource.IsCancellationRequested) 
     { 
      _workerQueue.Add(item); 
     } 
    } 

la CompleteAdding est appelée sur la Éliminez de la classe emballage consommateur-producteur :

public void Dispose() 
    { 
     if (!_IsActive) 
      return; 
     _IsActive = false; 
     _cancellationTokenSource.Cancel(); 
     _workerQueue.CompleteAdding(); 
     // Wait for the consumer's thread to finish. 
     for (int i = 0; i < _workers.Length; ++i) 
     { 
      Task t1 = Task.Factory.StartNew(() => 
      { 
       try 
       { 
        if (!_workers[i].Join(4000)) 
         LogWriter.Trace("Failed to join thread", "ThreadFailureOnDispose"); 
       } 
       catch (Exception ex) 
       { 
        OnLogged(ex.Message + ex.StackTrace); 
       } 
      }); 

     } 


     // Release any OS resources. 
    } 

Quelqu'un de Microsoft a une idée? devrais-je dormir après l'annulation et avant d'appeler le CompleteAdding?

Answer 1

Regardez ce morceau de code:

for (int i = 0; i < _workers.Length; ++i) 
    { 
     Task t1 = Task.Factory.StartNew(() => 
     { 
      try 
      { 
       if (!_workers[i].Join(4000)) << == Here 
        LogWriter.Trace("Failed to join thread", "ThreadFailureOnDispose"); 
      } 

En _workers[i].Join(4000), la valeur de i n'est pas ce que vous pensez qu'il est. Essayez à nouveau avec:

for (int i = 0; i < _workers.Length; ++i) 
    { 
     int j = i; // copy 
     Task t1 = Task.Factory.StartNew(() => 
     { 
      try 
      { 
       if (!_workers[j].Join(4000)) // j 
        LogWriter.Trace("Failed to join thread", "ThreadFailureOnDispose"); 
      } 

Dans votre version, la variable 'i' est capturée et toutes les tâches utilisent la même var. Tous sauf les premiers verront i == _workers.Length car ils sont exécutés une fois la boucle for terminée.

Il s'agit d'un problème de var capturé lambda + classique.