Làm thế nào để sử dụng nhiều luồng

Question

tôi có mã này:

import thread 

def print_out(m1, m2): 
    print m1 
    print m2 
    print "\n" 

for num in range(0, 10): 
    thread.start_new_thread(print_out, ('a', 'b')) 

Tôi muốn tạo 10 chủ đề, mỗi chủ đề chạy chức năng print_out, nhưng tôi đã thất bại. Các lỗi như sau:

Unhandled exception in thread started by 
sys.excepthook is missing 
lost sys.stderr 
Unhandled exception in thread started by 
sys.excepthook is missing 
lost sys.stderr 
Unhandled exception in thread started by 
sys.excepthook is missing 
lost sys.stderr 
Unhandled exception in thread started by 
sys.excepthook is missing 
lost sys.stderr 
Unhandled exception in thread started by 
sys.excepthook is missing 
lost sys.stderr 
Unhandled exception in thread started by 
sys.excepthook is missing 
lost sys.stderr 
Unhandled exception in thread started by 
sys.excepthook is missing 
lost sys.stderr 
Unhandled exception in thread started by 
sys.excepthook is missing 
lost sys.stderr 
Unhandled exception in thread started by 
sys.excepthook is missing 
lost sys.stderr 
Unhandled exception in thread started by 
sys.excepthook is missing 
lost sys.stderr 

Answer 1

Trước hết, bạn nên sử dụng mức threading mô-đun cao hơn và đặc biệt là lớp Thread. Mô-đun thread không phải là những gì bạn cần.

Khi bạn mở rộng mã này, rất có thể bạn cũng sẽ muốn đợi các chuỗi kết thúc. Sau đây là một minh chứng về cách sử dụng phương pháp join để đạt được điều đó:

import threading 

class print_out(threading.Thread): 

    def __init__ (self, m1, m2): 
     threading.Thread.__init__(self) 
     self.m1 = m1 
     self.m2 = m2 

    def run(self): 
     print self.m1 
     print self.m2 
     print "\n" 

threads = [] 
for num in range(0, 10): 
    thread = print_out('a', 'b') 
    thread.start() 
    threads.append(thread) 

for thread in threads: 
    thread.join() 

Answer 2

Bạn nên để cho các chủ đề chính ở lại sống một thời gian ngắn. Nếu chủ đề chính chết, tất cả các luồng khác và do đó bạn sẽ không thấy bất kỳ đầu ra nào. Thử thêm time.sleep(0.1) vào cuối mã và sau đó bạn sẽ thấy kết quả đầu ra.

Sau đó, bạn có thể xem thread.join() để biết thêm về điều này.

Answer 3

Cách tiếp cận khác là sử dụng lớp luồng.

instance[num]=threading.Thread(target=print_out, args=('a', 'b')) 

instance[num].start()