Pytania otagowane jako parallel-processing

Przetwarzanie równoległe, w przeciwieństwie do samego przetwarzania współbieżnego, gwarantuje rozpoczęcie / wykonanie / zakończenie wszystkich zadań na poziomie wątku i / lub instrukcji wykonywanych równolegle i zapewnia gwarantowane zakończenie jednocześnie wykonywanych ścieżek kodu.

13
Jak wyartykułować różnicę między programowaniem asynchronicznym a równoległym?
Wiele platform promuje asynchroniczność i równoległość jako sposób na poprawę responsywności. Ogólnie rozumiem różnicę, ale często trudno mi to wyrazić we własnym umyśle, jak również w przypadku innych. Jestem programistą na co dzień i dość często używam asynchronii i wywołań zwrotnych. Równoległość wydaje się egzotyczna. Ale wydaje mi się, że …
5
Dlaczego powinienem preferować jedno zadanie „await Task.WhenAll” zamiast wielu oczekujących?
W przypadku, gdy nie zależy mi na kolejności wykonywania zadań i po prostu potrzebuję ich wszystkich, czy nadal powinienem używać await Task.WhenAllzamiast wielu await? np. jest DoWork2poniżej preferowanej metody DoWork1(i dlaczego?): using System; using System.Threading.Tasks; namespace ConsoleApp { class Program { static async Task<string> DoTaskAsync(string name, int timeout) { var …
8
Czy program PowerShell może uruchamiać polecenia równolegle?
Mam skrypt PowerShell do przetwarzania wsadowego na kilku obrazach i chciałbym przeprowadzić równoległe przetwarzanie. Wydaje się, że Powershell ma pewne opcje przetwarzania w tle, takie jak start-job, wait-job itp., Ale jedynym dobrym źródłem, które znalazłem do wykonywania równoległej pracy, było napisanie tekstu skryptu i uruchomienie go ( wielowątkowość PowerShell ) …
1
Przepełnienie sterty wątków Haskell pomimo tylko 22Mb całkowitego zużycia pamięci?
Próbuję zrównoleglenie ray-tracera. Oznacza to, że mam bardzo długą listę małych obliczeń. Program podstawowy działa na określonej scenie w 67,98 sekund i 13 MB całkowitego wykorzystania pamięci oraz 99,2% wydajności. W mojej pierwszej próbie użyłem strategii równoległej parBufferz rozmiarem bufora 50. Wybrałem, parBufferponieważ przegląda listę tylko tak szybko, jak zużywane …
5
Przerwij równolegle. Przed?
Jak wyjść z pętli parallel.for ? Mam dość złożone oświadczenie, które wygląda następująco: Parallel.ForEach<ColorIndexHolder>(ColorIndex.AsEnumerable(), new Action<ColorIndexHolder>((ColorIndexHolder Element) => { if (Element.StartIndex <= I && Element.StartIndex + Element.Length >= I) { Found = true; break; } })); Korzystając z klasy równoległej, mogę zdecydowanie zoptymalizować ten proces. Jednak; Nie mogę dowiedzieć się, …
7
Ile kosztuje blokada?
Eksperymentowałem z wielowątkowością i przetwarzaniem równoległym i potrzebowałem licznika, aby wykonać podstawowe zliczanie i analizę statystyczną szybkości przetwarzania. Aby uniknąć problemów z jednoczesnym używaniem mojej klasy, użyłem instrukcji lock na zmiennej prywatnej w mojej klasie: private object mutex = new object(); public void Count(int amount) { lock(mutex) { done += …
4
Jak działa algorytm sortowania MapReduce?
Jednym z głównych przykładów wykorzystywanych do zademonstrowania możliwości MapReduce jest test porównawczy Terasort . Mam problem ze zrozumieniem podstaw algorytmu sortowania używanego w środowisku MapReduce. Dla mnie sortowanie polega po prostu na określeniu względnego położenia elementu w stosunku do wszystkich innych elementów. Tak więc sortowanie polega na porównywaniu „wszystkiego” ze …
5
decydujesz się na podproces, wieloprocesowość i wątek w Pythonie?
Chciałbym zsynchronizować mój program w Pythonie, aby mógł korzystać z wielu procesorów na maszynie, na której działa. Moja równoległość jest bardzo prosta, ponieważ wszystkie równoległe „wątki” programu są niezależne i zapisują swoje dane wyjściowe w oddzielnych plikach. Nie potrzebuję wątków do wymiany informacji, ale konieczne jest, aby wiedzieć, kiedy wątki …
13
Jak czekać na ukończenie kilku wątków?
Jak można po prostu zaczekać na zakończenie całego procesu gwintowanego? Na przykład, powiedzmy, że mam: public class DoSomethingInAThread implements Runnable{ public static void main(String[] args) { for (int n=0; n<1000; n++) { Thread t = new Thread(new DoSomethingInAThread()); t.start(); } // wait for all threads' run() methods to complete before …
2
SLURM `srun` vs` sbatch` i ich parametry
Próbuję zrozumieć, jaka jest różnica między poleceniami SLURM sruna sbatchpoleceniami. Będę zadowolony z ogólnego wyjaśnienia, a nie konkretnych odpowiedzi na poniższe pytania, ale oto kilka konkretnych punktów nieporozumień, które mogą być punktem wyjścia i dać wyobrażenie o tym, czego szukam. Zgodnie z dokumentacją , srunjest dla zadań składających, a sbatchto …
2
Udostępnianie kolejki wyników kilku procesom
Dokumentacja multiprocessingmodułu pokazuje, jak przekazać kolejkę do procesu uruchomionego multiprocessing.Process. Ale jak mogę współużytkować kolejkę z asynchronicznymi procesami roboczymi, od których rozpoczęto apply_async? Nie potrzebuję dynamicznego łączenia ani niczego innego, tylko sposób, aby pracownicy (wielokrotnie) zgłaszali swoje wyniki z powrotem do bazy. import multiprocessing def worker(name, que): que.put("%d is done" …
2
Parallel mapM na tablicach Repa
W mojej ostatniej pracy z Gibbs samplingwielkim wykorzystaniem RVar, moim zdaniem, zapewnia prawie idealny interfejs do generowania liczb losowych. Niestety, nie mogłem skorzystać z Repa ze względu na brak możliwości korzystania z monadycznych działań na mapach. Chociaż wyraźnie mapy monadyczne nie mogą być generalnie zrównoleglane, wydaje mi się, że RVarmoże …
Korzystając z naszej strony potwierdzasz, że przeczytałeś(-aś) i rozumiesz nasze zasady używania plików cookie i zasady ochrony prywatności.
Licensed under cc by-sa 3.0 with attribution required.