multiprocessing

18Ciepło

5Odpowiedz

Użycie pamięci ciągle rośnie z multiprocessing.pool Pythona

Oto program: #!/usr/bin/python import multiprocessing def dummy_func(r): pass def worker(): pass if __name__ == '__main__': pool = multiprocessing.Pool(processes=16) for in

5Ciepło

3Odpowiedz

Czy istnieje wersja wywołania systemowego wait(), który ustawia limit czasu?

Czy istnieje sposób na skorzystanie z połączenia systemowego wait() z limitem czasu, poza wykorzystaniem pętli zajętości oczekującej lub zajętości? Mam proces nadrzędny, który sam w sobie jest fork, a

6Ciepło

2Odpowiedz

Python Multiprocessing Kill Processes

Uczę się, jak korzystać z biblioteki wieloprocesorowej Python. Jednakże, podczas gdy przechodzę niektóre przykłady, zakończyłem z wieloma procesami Pythona działającymi w moim tle. Jednym z example wy

20Ciepło

1Odpowiedz

ProcessPoolExecutor z concurrent.futures sposób wolniejszy niż multiprocessing.Pool

Eksperymentowałem z nowym, błyszczącym modułem concurrent.futures wprowadzonym w Pythonie 3.2, i zauważyłem, że prawie z identycznym kodem, używanie Pool z concurrent.futures jest sposobem wolniej niż

9Ciepło

1Odpowiedz

Jak działa funkcja wywołania zwrotnego w wieloprocesorowym pythonie map_async

Kosztowało mnie to całą noc, aby debugować mój kod, iw końcu znalazłem ten podchwytliwy problem. Proszę spojrzeć na kod poniżej. from multiprocessing import Pool def myfunc(x): return [i for i

8Ciepło

1Odpowiedz

Proces automatycznego zabijania i proces potomny wieloprocesorowego puli

Używam modułu przetwarzania wieloprocesowego do przetwarzania równoległego. Bellow code snippet wyszukuje nazwę pliku w lokalizacji X i zwraca nazwę pliku, w którym znaleziono ciąg znaków. Ale w niekt

7Ciepło

1Odpowiedz

Wieloprocesorowość w Pythonie> = lista 125 nigdy się nie kończy

Próbuję zaimplementować to wieloprocesowe tutorial do własnych celów. Początkowo myślałem, że nie skaluje się dobrze, ale kiedy zrobiłem powtarzalny przykład, stwierdziłem, że jeśli lista przedmiotów

6Ciepło

2Odpowiedz

Parametr ctx w trybie wieloprocesowym.Queue

Próbuję użyć kolejki z modułu multiprocessing.Queue. wdrażania (https://docs.python.org/3.4/library/multiprocessing.html#exchanging-objects-between-processes) wykorzystuje q = Queue() jako przykład

10Ciepło

2Odpowiedz

Program EXE systemu Windows skompilowany przez PyInstaller kończy się niepowodzeniem z wieloprocesowym przetwarzaniem

W moim projekcie używam biblioteki Pythona multiprocessing do tworzenia wielu procesów w __main__. Projekt jest pakowany do pojedynczego pliku EXE systemu Windows przy użyciu PyInstaller 2.1.1. tworzę

7Ciepło

2Odpowiedz

Jak mogę zrobić zapis atomowy na stdout w pythonie?

Czytałem w niektórych źródeł, że komenda druku nie jest bezpieczny wątku, a obejście jest użycie sys.stdout.write polecenie zamiast, ale nadal nie działa dla mnie i piśmie do STDOUT nie jest atomowy.