线程模块是否真的在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()