multiprocessing

6Ciepło

1Odpowiedz

Dlaczego proces demona multipleksowania w języku Python nie drukuje na standardowe wyjście?

Eksperymentowałem z procesami wieloprocesowymi i uruchamiałem blokadę umysłu z demonami. Mam jeden demon i jeden proces inny niż demon, demon wysyłający dane wyjściowe co jedną sekundę w nieskończonoś

6Ciepło

2Odpowiedz

Jak zmienić liczbę równoległych procesów?

Mam skrypt Pythona, który uruchamia metodę równolegle. parsers = { 'parser1': parser1.process, 'parser2': parser2.process } def process((key, value)): parsers[key](value) pool = Po

7Ciepło

1Odpowiedz

Porównaj i zamień w C++

Więc używamy wersji boost, która jest całkiem stara, a do aktualizacji potrzebuję do atomowej operacji CAS w C++ dla mojego kodu. (Nie jesteśmy jeszcze przy użyciu C++ 0x albo) I stworzył następującą

5Ciepło

1Odpowiedz

Jak zabić zadanie wieloprocesorowe w języku Python?

W odniesieniu do this question zapytałem, mogę z powodzeniem uruchomić zadania za pomocą przetwarzania wieloprocesorowego i widzę, że wszystkie procesory są wykorzystywane. Jak mogę zabić tę pracę? Od

26Ciepło

2Odpowiedz

Równoczesne żądania z MRI Ruby

Połączyłem prosty przykład próbujący udowodnić współbieżne żądania w Railsach przy użyciu podstawowego przykładu. Zauważ, że używam MRI Ruby2 i Rails 4.2. def api_call sleep(10) render :json

5Ciepło

1Odpowiedz

Udostępnianie wielu kolejek między procesami w Pythonie

Jestem świadomy multiprocessing.Manager() i jak można go używać do tworzenia wspólnych obiektów, w szczególności kolejek, które mogą być wymieniane między pracownikami. Istnieje this question, this qu

6Ciepło

2Odpowiedz

Jak zmienić serializer, który moja podklasa multiprocessing.mangers.BaseManager używa do cPickle?

Korzystanie Python 2.7, ja przechodząc wiele dużych obiektów w całej procesach wykorzystujących menedżera pochodzący z multiprocessing.managers. BaseManager i chciałbym użyć cPickle jako serializera,

7Ciepło

2Odpowiedz

Blokady wieloprocesorowe Python

Ten kod wieloprocesowy działa zgodnie z oczekiwaniami. Tworzy 4 procesy Pythona i używa ich do drukowania liczb od 0 do 39, z opóźnieniem po każdym wydruku. import multiprocessing import time def j

8Ciepło

2Odpowiedz

Zakres kodu Pythona i wieloprocesorowość

Używam coveralls w połączeniu z coverage.py do śledzenia kodu Pythona dla moich skryptów testowych. Używam następujące polecenia: coverage run --parallel-mode --source=mysource --omit=*/stuff/idont/ne

6Ciepło

2Odpowiedz

imap_unordered() zawiesza się, jeśli iterable zgłasza błąd

rozważyć plik sample.py zawiera następujący kod: from multiprocessing import Pool def sample_worker(x): print "sample_worker processes item", x return x def get_sample_sequence(): f