Suchergebnisse für Anfrage "multiprocessing"
gensim LdaMulticore nicht Multiprozessing?
Wenn ich gensim's @ laufen lasLdaMulticore Modell auf einer Maschine mit 12 Kernen unter Verwendung von: lda = LdaMulticore(corpus, num_topics=64, workers=10)Ich erhalte eine Protokollmeldung mit der Aufschrift using serial LDA version on this ...
MSBuild - So erstellen Sie mehrere Dateien UND Projekte gleichzeitig
Ich habe eine große Visual Studio 2010-Lösungsdatei .sln) das eine große Anzahl von Projekten enthält ~50). Jedes Projekt besteht aus ungefähr20 .cpp und.h Dateien. Das Erstellen des gesamten Projekts dauert ungefähr 2 Stunden auf einem schnellen ...
Python Multiprocessing erzeugt kontinuierlich pythonw.exe-Prozesse ohne eigentliche Arbeit.
Ich verstehe nicht, warum dieser einfache Code # file: mp.py from multiprocessing import Process import sys def func(x): print 'works ', x + 2 sys.stdout.flush() p = Process(target= func, args= (2, )) p.start() p.join() p.terminate() print ...
Wie man ein ssl.SSLContext-Objekt auswählt
Python 3.5 unter Windows: import ssl, pickle, multiprocessing context = ssl.create_default_context() foo = pickle.dumps(context) pickle.loads(foo) Löst eine Ausnahme aus: TypeError: __new__() missing 1 required positional argument: ...
Python-Protokollierung mit Multiprocessing, Root-Protokollierung in Windows ande
Ich habe versucht, mit Multiprocessing zu protokollieren. Unter Windows wird ein anderer Root-Logger im Child-Prozess angezeigt. Unter Linux ist dies jedoch in Ordnung. Der Testcode: main.py: #!/usr/bin/env python # -*- coding: utf-8 -*- ...
Python 3 Multiprocessing: Optimale Blockgröße
Wie finde ich die optimale Blockgröße fürmultiprocessing.Pool Instanzen? Ich habe dies zuvor verwendet, um einen Generator für @ zu erstellen sudoku objects: processes = multiprocessing.cpu_count() worker_pool = multiprocessing.Pool(processes) ...
Sellerie: Wie kann man die Anzahl der Aufgaben in der Warteschlange begrenzen und den Fütterungsvorgang beenden, wenn sie voll sind?
Ich bin sehr neu bei Sellerie und hier ist die Frage, die ich habe: Angenommen, ich habe ein Skript, mit dem ständig neue Daten aus der Datenbank abgerufen und mit Sellerie an die Mitarbeiter gesendet werden sollen. tasks.py # Celery Task ...
Python manager.dict () ist im Vergleich zu regulärem dict @ sehr langs
Ich habe ein Dikt zum Speichern von Objekten: jobs = {} job = Job() jobs[job.name] = job Jetzt möchte ich es konvertieren, um Manager-Dikt zu verwenden, da ich Multiprocessing verwenden möchte und dieses Dikt an Prozesse weitergeben muss. mgr = ...
Einfachste Methode zum Lesen von CSV-Dateien mit Multiprocessing in Pandas
Hier ist meine Frage. Mit einer Reihe von CSV-Dateien (oder anderen Dateien). Pandas ist eine einfache Möglichkeit, sie zu lesen und in @ zu speicherDataframe Format. Aber wenn die Anzahl der Dateien sehr groß war, möchte ich die Dateien ...
Broken Pipe bei Verwendung von Python Multiprocessing Managers (BaseManager / SyncManager) zum Freigeben der Warteschlange für Remote-Computer
Im letzten Monat hatten wir ein anhaltendes Problem mit dem Python 2.6.x-Multiprozessor-Paket, als wir versuchten, eine Warteschlange für mehrere verschiedene (Linux-) Computer freizugeben. Ich habe diese Frage auch Jesse Noller direkt gestellt, ...