с использованием многопоточной функции excute member в Python

Question

Я пытаюсь использовать python для кодирования многопоточной программы. Поскольку я очень новичок в python, я утверждаю, что если бы я спросил что-то общее.

Вот мой код в основном:

multi_threads = [] 
    simulator = Simulation(simulation_number) 
     # Simulation is my class, run() is a member function 

    for i in range(0, thread_number): 
     multi_threads.append(Thread(target = simulator.run, args = (start, end,))) 

    for i in range(0, thread_number): 
     multi_threads[i].start() 
     multi_threads[i].join() 

и имитация :: бежать:

def run(self, start, end): 
     # do something... 
     print "in run" 
     return 

Я ожидаю увидеть in run несколько раз. Но оказывается, что ничего нет.

Могу я узнать, что я не так? Спасибо заранее.

Answer 1

Вам необходимо позвонить по номеру .start(). Так что в вашем случае:

for t in multi_threads: 
    t.start() 

отредактирован измениться выполнить для запуска (спасибо комментаторам, я misremembered название метода)

Answer 2

Вот некоторые полный код:

from threading import Thread 

class Simulation(object): 
    def __init__(self, n): 
     pass 

    def run(self, start, end): 
     print "Running",start,end 

simulation_number=None 

start = None 
end = None 

thread_number=5 


multi_threads = [] 
simulator = Simulation(simulation_number) 
# Simulation is my class, run() is a member function 


for i in range(0, thread_number): 
    multi_threads.append(Thread(target = simulator.run, args = (i, end,))) 

for i in range(0, thread_number): 
    multi_threads[i].start() 
    multi_threads[i].join() 

И выводит «Running» для каждого потока, хотя в этом случае каждый поток заканчивается до следующего запуска, поэтому нет смысла использовать потоки.