線程模塊是否真的在python中並行？還是我們需要使用多處理？

Question

所以，我寫了這個簡單的代碼來檢查，如果蟒蛇線程模塊是真正平行，我發現，在這種情況下，

from threading import Thread, current_thread 
import multiprocessing as mp 
def callback(result): 
    print result 

def run_sql(n): 
    print current_thread() 
    for i in range(n): 
     i=i+1 
    print 'done for ', current_thread() 

if __name__=='__main__': 
    n=100000000 
    pool = mp.Pool(5) 
    threads= [ Thread(target=run_sql, args=(n,)) for i in range(5)] 
    for t in threads: 
     t.start() 
    for t in threads: 
     t.join() 

我試圖與Pool.apply_async同這實際上是平行的。

def callback(result): 
    print result 

def run_sql(n): 
    print current_thread() 
    for i in range(n): 
     i=i+1 
    print 'done for ', current_thread() 

if __name__=='__main__': 
    print datetime.datetime.now() 
    n=100000000 
    pool = mp.Pool(5) 
    for i in range(10): 
     pool.apply_async(run_sql, args= (n,),callback=callback) 
    pool.close() 
    pool.join() 

所以我的問題是什麼是使用，如果它是不是真的平行甚至可以節省工控機，並使用相同的內存區域的線程模塊的地步？另外，線程可以使用隊列或其他東西並行嗎？

Answer 1

好像你儘快加入你的線程，當你開始他們：

for t in threads: 
    t.start() 
    t.join() 

IIRC，Thread.join將等待線程完成，然後再繼續（這意味着你等待第一個線程啓動第二）...

一般來說之前完成，則需要2個循環：

for t in threads: 
    t.start() 
# other stuff to do in the main thread... 
for t in thread: 
    t.join()