Tag: python-multithreading
python-multithreading bezieht sich auf die Aufteilung der Arbeit in mehrere streams von der Ausführung in Python.
2
Antworten
Ich verwende Python 2.7. Ich habe einen timer, der wiederholt sich ständig, ein timer-Rückruf-Aktion, bis Sie gestoppt wurde. Es verwendet einen Timer-Objekt. Das problem ist, dass nachdem es angehalten worden ist, es kann nicht neu gestartet werden.
3
Antworten
Habe ich kleine server und-client Python-Skripte, in denen der client sendet einen string, und der server antwortet mit der Rückseite. Wenn der Kunde einen quit-string, der client beendet und dann den server verlässt. Ich möchte den server
1
Antworten
Ich versuche zu erstellen 86 Instanzen task.py gleichzeitig laufen lassen. import sys import subprocess for file in range(86): subprocess.call([sys.executable,'task.py',str(file)+'in.csv',str(filen)+'out.csv']) Was ist das problem? das problem war "Teilprozess.Anruf wartet auf den Befehl zu vervollständigen. Verwenden Teilprozess.Popen statt:" InformationsquelleAutor
1
Antworten
Habe ich eine python-Klasse nennen wir es AClass und ein weiteres MyThread erstreckt Thread. Und in diesem AClass ich 2 Objekte der Klasse MyThread und ich habe auch eine semaphore, die ich geben Sie es als parameter
3
Antworten
Hallo ich versuche ein Skript ausgeführt wird, mehrere Male, möchte aber zu diesem Ort, zur gleichen Zeit von dem, was ich verstanden, dass ich Teilprozess und threading zusammen jedoch wenn ich es ausführen, es sieht immer noch
1
Antworten
Ich erhalte die folgende Fehlermeldung Traceback (most recent call last): File "/Library/Frameworks/Python.framework/Versions/2.7/lib/python2.7/threading.py", line 810, in __bootstrap_inner self.run() File "python/file_download.py", line 30, in run self._downloadFile(host[0], host[1]) File "python/file_download.py", line 57, in _downloadFile th.exit() AttributeError: 'Thread' object has no
2
Antworten
Ich bin mit einem thread zu Lesen von Zeichenfolgen aus einem Datenstrom (/dev/tty1), die während der Bearbeitung andere Dinge, die in der main-loop. Ich möchte den Thread zu beenden zusammen mit dem main-Programm beim drücken von STRG-C.
1
Antworten
dies ist wirklich verwirrend mich, und ich kann nicht finden die Antwort. import thread import time import random import sys sys.stdout.flush() def run_often(thread_name, sleep_time): while True: time.sleep(sleep_time) print "%s" % (thread_name) def run_randomly(thread_name, sleep_time): while True: time.sleep(sleep_time)
1
Antworten
Ich versuche ein Programm zu schreiben, das schafft neue threads in einer Schleife, und nicht warten, für Sie zu beenden. Wie ich es verstehe, wenn ich .start() für den thread, meine main-Schleife einfach weiter, und der andere
2
Antworten
Ich versuche, ein Programm gestartet wird, sowohl ein view-Fenster (Konsole) und ein Befehl-Linie. In das view-Fenster, würde es zeigen Konstante updates, während die Kommandozeilen-Fenster verwenden würde raw_input() Befehle annehmen, die Einfluss auf das view-Fenster. Ich denke über
6
Antworten
Ich habe ein einfaches threaded Python-Programm des standard-Paradigma: class SearchThread(threading.Thread): def __init__(self, search_queue): threading.Thread.__init__(self) self.search_queue = search_queue def run(self): while True: try: search_url = self.search_queue.get(timeout=15) # <do Internet search and print output/> except Queue.Empty: self.search_queue.task_done() break except
2
Antworten
Was ist das Ziel der Arbeiterinnen? Sind diese Arbeitnehmer für multi-threading oder etwas anderes? Wenn die Odoo Instanz zu starten sehe ich bei mindestens 6 Beschäftigten auf-Befehl, informiert: 2016-03-10 13:55:09,602 15504 INFO ? openerp.service.server: Worker WorkerHTTP (15504)
4
Antworten
Habe ich ein python-multi-threaded-Anwendung. Ich will laufen ein asyncio-Schleife in einem thread und post calbacks und Coroutinen, um es aus einem anderen thread. Sollte einfach sein, aber ich kann nicht meinen Kopf um die asyncio Zeug. Kam
3
Antworten
Ich versuche ein Postfach checker mit imap lib, funktioniert es ziemlich gut mit python, queue und multithread-ohne gui. Aber wenn ich versuche eine gui, alle Funktion die ich gemacht habe, machen die gui einfrieren, bis fertig stellen
2
Antworten
Ich bin an einem Projekt arbeiten, die braucht etwas automation und web-Verschrottung, für die ich bin mit Selen und BeautifulSoup (python2.7). Ich das öffnen will nur eine Instanz eines web-Browsers und anmelden, um eine website, zu halten,
14
Antworten
Rufe ich eine Funktion in Python, die ich weiß, Stillstand und Kraft, mich um das Skript neu starten. Wie rufe ich die Funktion oder was muss ich wickeln Sie es in, so dass, wenn es länger dauert
1
Antworten
Ich bin derzeit mit dem threading - Funktion in python und bekam die folgende: In [1]: import threading threading.activeCount() Out[1]: 4 Nun auf meinem terminal habe ich mit lscpu und lernte dort sind 2 threads pro core
2
Antworten
Mir läuft ein Skript, welches extrahiert die Informationen aus debian-Paketen und speichert Sie in einer Datenbank. Nach dem extrahieren von Informationen aus über 100 Paketen ein Fehler Auftritt. Die Fehlermeldung "kann nicht einen neuen thread starten" Warum
2
Antworten
class My_Thread(threading.Thread): def __init__(self): threading.Thread.__init__(self) def run(self): print "Starting " + self.name cmd = [ "bash", 'process.sh'] p = subprocess.Popen(cmd, stdout=subprocess.PIPE, stderr=subprocess.STDOUT) for line in iter(p.stdout.readline, b''): print ("-- " + line.rstrip()) print "Exiting " + self.name
2
Antworten
Was ich möchte in der Lage sein zu tun ist, Fragen Sie einen Benutzer eine Frage mit input. Zum Beispiel: print('some scenario') prompt = input("You have 10 seconds to choose the correct answer...\n") dann, wenn die Zeit
2
Antworten
Jede Hilfe, wie bekomme ich diese zu akzeptieren, mehr als einen Kunden, und warum es nicht im moment? Danke! Außerdem ist es etwas, was ich falsch mache mit diesem code? Ich habe folgenden zumeist Python 2 tutorials,
2
Antworten
Ich versuche, mich eingefädelt, Flug-software für ein Projekt in Python 3.4, die ich brauche, threads zu starten, sich im Falle eines I/O-Fehler Auftritt, während ein sensor Lesen oder zu einem anderen fluke-crash so. Also ich bin dabei,
2
Antworten
Bin ich versucht, der download eines ganzen ftp-Verzeichnisses in parallel. #!/usr/bin/python import sys import datetime import os from multiprocessing import Process, Pool from ftplib import FTP curYear="" remotePath ="" localPath = "" def downloadFiles (remotePath,localPath): splitted =
2
Antworten
Gefiel mir die Möglichkeit, wiederum eine Funktion in einem thread ohne die unnötige Zeile, eine Klasse zu definieren. Ich weiß, über _thread, aber es scheint, dass Sie nicht verwenden sollte _thread. Gibt es ein good-practice-äquivalent thread.start_new_thread für
2
Antworten
Den aktuellen Python-Anwendung, an der ich arbeite, hat das Bedürfnis zu nutzen, um 1000+ threads (Pythons threading-Modul). Nicht, dass jeder einzelne thread arbeitet bei max cpu-Zyklen, dies ist nur ein web-server-Last-test-Anwendung, die ich erschaffe. I. E. emulieren
2
Antworten
Ich versuche zu tun, einige zeichnen, die parallel zur Oberfläche große batch-jobs schneller. Zu diesem Zweck starte ich einen thread für jede Handlung, die ich planen. Ich hatte gehofft, dass jeder thread fertig würde, seine Plotten und
1
Antworten
Ich habe gesehen, eine Menge von Python-Skripten, die die Verwendung von Threads in einer Klasse und viele von Ihnen nutzen die threading.Event(). Zum Beispiel: class TimerClass(threading.Thread): def __init__(self): threading.Thread.__init__(self) self.event = threading.Event() def run(self): while not self.event.is_set():
3
Antworten
Ich bin neu auf multithreading in python und versuchen zu lernen, die multithreading verwenden von threading-Modul. Ich habe ein sehr einfaches Programm von multi-threading, und ich habe Schwierigkeiten zu verstehen, die threading.Thread.join Methode. Hier ist der source-code
13
Antworten
Rufe ich eine Funktion in Python, die ich weiß, Stillstand und Kraft, mich um das Skript neu starten. Wie rufe ich die Funktion oder was muss ich wickeln Sie es in, so dass, wenn es länger dauert
11
Antworten
Wie bekomme ich ein thread zurückzukehren, ein Tupel oder ein beliebiger Wert meiner Wahl zurück zu den Eltern in Python? InformationsquelleAutor der Frage Paul Joseph | 2009-12-11
5
Antworten
Ich verbrachte einen ganzen Tag auf der Suche nach einem möglichst einfachen Multithread-URL fetcher in Python, aber die meisten scripts, die ich gefunden werden können, werden über queues oder multiprocessing oder komplexe Bibliotheken. Schließlich schrieb ich mich
4
Antworten
Ich bin versucht zu schreiben, eine Methode, die nach unten zählt, die zu einer gegebenen Zeit, und wenn ein restart-Befehl gegeben wird, es wird die task ausgeführt werden soll. Aber ich glaube nicht, dass Python threading.Timer Klasse
3
Antworten
Möchte ich weitergeben benannten Argumente, um die target-Funktion beim erstellen von einem Thread-Objekt. Folgenden ist der code, den ich geschrieben habe: import threading def f(x=None, y=None): print x,y t = threading.Thread(target=f, args=(x=1,y=2,)) t.start() Bekomme ich einen syntax-Fehler
3
Antworten
Sagen ich habe eine sehr große Liste, und ich bin der Durchführung einer operation etwa so: for item in items: try: api.my_operation(item) except: print 'error with item' Mein Problem ist zweigeteilt: die Es gibt eine Menge von
3
Antworten
Merke ich, dass es oft vorgeschlagen, um zu verwenden Warteschlangen mit mehreren threads, anstelle von Listen und .pop(). Ist dies, weil die Listen sind nicht thread-safe ist, oder aus irgendeinem anderen Grund? InformationsquelleAutor der Frage lemiant |
1
Antworten
Sagen, dass ich eine Funktion, die wie folgt aussieht: def _thread_function(arg1, arg2=None, arg3=None): #Random code Nun möchte ich einen thread eröffnen über, die Funktion, und geben Sie arg2, aber nicht arg3. Ich versuche dies wie folgt: #Note:
5
Antworten
Ich würde gerne ein Programm erstellen, dass ausgeführt wird, mehrere Licht-threads, sondern beschränkt sich auf eine Konstante, vordefinierte Anzahl gleichzeitig laufender Aufgaben, wie hier (aber ohne die Gefahr der race condition): import threading def f(arg): global running
3
Antworten
Ich bin mit dem I/O non-blocking python-server-Tornado. Ich habe eine Klasse GET Anforderungen, die möglicherweise eine erhebliche Menge an Zeit in Anspruch (man denke im Bereich von 5-10 Sekunden). Das problem ist, dass Tornado-Blöcken, die auf diese