La façon la plus simple d'exécuter trois méthodes en parallèle en C#

Question

J'ai trois méthodes que j'appelle pour faire des calculs, à savoir

results.LeftFront.CalcAi();  
results.RightFront.CalcAi();  
results.RearSuspension.CalcAi(geom, vehDef.Geometry.LTa.TaStiffness, vehDef.Geometry.RTa.TaStiffness);

Chacune des fonctions est indépendante des autres et peut être calculée en parallèle sans blocage.
Quel est le moyen le plus simple de les calculer en parallèle sans que la méthode de contention ne se termine avant que les trois ne soient terminées ?

Answer 1

Voir le Documentation sur le TPL . Ils listent cet échantillon :

Parallel.Invoke(() => DoSomeWork(), () => DoSomeOtherWork());

Dans votre cas, cela devrait donc fonctionner :

Parallel.Invoke(
    () => results.LeftFront.CalcAi(),
    () => results.RightFront.CalcAi(),
    () => results.RearSuspension.CalcAi(geom, 
                                        vehDef.Geometry.LTa.TaStiffness, 
                                        vehDef.Geometry.RTa.TaStiffness));

EDITAR: L'appel revient après que toutes les actions ont fini de s'exécuter. Invoke() ne garantit pas qu'elles seront effectivement exécutées en parallèle, ni l'ordre d'exécution des actions.

Answer 2

Vous pouvez également le faire avec les tâches (plus agréable si vous avez besoin ultérieurement d'une annulation ou d'un résultat similaire).

var task1 = Task.Factory.StartNew(() => results.LeftFront.CalcAi());
var task2 = Task.Factory.StartNew(() => results.RightFront.CalcAi());
var task3 = Task.Factory.StartNew(() =>results.RearSuspension.CalcAi(geom, 
                              vehDef.Geometry.LTa.TaStiffness, 
                              vehDef.Geometry.RTa.TaStiffness));

Task.WaitAll(task1, task2, task3);

Answer 3

Dans .NET 4, Microsoft a introduit la bibliothèque parallèle de tâches qui a été conçue pour gérer ce type de problème, voir Programmation parallèle dans le cadre de .NET .

Answer 4

Pour exécuter des méthodes parallèles indépendantes les unes des autres, on peut également utiliser ThreadPool.QueueUserWorkItem. Voici l'exemple de méthode

public static void ExecuteParallel(params Action[] tasks)
{
    // Initialize the reset events to keep track of completed threads
    ManualResetEvent[] resetEvents = new ManualResetEvent[tasks.Length];

    // Launch each method in it's own thread
    for (int i = 0; i < tasks.Length; i++)
    {
        resetEvents[i] = new ManualResetEvent(false);
        ThreadPool.QueueUserWorkItem(new WaitCallback((object index) =>
            {
                int taskIndex = (int)index;

                // Execute the method
                tasks[taskIndex]();

                // Tell the calling thread that we're done
                resetEvents[taskIndex].Set();
            }), i);
    }

    // Wait for all threads to execute
    WaitHandle.WaitAll(resetEvents);
}

Vous trouverez plus de détails sur cette fonction ici :
http://newapputil.blogspot.in/2016/03/running-parallel-tasks-using.html

Answer 5

var task1 = SomeLongRunningTask();
var task2 = SomeOtherLongRunningTask();

await Task.WhenAll(task1, task2);

L'avantage de cette méthode par rapport à Task.WaitAll est qu'elle libère le fil et attend l'achèvement des deux tâches.