Es hat lange gedauert - aber hier ist das funktionierende Grundgerüst vom Test Code mit allem was ich benötige :D


import multiprocessing
from time import sleep

is_beep = True # beep on/off

try:
import winsound
def beep():
frequency = 2500 # Set Frequency To 2500 Hertz
duration = 500 # Set ...

@Dennis89

Danke!
Sooo einfach, wenn man es weiss

Jetzt bleibt für mich aber noch die große Frage wie ich an die "Ergebnisse" der Prozesse ran komme.

Hallo,
Ich habe erst mal versucht mich mit ein paar Grundlagen zu beschäftigen und der folgende Test Code funzt auch erst mal.
Ich habe mir drei Prozesse erstellt mit unterschiedlichen Laufzeiten (sleep)
Zum Test werden zwei Prozesse in einer vorbestimmten Zeit beendet und der dritte "moviestar ...

@Sirius3

ohne 'self' - das hab ich auch getestet. einmal nur die Funktion _load_movie_data() außerhalb der klasse und auch beide Funktionen in einen eigenen file gepackt.
in keinem Fall kam es dazu das pydevd reagiert hat

def _load_movie_data(queue):
import pydevd
pydevd.settrace('localhost ...

Moin,
zum immer noch vorhandenen Problem "cannot pickle '_queue.SimpleQueue' object"

Um mögliche Fehlerquellen im alten Code auszuschließen hab ich als Test mal folgendes gemacht:

def get_sources(self,params):
try:
queue = multiprocessing.SimpleQueue()
p = multiprocessing.Process(target=self ...

Hallo,

und wieder ging es einen kleinen Schritt weiter

Connected to pydev debugger (build 173.4127.16)
process gestartet: Process-1
process gestartet: Process-2

Aber zu früh gefreut - die run funktion (filmpalst, filmpro wird nicht ausgeführt)

Gruß kasi45

Hallo,
ein kleiner Schritt näher am Ziel.

Can't pickle <class 'filmpalast.source'>: import of module 'filmpalast' failed

Diese Exception gibt es nun nicht mehr!

Zwei Beiträge weiter oben, im ersten Codeblock habe ich eine Zeile ergänzt:

if spec:
module = importlib.util.module_from_spec(spec ...

"Senile Bettflucht" - PC einschalten und testen :lol:

Zur besseren Übersicht nur mit zwei processes getestet und ein paar print hinzugefügt

for process in processes:
print('process: '+ str(process))
print('process name: '+ str(process.name))
print('process args: '+ str(process._args))
try ...

Hallo,

zum besseren Verständnis woher "sourceDict" kommt. Im Verzeichnis "sourceSubFolders" liegen PythonFiles alle mit einer Klasse 'source' in der sich die Funktion run() befindet. Alle Funktionen run() sollen über multiprocessing verarbeitet werden.

for i in sourceSubFolders:
for loader ...

Hallo __blackjack__,

das war aber mal eine menge an Input für mich. :)

So einige Teile von diesem Code sind schon uralt und kommen von einem Kodi Addon dass es schon lange nicht mehr gibt.
Du hast in allem recht - und weil so viel Chaos im Code war und auch noch ist wollte ich die damaligen ...

Hallo @__blackjack__ ,

`Process`-Objekte haben eine `terminate()`-Methode.
Genau dies war der Grund es mal mit "multiprocessing" zu versuchen.

hier die Änderungen im Sourcecode bei meinem Versuch mit "multiprocessing" zum Ziel zu kommen:

#futures = {self.executor.submit(self._getSource ...

Hallo,

zu meinem Python Problem:

Innerhalb einer Funktion starte ich mit ThreadPoolExecutor (concurrent.futures) mehrere Threads.
Die Funktion 8main) läuft weiter und es wird eine Schleife mit timeout startet.
In dieser Schleife wird u.a. abgefragt welche Threads zu dem Zeitpunkt noch nicht ...