Threads laufen nicht parallel in Python-Skript

Question

Ich bin neu in Python und Threading. Ich versuche mehrere Threads gleichzeitig auszuführen. Hier ist mein Grundcode:

import threading 
    import time 
    threads = [] 

    print "hello" 

    class myThread(threading.Thread): 
      def __init__(self,i): 
        threading.Thread.__init__(self) 
        print "i = ",i 
        for j in range(0,i): 
          print "j = ",j 
          time.sleep(5) 

    for i in range(1,4): 
      thread = myThread(i) 
      thread.start() 

Während 1 Thread für time.sleep(5) wartet ich will ein anderer Thread zu starten. Kurz gesagt, alle Threads sollten parallel laufen.

Answer 1

Sie könnten einige Missverständnisse haben, wie threading.Thread, allen voran __init__() Methode Unterklasse ist etwa, was einen Konstruktor stellt in Python, im Grunde wird es jedes Mal ausgeführt werden, wenn Sie eine Instanz erstellen, in Ihrem Fall, wenn thread = myThread(i) ausgeführt wird, wird es bis Ende __init__() blockieren.

Dann sollten Sie Ihre Aktivitäten in run() bewegen, so dass, wenn start() aufgerufen wird, wird der Faden zu laufen. Zum Beispiel:

import threading 
import time 
threads = [] 

print "hello" 

class myThread(threading.Thread): 
    def __init__(self, i): 
     threading.Thread.__init__(self) 
     self.i = i 

    def run(self): 
     print "i = ", self.i 
     for j in range(0, self.i): 
      print "j = ",j 
      time.sleep(5) 

for i in range(1,4): 
    thread = myThread(i) 
    thread.start() 

P.S. Aufgrund der Existenz von GIL in CPython sind Sie möglicherweise nicht in der Lage, alle Ihre Prozessoren vollständig zu nutzen, wenn die Task CPU-gebunden ist.

Answer 2

Hier ist ein Beispiel, wie Sie Threading basierend auf Ihren Code verwenden:

import threading 
import time 
threads = [] 

print "hello" 

def doWork(i): 
    print "i = ",i 
    for j in range(0,i): 
     print "j = ",j 
     time.sleep(5) 

for i in range(1,4): 
    thread = threading.Thread(target=doWork, args=(i,)) 
    threads.append(thread) 
    thread.start() 

# you need to wait for the threads to finish 
for thread in threads: 
    thread.join() 

print "Finished"