程序與執行緒

程序是載入到記憶體，正在被執行的程式。每個程序都擁有自己的位址空間、記憶體、資料棧以及其他用於跟蹤執行的輔助資料。程序是表示資源分配的的基本概念，又是排程執行的基本單位，是系統中的併發執行的單位。執行緒是比程序還小的執行基本單元，乙個程序至少有乙個執行緒。執行緒是一種輕量級的程序，多執行緒處理就是允許乙個程序中在同一時刻執行多個任務。

並行是指同一時刻同時做多件事情，而併發是指同一時間間隔內做多件事情。並行的必要條件就是cpu核心數 >= 總程序數，併發是多個程序在乙個cpu上交替進行，但看上去好像是一起執行。

python模組——multiprocessing

大致流程：

例項化乙個程序，引數分別是函式名、可選引數*args、可選引數**kwargs。

開啟程序

下面是乙個小例子

import multiprocessing
import time
print("start--{}".format(time.asctime(time.localtime(time.time()))))
def run():
print("start1--{}".format(time.asctime(time.localtime(time.time()))))
time.sleep(5)#模擬阻塞任務
print("end1--{}".format(time.asctime(time.localtime(time.time()))))
pro = multiprocessing.process(target=run)
pro.start()
time.sleep(5)#模擬阻塞任務
print("end--{}".format(time.asctime(time.localtime(time.time()))))

start--sat oct 20 23:49:04 2018 start1--sat oct 20 23:49:04 2018 end--sat oct 20 23:49:09 2018 end1--sat oct 20 23:49:09 2018

上述執行結果表明執行時間為5秒，上述**有兩個阻塞任務，每個阻塞任務都會耗時5秒，正常情況下，執行時間應該為10秒，但這裡為兩個阻塞多開了乙個程序，即在同一時間同時處理這兩個阻塞，所以耗時為5秒。下面是未開程序的**及執行結果。

import time
print("start--{}".format(time.asctime(time.localtime(time.time()))))
def run():
print("start1--{}".format(time.asctime(time.localtime(time.time()))))
time.sleep(5)#模擬阻塞任務
print("end1--{}".format(time.asctime(time.localtime(time.time()))))
run()
time.sleep(5)#模擬阻塞任務
print("end--{}".format(time.asctime(time.localtime(time.time()))))

start--sat oct 20 23:53:44 2018 start1--sat oct 20 23:53:44 2018 end1--sat oct 20 23:53:49 2018 end--sat oct 20 23:53:54 2018

上述執行時間為10秒

python在設計的時候還沒有多核處理器的概念，因此為了設計方便與執行緒安全，直接設計了乙個鎖，這個鎖要求在任何程序中，一次只能有乙個執行緒執行，因此python並不能為多個執行緒分配多個cpu，所以python中的執行緒只能實現併發，不能實現真正的並行。但在python3中的gil鎖有乙個很棒的的設計，那就是在遇到阻塞時會自動切換執行緒。

python模組——threading

大致流程：

例項化乙個執行緒，引數分別是函式名、可選引數*args、可選引數**kwargs。

開啟執行緒

import threading
import time
print("start--{}".format(time.asctime(time.localtime(time.time()))))
def run():
print("start1--{}".format(time.asctime(time.localtime(time.time()))))
time.sleep(5)#模擬阻塞任務
print("end1--{}".format(time.asctime(time.localtime(time.time()))))
pro = threading.thread(target=run)
pro.start()
time.sleep(5)#模擬阻塞任務
print("end--{}".format(time.asctime(time.localtime(time.time()))))

start--sun oct 21 00:08:22 2018 start1--sun oct 21 00:08:22 2018 end--sun oct 21 00:08:27 2018 end1--sun oct 21 00:08:27 2018

執行時間為5秒，說明開闢的執行緒避開了阻塞任務。

由於執行緒能有效的避開阻塞任務，故可以利用這一點實現服務端的多執行緒併發。

import socket
import threading
server = socket.socket()
server.bind(('127.0.0.5',8520))
server.listen(50)
def func(a):
date = a.recv(1024)
if date:
print("已收到資訊-->{}".format(date.decode()))
a.send(date)
else:
a.close()
while true:
a, b = server.accept()
pro = threading.thread(target=func,args = (a,))
pro.start()

import socket
import multiprocessing
server = socket.socket()
server.bind(('127.0.0.5',8520))
server.listen(50)
def func(a):
date = a.recv(1024)
if date:
print("已收到資訊-->{}".format(date.decode()))
a.send(date)
else:
a.close()
while true:
a, b = server.accept()
pro = multiprocessing.process(target=func,args = (a,))
pro.start()

程序與執行緒

程序與執行緒

程序與執行緒

程序與執行緒

相關推薦