目前個人計算機大都是多核的，但是在執行python程式的時候會發現實際上只有一個核心（CPU）在跑程式碼，另外幾個核心都在偷懶呢，如下圖

 

平行計算的目的是將所有的核心都執行起來以提高程式碼的執行速度，在python中由於存在全域性直譯器鎖（GIL）如果使用預設的python多執行緒進行平行計算可能會發現程式碼的執行速度並不會加快，甚至會比使用但核心要慢！！！

一些並行模組通過修改pyhton的GIL機制突破了這個限制，使得Python在多核電腦中也能夠有效的進行平行計算。PP（Parallel Python）模組就是其中一種。

pp模組是python的一個輕量級並行模組，能夠有效提高程式執行效率，使用非常方便。

下面這段測試程式碼是計算從0到給定範圍內所有質數的和，即計算0~100000，0~100100，... ，0~100700這8個範圍內的所有質數的和：

1. import pp,time,math
   
2. def isprime(n):
   
3.     """Returns True if n is prime and False otherwise"""
   
4.     if not isinstance(n, int):
   
5.         raise TypeError("argument passed to is_prime is not of 'int' type")
   
6.     if n < 2:
   
7.         return False
   
8.     if n == 2:
   
9.         return True
   
10.     max = int(math.ceil(math.sqrt(n)))
    
11.     i = 2
    
12.     while i <= max:
    
13.         if n % i == 0:
    
14.             return False
    
15.         i += 1
    
16.     return True
    
17. def sum_pimes(n):
    
18.     """Calculates sum of all primes below given integer n"""
    
19.     return sum([x for x in range(2, n) if isprime(x)])
    
20. #序列程式碼
    
21. print("{beg}序列程式{beg}".format(beg='-'*16))
    
22. startTime = time.time()
    
23. inputs = (100000, 100100, 100200, 100300, 100400, 100500, 100600, 100700)
    
24. results = [ (input,sum_primes(input)) for input in inputs ]
    
25. for input, result in results:
    
26.     print("Sum of primes below %s is %s" % (input, result))
    
27. print("用時:%.3fs"%( time.time()-startTime ) )
    
28. #並行程式碼
    
29. print("{beg}並行程式{beg}".format(beg='-'*16))
    
30. startTime = time.time()
    
31. job_server = pp.Server()
    
32. inputs = (100000, 100100, 100200, 100300, 100400, 100500, 100600, 100700)
    
33. jobs = [(input, job_server.submit(sum_primes, (input, ), (isprime, ),
    
34.         ("math", )) ) for input in inputs]
    
35. for input, job in jobs:
    
36.     print("Sum of primes below %s is %s" % (input, job()))
    
37. print("用時:%.3fs"%( time.time()-startTime ) )
    

複製程式碼
執行效果圖：

 

由於樓主的電腦是偽4核（實際是2核，由於intel使用了超執行緒把它變成了4核的樣子），因此效率只是提高了兩倍，不過也還是不錯了~
理論上你的電腦中實際有多少的個核心，通過平行計算就能提高多少被效率（實際的提高倍速會低一點）。

可以看到並行程式碼只是比序列程式碼多了幾行，然而效率就翻倍了，看到這各位魚油有木有動心呢 

下面就開始正式介紹這個模組了

一：安裝

1.從官網下載對應版本的PP模組：http://www.parallelpython.com/content/view/18/32/

我的系統是Windows，python版本是3.4.4因此選擇了下面這個版本

 

2.在解壓目錄下開啟命令列，輸入python setup.py install就自動開始安裝了（就是這麼簡單 ）

 

二：使用

1.匯入模組

1. import pp

複製程式碼
2.開啟服務

1. job_server = pp.Server() 
   
2. #ncpus = 4 #可以自己指定使用的核心數
   
3. #job_server = pp.Server(ncpus) #建立服務
   
4. #預設為使用全部核心

複製程式碼
3.提交任務

1. f1 = job_server.submit(func1, args1, depfuncs1, modules1) 
   
2. #func1: 被並行執行的函式
   
3. #args1: func的引數，以元組的形式傳入
   
4. #depfuncs1: 被func呼叫的函式，以元組的形式傳入
   
5. #modules1: 函式執行需要呼叫的模組，以元組的形式傳入

複製程式碼
4.獲取結果

1. r1 = f1()

複製程式碼

下面根據之前的測試例子解釋下pp模組的使用

子程式

1. math
   
2. def isprime(n):
   
3.     if not isinstance(n, int):
   
4.         raise TypeError("argument passed to is_prime is not of 'int' type")
   
5.     if n < 2:
   
6.         return False
   
7.     if n == 2:
   
8.         return True
   
9.     max = int(math.ceil(math.sqrt(n)))
   
10.     i = 2
    
11.     while i <= max:
    
12.         if n % i == 0:
    
13.             return False
    
14.         i += 1
    
15.     return True
    
16. def sum_pimes(n):
    
17.     return sum([x for x in range(2, n) if isprime(x)])
    

複製程式碼
主程式

1. import pp
   
2. job_server = pp.Server()
   
3. inputs = (100000, 100100, 100200, 100300, 100400, 100500, 100600, 100700)
   
4. jobs = [(input, job_server.submit(sum_primes, (input, ), (isprime, ),
   
5.         ("math", )) ) for input in inputs]
   
6. for input, job in jobs:
   
7.     print("Sum of primes below %s is %s" % (input, job()))
   

複製程式碼
第1行：匯入pp模組
第2行：開啟pp服務，沒有填引數表示使用全部核心進行計算
第3行：設定任務，即程式需要計算0~100000，0~100100，... ，0~100700這8個範圍內的所有質數的和
第4行：是一個列表推導式，它的作用是將inputs中的值傳遞給sum_primes，並且執行job_server.submit函式。

1. 在job_server.submit的引數：
   
2. - sum_primes為被並行執行的函式，注意這裡不能寫成sum_primes()
   
3. - (input,)為sum_primes的引數即100000，100100，...，100700。注意這裡要以元組形式傳入，而","是元組的標誌，因此括號中的逗號不能漏了
   
4. - (isprime,)是sum_primes執行過程中需要用到的函式，以元組形式傳入
   
5. - ("math",)是sum_primes或isprime函式中需要用到的模組，以元組形式傳入

複製程式碼
最後兩行：執行完第四行後得到的jobs列表中的每個元素都是一個二元組即(input,func)的形式。這兩行的意思就是迴圈呼叫func，並列印結果。（通過函式呼叫的方式獲取平行計算結果）
到這裡一個使用pp模組進行平行計算的程式碼就實現了（平行計算就是如此簡單 ）。

隨著任務的需求不同，程式碼量也會有所變化，不過基本過程就是以上四步。