Dlaczego te zadania są uruchamiane sekwencyjnie?

Question

Dlaczego poniższy kod jest wykonywany sekwencyjnie?

List<Task> tasks = new List<Task>(); 

for (int i = 0; i <= max; i += block) 
{ 
    if (i + block >= max) 
     tasks.Add(Task.Factory.StartNew(() => Count(ref counter, block))); 
    else 
     block = max - i; 
} 

Task.WaitAll(tasks.ToArray()); 

Przetestowałem również wersję tego przy użyciu Parallel.Invoke; ono również nie działa równolegle. Musi być coś, czego nie rozumiem, ale kiedy próbuję tego używać, najczęściej otrzymuję instrukcje, jak wymusić sekwencyjne wykonanie.

W odpowiedzi na jedno z zastrzeżeniami podanymi w poniższej odpowiedzi, mam włączone następujące metody dla odniesienia:

static void Count(ref int counter, int num) 
{ 
    int localCounter = 0; 
    for (int i = 0; i < num; i++) 
     if (Coin()) localCounter++; 
    System.Threading.Interlocked.Add(ref counter, localCounter); 
} 

redakcją ponownie: Dziękuję wszystkim!

Answer 1

dlaczego poniższy kod jest wykonywany sekwencyjnie?

Nie ma, chyba że masz coś w metodzie Count synchronizującej dostęp do pojedynczego zasobu. Jeśli można go zrównoleglić, to będzie działać równolegle.

Jeśli bardzo szybko wykonasz Count, zadania zakończą się szybciej, niż zaplanowano nowe zadania, dlatego wszystkie mogą być wykonywane w kolejności.

Answer 2

Wystarczy wymienić tasks.Add(Task.Factory.StartNew(() => Count(ref counter, block))); na Console.WriteLine i zdebugować swój kod.

Nigdy nie tworzy się więcej niż jedno zadanie.

for (int i = 0; i <= max; i += block) 
{ 
    if (i + block >= max) 
     Console.WriteLine(i); 
    else 
     block = max - i; 

} 

Answer 3

Wydaje mi się, że jest coś nie tak z pętli/if:

for (int i = 0; i <= max; i += block) 
{ 
    if (i + block >= max) 
     tasks.Add(Task.Factory.StartNew(() => Count(ref counter, block))); 
    else 
     block = max - i; 
} 

Jeśli czytam to prawo, będzie dodać zadanie tylko jeśli i + block >= max i będziesz pętla tylko wtedy, gdy i + block <= max (pokazujący zarówno wzrost licznika, jak i sprawdzenie stanu). W związku z tym dodasz zadanie tylko raz.

Ponadto zmieniasz blok, gdy nie dodajesz zadania. Oczekuję, że chcesz czegoś bardziej podobnego do poniższego, ale nie mogę być pewny, że nie ma więcej kodu:

for (int i = 0; i <= max; i += block) 
{ 
    tasks.Add(Task.Factory.StartNew(() => Count(ref counter, block))); 
    if (i + block >= max) { block = max - i; } 
}