python-multiprocessing

0열

1답변

파이썬의 풀 맵 메서드를 사용할 때 사용자 지정 개체를 반환 할 수 없습니다.

나는 다중 처리를 사용하여 파이썬에서 간단한 테스트 프로그램을 작성하려고합니다. Pool.map()을 사용하고 있습니다. 그것에, 나는 자식 프로세스에 의해 호출되어야하는 메소드를 전달하고있다. 올바르게 작동하고 반환 형식이 파이썬 기본 제공 형식 (예 : 문자열, 날짜/시간 등) 일 때 예상되는 결과가 나타납니다. 그러나 사용자 지정 클래스를 반환 형식으

0열

1답변

파이썬 다중 처리 .pool 순차적 프로세스 실행

저는 파이썬과 특히 '멀티 프로세싱'모듈에 새로운 것이 있습니다. 그러나, 저는 24 cpus에서 여러 프로세스 (예를 들어 100)를 실행하는 아주 간단한 스크립트를 작성했습니다. 그러나 프로세스가 순차적으로 실행되는 것이 아니라 무작위로 실행되는 것으로 나타났습니다. 프로세스를 순차적으로 실행할 수있는 방법이 있습니까? | 내가 파이썬 코드를 실행 한

1열

1답변

다중 프로세스에서 프로세스를 조율하는 방법?

나는 여러 프로세스에 의해 병렬로 multiprocessing.Queue을 처리하기위한 프로그램을 작성 중이다. 오케스트레이션 부분을 더 깊이 파고 들어갈수록 이해가 덜합니다. 내가 달성하고자하는 것은 여러 프로세스를 시작하고 모든 프로세스가 진행되기 전에 완료되었는지 확인하는 것입니다. 이것은 .join()에 대한 일처럼 들립니다. 나는 다음과 같은 데모

2열

1답변

Queue()/deque()와 통신을위한 클래스 변수 및 "poison pill"사용과 관련한 프로세스 대 스레드

While True 루프에서 영원히 실행되는 스레드 또는 프로세스를 만들고 싶습니다. 다중 처리 .Queue() 또는 collections.deque() 대기열에 대한 양식으로 작업자에게 데이터를 전송하고 수신해야합니다. 나는 상당히 빠르기 때문에 collections.deque()를 사용하는 것을 선호한다. 또한 작업자를 결국 죽일 수 있어야합니다 (wh

2열

1답변

기능

멀티 프로세싱에 항목의 목록을 전달 나는 다음과 같은 기능이 있습니다 : def create_job(target, args): p = multiprocessing.Process(target=target, args=args) p.start() return p 위의 함수가 호출됩니다 : ps = create_job(mc.colle

1열

1답변

실행 사이의 파이썬 다중 처리 sleep

나는 여러 작업을 병렬로 실행해야하는 python 스크립트를 가지고있다. 최대 프로세스 수를 20으로 설정했지만 작업을 전송하는 사이에 스크립트를 5 초 동안 기다려야합니다. 내 스크립트를 실행하면 모든 작업이 즉시 시작, #!/usr/bin/env python import multiprocessing import subprocess def pr

4열

2답변

python 3.4 multiprocessing

이 질문은 어떤 코드에 대한 도움과 조언을 요구합니다. 나는 현재 Python 3.4를 배우고 있습니다.기본 네트워크 검사 도구를 만들었습니다. 텍스트 파일에서 항목을 가져옵니다. 각 항목에 대해 파이썬에서 dns (pydns 사용)를 확인하고 ip (ping을 사용하여) OS 기본 핑 호출). 현재 저는 5000-9000000 IP 주소를 확인하고 있으며

0열

1답변

다중 처리, 풀링 및 임의성

이상한 일이 있습니다. 경제를 시뮬레이트하는 프로그램을 작성했습니다. 하나의 CPU 코어에서이 시뮬레이션을 하나씩 실행하는 대신 멀티 프로세싱을 사용하여 작업 속도를 높이고 싶습니다. 따라서 코드를 실행하고 (벌금), 내가하고있는 시뮬레이션에서 몇 가지 통계를 얻고 싶습니다. 그런 다음 놀랍게도 한 번에 발생하는 모든 시뮬레이션이 동일한 결과를 산출합니다.

2열

2답변

map/imap/imap_unordered를 인자없이 함수와 함께 사용할 수 있습니까?

가끔 인수없이 함수에 다중 처리를 사용해야합니다. 나는 같은 것을 할 수 있으면 좋겠다 : 나는 Process(target=f, args=()) 할 수 from multiprocessing import Pool def f(): # no argument return 1 # TypeError: f() takes no arguments (1 gi

4열

1답변

프로그램은 map()과 함께 작동하지만 pool.map()을 사용하여 TypeError를 발생시킵니다.

나는 꽤 오랫동안 사용되지 않았지만 이미 사용되어 잘 작동 한 프로그램이 있습니다. 여러 데이터에 대해 동일한 작업을 여러 번 수행해야하므로 다중 처리가 사용됩니다. 이제 새 매개 변수를 추가하는 프로그램을 만져서 테스트 한 결과 오류가 있음을 알았습니다. 또한 이전 (버전 제어) 버전도 동일한 오류가 발생합니다. 전체 오류는 다음과 같습니다. Except