task-parallel-library

6Ciepło

1Odpowiedz

Konwertuj IEnumerable <Task<T>> do IObservable <T>

Próbuję użyć rozszerzeń reaktywnych (Rx), aby buforować wyliczanie zadań po ich zakończeniu. Czy ktoś wie, czy jest to czysty wbudowany sposób robienia tego? Metoda rozszerzenia ToObservable po prostu

12Ciepło

2Odpowiedz

Tworzenie zadania z pulsem

Chcę uruchomić Task, który ma "heartbeat", który działa w określonym przedziale czasu, dopóki zadanie się nie zakończy. myślę metodę rozszerzenia jak to będzie działać dobrze: public static async Task

52Ciepło

2Odpowiedz

Wdrażanie poprawnego wykonania bloku do ponownej próby

Teaser: Chłopaki, to pytanie nie dotyczy tego, jak zaimplementować politykę ponawiania prób. Chodzi o poprawne zakończenie bloku przepływu danych TPL. To pytanie jest głównie kontynuacją mojego poprze

5Ciepło

3Odpowiedz

Task.wait i kontynuacja

Mam zadanie jak poniżej. var task = Task<string>.Factory.StartNew(() => longrunningmethod() .ContinueWith(a => longrunningmethodcompleted((Task<string>)a, TaskScheduler.FromCurren

7Ciepło

1Odpowiedz

Implementacja metody rozszerzenia WebRequest.GetResponseAsync z obsługą CancellationToken

Pomysł jest prosty, ale implementacja ma kilka interesujących niuansów. Jest to sygnatura metody rozszerzenia, którą chciałbym wdrożyć w .NET 4. public static Task<WebResponse> GetResponseAsync(this W

62Ciepło

5Odpowiedz

Co to jest metoda wymiany dla Task.Run w .NET 4.0 przy użyciu C#?

Mam program, który daje mi błąd składni "System.Threading.Tasks.task nie zawiera definicji Run". Używam VB 2010 .NET 4.0 Jakieś pomysły? jakiekolwiek zamienniki dla Run w .net 4.0? using System; usin

5Ciepło

1Odpowiedz

Jak utworzyć sekwencję Rx, uruchamiając zadania w stosunku do wartości oryginalnej sekwencji?

Mam sekwencję typu IObservable<T> i funkcję, która mapuje T, CancellationToken na Task<U>. Jaki jest najczystszy sposób na uzyskanie z nich IObservable<U>? muszę następujące semantyka: każdego zadania

13Ciepło

2Odpowiedz

Czekają na liście zadań

staram się zrobić coś takiego: foreach (var o in ObjectList) { CalculateIfNeedToMakeTaskForO(o); if (yes) TaskList.Add(OTaskAsync()); } Teraz chciałbym czekać na wszystkich tych z

13Ciepło

1Odpowiedz

UnsafeQueueUserWorkItem i co dokładnie oznacza "nie propaguje stos wywołujący"?

Czytam i uczę się o ThreadScheduler oraz artykułach dotyczących zadań i natknąłem się na funkcję ThreadPool.UnsafeQueueUserWorkItem używaną w jednym z MSDN examples na temat własnych aplikacji ThreadS

10Ciepło

2Odpowiedz

bezpieczeństwo Temat zwrotu plonu z Parallel.ForEach()

Rozważmy następujący przykładowy kod, który tworzy enumerable zbiór liczb całkowitych i przetwarza je równolegle: using System.Collections.Generic; using System.Threading.Tasks; public class Progra