Parallel.ForEach z dodawaniem do listy

Próbuję uruchomić wiele funkcji, które łączą się ze zdalną lokalizacją (przez sieć) i zwracają listę ogólną. Ale chcę je uruchamiać jednocześnie.

Na przykład:

public static List<SearchResult> Search(string title)
{
    //Initialize a new temp list to hold all search results
    List<SearchResult> results = new List<SearchResult>();

    //Loop all providers simultaneously
    Parallel.ForEach(Providers, currentProvider =>
    {
        List<SearchResult> tmpResults = currentProvider.SearchTitle((title));

        //Add results from current provider
        results.AddRange(tmpResults);
    });

    //Return all combined results
    return results;
}

Jak widzę, wiele wstawień do „wyników” może mieć miejsce w tym samym czasie ... co może spowodować awarię mojej aplikacji.

Jak mogę tego uniknąć?

//In the class scope:
Object lockMe = new Object();    

//In the function
lock (lockMe)
{    
     results.AddRange(tmpResults);
}

Zasadniczo blokada oznacza, że ​​tylko jeden wątek może mieć dostęp do tej krytycznej sekcji w tym samym czasie.

Możesz użyć kolekcji współbieżnej .

Przestrzeń System.Collections.Concurrentnazw udostępnia kilka klas kolekcji bezpiecznych dla wątków, które powinny być używane zamiast odpowiednich typów w przestrzeniach nazw System.Collections i, System.Collections.Genericgdy wiele wątków jednocześnie uzyskuje dostęp do kolekcji.

Możesz na przykład użyć, ConcurrentBagponieważ nie masz gwarancji, w jakiej kolejności pozycje zostaną dodane.

Reprezentuje bezpieczną wątkowo, nieuporządkowaną kolekcję obiektów.

Dla tych, którzy wolą kod:

public static ConcurrentBag<SearchResult> Search(string title)
{
    var results = new ConcurrentBag<SearchResult>();
    Parallel.ForEach(Providers, currentProvider =>
    {
        results.Add(currentProvider.SearchTitle((title)));
    });

    return results;
}

Kolekcje współbieżne są nowością w .Net 4; są zaprojektowane do pracy z nową funkcją równoległą.

Zobacz kolekcje współbieżne w .NET Framework 4 :

Przed .NET 4 trzeba było zapewnić własne mechanizmy synchronizacji, jeśli wiele wątków mogło uzyskiwać dostęp do jednej udostępnionej kolekcji. Trzeba było zablokować kolekcję ...

... [...] [nowe] klasy i interfejsy w System.Collections.Concurrent [dodane w .NET 4] zapewniają spójną implementację dla [...] wielowątkowych problemów programistycznych obejmujących współdzielone dane między wątkami.

Można to zwięźle wyrazić za pomocą PLINQ AsParalleli SelectMany:

public static List<SearchResult> Search(string title)
{
    return Providers.AsParallel()
                    .SelectMany(p => p.SearchTitle(title))
                    .ToList();
}