一、程序

           我們電腦的應用程式，都是程序，程序是資源分配的單位。程序切換需要的資源最大，效率低。         程序之間相互獨立         cpu密集的時候適合用多程序

#多程序併發

import multiprocessing
from multiprocessing import Pool
import time
def test1():
    
 
for i in range(10):
        time.sleep(1)
        print('test', i)
 
def test2():
    for i in range(10):
        time.sleep(1)
        print('test', i)
 
if __name__ == '__main__':
    p1 = multiprocessing.Process(target=test1)
    p2 = multiprocessing.Process(target=test2)
    p1.start()
    p2.start()
 

 

#程序之間不共享

import multiprocessing
from multiprocessing import Pool
import time
import threading
g_num = 0
def test1():
    global g_num
    for i in range(10):
        g_num += 1
def test2():
    print(g_num)
if __name__ == '__main__':
    p1 = multiprocessing.Process(target=test1)
    p2 
 
= multiprocessing.Process(target=test2)
    p1.start()
    p1.join()
    p2.start()

結果是 0   

二、程序池

        python中，程序池內部會維護一個程序序列，當需要時，程式會去程序池中獲取一個程序，如果程序池序列中沒有可供使用的程序，那麼程式就會等待，直到程序池中有可用的程序為止。

#程序池實現併發

import multiprocessing
from multiprocessing import Pool
import time
import threading
g_num = 0
def test1():
    for i in range(10):
        time.sleep(1)
        print('test1',i)
def test2():
    for i in range(10):
        time.sleep(1)
        print('test2',i)
 
if __name__ == '__main__':
    pool = Pool(2)    # 允許程序池裡同時放入2個程序 其他多餘的程序處於掛起狀態
    pool.apply_async(test1)      
    pool.apply_async(test2)
    pool.close()  # close() 必須在join()前被呼叫
    pool.join()    # 程序池中程序執行完畢後再關閉，如果註釋，那麼程式直接關閉。


join() 方法實現程序間的同步，等待所有程序退出。
close() 用來阻止多餘的程序湧入程序池 Pool 造成程序阻塞。
apply_async()本身就可以返回被程序呼叫的函 數的返回值 

 

三、 協程：

        協程相對獨立，有自己的上下文，但其切換由自己控制，由當前協程切換到其他協程由協程來控制。而執行緒的切換由系統控制。  協程切換需要的資源很小，效率高   多程序、多執行緒根據cpu核數不一樣可能是並行的，但是協程在一個執行緒中

#協程，自動切換（可以在test2sleep的時候切換去執行test1）

import gevent,time
from gevent import monkey    
monkey.patch_all()   #gevent三行放在其他所有import語句之前可以避免出現警告或者報錯資訊,導致程式不能正常執行
def test1():
    for i in range(10):
        time.sleep(1)
        print('test1',1)
 
def test2():
    for i in range(10):
        time.sleep(2)
        print('test2',2)
g1 = gevent.spawn(test1)
g2 = gevent.spawn(test2)
g1.join()
g2.join()