multiprocessing

7Ciepło

2Odpowiedz

Skręcony klient sieciowy z pracownikami wieloprocesowymi?

Tak, mam aplikację, która używa Twisted + Stomper jako klienta STOMP, który prowadzi prace do wieloprocesowości. Pracowników. To wydaje się działać ok, gdy po prostu użyć skryptu Pythona to odpalić, k

49Ciepło

3Odpowiedz

Dane wyjściowe dziennika przetwarzania wieloprocesowego. Przetwarzanie

Czy istnieje sposób rejestrowania wyjścia standardowego z danego procesu podczas korzystania z klasy wieloprocesowej.Proces w python?

16Ciepło

1Odpowiedz

accept() z gniazdami współdzielonymi między wieloma procesami (w oparciu o prefinging Apache)

Pracuję nad kodem Pythona wzorowanym na serwerze prefabrykacji MPM Apache. Jestem bardziej programistą aplikacji niż programistą sieciowym i minęło 10 lat, odkąd przeczytałem Stevensa, więc staram się

10Ciepło

3Odpowiedz

Python multiprocessing i dostęp do bazy danych z pyodbc "nie jest bezpieczny"?

Problem: otrzymuję następujący traceback i nie rozumiem, co to znaczy i jak to naprawić: Traceback (most recent call last): File "<string>", line 1, in <module> File "C:\Python26\lib\multipr

15Ciepło

2Odpowiedz

Dumping wieloprocesorowy. Kwota do listy

Chcę zrzucić multiprocessing.Queue na listę. W tym celu napisałem następującą funkcję: import Queue def dump_queue(queue): """ Empties all pending items in a queue and returns them in a li

6Ciepło

4Odpowiedz

Wiele fork() współbieżność

Jak używać polecenia fork() w taki sposób, że można tarło 10 procesów i mieć je zrobić małe zadania jednocześnie. współbieżne jest operacyjny słowo, wiele miejsc, które pokazują, jak używać widelca uż

9Ciepło

1Odpowiedz

W jaki sposób można profilować zrównoleglony skrypt w języku Python?

Załóżmy, że mam skrypt Pythona o nazwie my_parallel_script.py który polega na wykorzystaniu multiprocessing parallelize kilka rzeczy i uruchomić go za pomocą następującego polecenia: python -m cProfil

6Ciepło

1Odpowiedz

Profilowanie puli wieloprocesorowej Pythona

Próbuję uruchomić cProfile.runctx() dla każdego procesu w puli wieloprocesowej, aby zorientować się, jakie wąskie gardła dla wielu procesów znajdują się w moim źródle. Tutaj jest uproszczony przykład

11Ciepło

2Odpowiedz

Python 2.6 wyślij obiekt połączenia na kolejkę/Rura/etc

Biorąc this bug (Python Issue 4892) który daje podstawę do następującego błędu: >>> import multiprocessing >>> multiprocessing.allow_connection_pickling() >>> q = multiprocessing.Queue() >>> p = mu

6Ciepło

2Odpowiedz

Python Multiprocessing

widzę to po naciśnięciu Ctrl-C, aby zakończyć moją aplikację Error in atexit._run_exitfuncs: Traceback (most recent call last): File "/usr/lib/python2.6/atexit.py", line 24, in _run_exitfuncs