基本使用

**基本概念

**

• 進程
  • 幾乎所有的操作系統(tǒng)都支持同時運行多個任務，一個任務通常就是一個程序，每個運行中的程序就是一個進程
  • 進程是處于運行過程中的程序，并且具有一定的獨立功能
  • 進程是系統(tǒng)進行資源分配調(diào)度的一個獨立單位
• 線程
  • 線程（Thread）也叫 輕量級進程 ，是操作系統(tǒng)能夠進行運算調(diào)度的最小單位
  • 它被包涵在進程之中，是進程中的實際運作單位，線程自己不擁有系統(tǒng)資源，只擁有一點兒在運行中必不可少的資源，但它可與同屬一個進程的其它線程共享進程所擁有的全部資源
  • 進程中的多個線程之間可以并發(fā)執(zhí)行

一個進程可以擁有多個線程，一個線程必須有一個父進程。線程可以擁有自己的堆棧、自己的程序計數(shù)器和自己的局部變量，但不擁有系統(tǒng)資源，它與父進程的其他線程共享該進程所擁有的全部資源。

多線程的優(yōu)點

• 進程之間不能共享內(nèi)存，但線程之間共享內(nèi)存非常容易
• 操作系統(tǒng)在創(chuàng)建進程時，需要為該進程重新分配系統(tǒng)資源，但創(chuàng)建線程的代價則小得多。因此，使用多線程來實現(xiàn)多任務并發(fā)執(zhí)行比使用多進程的效率高
• Python 語言內(nèi)置了多線程功能支持，而不是單純地作為底層操作系統(tǒng)的調(diào)度方式，從而簡化了 Python 的多線程編程

示例

**方式一： **使用 threading.Thread(target=方法名) 的方式實現(xiàn)多線程

參數(shù)說明：threading.Thread(參數(shù)說明)

• target： 指定該線程要調(diào)度的目標方法。只傳函數(shù)名，不傳函數(shù)，即不加()
• args： 指定一個元組，以位置參數(shù)的形式為target指定的函數(shù)傳入?yún)?shù)。元組的第一個參數(shù)傳給target的第一個，以此類推
• kwargs： 指定一個字典，以關鍵字參數(shù)的形式為target指定的函數(shù)傳入?yún)?shù)
• daemon:指定所構建的線程是否為后臺線程

import time
import threading




def eat(num):
    for i in range(num):
        print("我正在吃飯......")
        time.sleep(1)




def drunk(num=10):
    for i in range(num):
        print("我正在喝水......")
        time.sleep(1)




if __name__ == '__main__':
    # 創(chuàng)建兩個線程
    t1 = threading.Thread(target=eat, args=(10,))
    t2 = threading.Thread(target=drunk)
    # 啟動兩個線程
    t1.start()
    t2.start()


    while True:
        threadList = threading.enumerate()
        print("正在運行的線程是：", threadList)
        print("正在運行的線程數(shù)量是：", len(threadList))
        time.sleep(2)

方式二： 繼承threading.Thread

import time
import threading




class MyThread(threading.Thread):


    def run(self):
        for i in range(10):
            print("線程啟動了，我的名字叫：", self.name)
            time.sleep(1)




if __name__ == '__main__':
    # 創(chuàng)建兩個線程
    t1 = MyThread()
    t2 = MyThread()
    # 啟動兩個線程, start() 方法內(nèi)部會自動去調(diào)用 run方法，所以此處寫 start() 就可以了
    t1.start()
    t2.start()


    while True:
        threadList = threading.enumerate()
        print("正在運行的線程是：", threadList)
        print("正在運行的線程數(shù)量是：", len(threadList))
        time.sleep(2)

全局變量、互斥鎖、死鎖

共享全局變量示例

import threading


g_num = 0


def fun_1(num):
    global g_num
    for i in range(num):
        g_num += 1
    print("------fun_1的g_num值：%d" % g_num)




def fun_2(num):
    global g_num
    for i in range(num):
        g_num += 1
    print("------fun_2的g_num值：%d" % g_num)




if __name__ == '__main__':
    t1 = threading.Thread(target=fun_1, args=(1000000,))
    t2 = threading.Thread(target=fun_2, args=(1000000,))
    t1.start()
    t2.start()

輸出結果 ：

從以上結果可以看出，直接使用全局變量是有問題的，按理說，預期結果應該是2000000，實際結果相關很大，且每次執(zhí)行結果都不一樣

原因

• 在g_num=0 時，t1取得g_num=0，此時系統(tǒng)把t1調(diào)度為 "sleeping" 狀態(tài)，把t2轉換為 "running" 狀態(tài)，t2 這時也獲得了 g_num=0
• 然后 t2對得到的值進行加1，并賦給g_num，使得g_num=1
• 然后系統(tǒng)又把 t2調(diào)度為"sleeing"，把t1轉為"running",線程t1又把它之前得到的0 加1后賦值給 g_num。
• 這樣就導致了 t1和t2都對 g_num加1，但結果仍然是 g_num=1

解決方案：互斥鎖

• 當多個線程幾乎同時修改某個共享數(shù)據(jù)的時候，需要進行同步控制
• 某個線程要更改共享數(shù)據(jù)時，先將其鎖定，此時資源狀態(tài)為**” 鎖定 “ ，其他線程不能更改；直到該線程釋放資源，將資源的狀態(tài)改為 ”**非鎖定 “， 其他的線程才能再次鎖定該資源。互拆鎖保證了 每次只有一個線程進行寫入操作 ，從而保證了多線程數(shù)據(jù)的正確性

import threading


g_num = 0


def fun_1(num):
    global g_num
    for i in range(num):
        # 上鎖，如果之前沒上鎖，此時調(diào)用就會上鎖；如果之前上鎖了，此時調(diào)用就會阻塞，直接鎖被別人釋放
        lock.acquire()
        g_num += 1
        # 釋放鎖
        lock.release()
    print("------fun_1的g_num值：%d" % g_num)




def fun_2(num):
    global g_num
    for i in range(num):
        # 上鎖，如果之前沒上鎖，此時調(diào)用就會上鎖；如果之前上鎖了，此時調(diào)用就會阻塞，直接鎖被別人釋放
        lock.acquire()
        g_num += 1
        # 釋放鎖
        lock.release()
    print("------fun_2的g_num值：%d" % g_num)




if __name__ == '__main__':
    # 創(chuàng)建一個互斥鎖，默認是沒上鎖的
    lock=threading.Lock()


    t1 = threading.Thread(target=fun_1, args=(1000000,))
    t2 = threading.Thread(target=fun_2, args=(1000000,))
    t1.start()
    t2.start()

死鎖

• 在線程共享多個資源的時候，如果兩個線程分別占有一部分資源并且同時等待對方的資源，就會造成死鎖
• 盡管死鎖很少發(fā)生，但一旦發(fā)生就會造成程序停止響應

import threading
import time




def fun_1():
    # 1號鎖，上鎖
    lock1.acquire()
    print("fun_1..do some thing.........1")
    time.sleep(1)


    # 2號鎖，上鎖，如果被別人占用了，則會阻塞
    lock2.acquire()
    print("fun_1..do some thing..........2")
    # 釋放2號鎖
    lock2.release()


    # 釋放1號鎖
    lock1.release()




def fun_2():
    # 2號鎖，上鎖
    lock2.acquire()
    print("fun_2..do some thing.........2")
    time.sleep(1)


    # 1號鎖，上鎖，如果被別人占用了，則會阻塞
    lock1.acquire()
    print("fun_2..do some thing..........1")
    # 釋放1號鎖
    lock1.release()


    # 釋放2號鎖
    lock2.release()


if __name__ == '__main__':
    # 創(chuàng)建兩個互斥鎖
    lock1=threading.Lock()
    lock2=threading.Lock()


    t1 = threading.Thread(target=fun_1)
    t2 = threading.Thread(target=fun_2)
    t1.start()
    t2.start()

輸出結果：會一直停止阻塞

死鎖解決方案

• 程序設計時避免

• **添加超時等待

  **

進程

進程的狀態(tài)

• 新建：操作系統(tǒng)調(diào)度啟動一個新進程
• 就緒態(tài)：運行的條件都已經(jīng)滿足，等待cpu執(zhí)行
• 執(zhí)行態(tài)：cpu 正在執(zhí)行
• 等待態(tài)：等待某些條件滿足，例如一個程序sleep了，此時就處于等待態(tài)

進程的創(chuàng)建

• 在python中，提供了 multiprocessing 模塊，就是跨平臺的多進程模塊，模塊提供了 Process類來代表一人進程對象，這個對象可以理解為一個獨立的進程
• Process 參數(shù)說明
  • target：傳遞函數(shù)的引用，子進程將執(zhí)行這個函數(shù)
  • args：給target指定的函數(shù)，傳遞參數(shù),以元組的方式傳遞,非必填
  • kwargs：給target指定的函數(shù)傳遞命名參數(shù)，非必填
  • name：給進程設定一個名稱,非必填
  • group：指定進程組，非必填
• Process 對象的常用方法
  • start()：啟動子進程
  • is_alive()：判斷子進程是否還活著
  • join(timeout)：是否等待子進程執(zhí)行結束，或等待多少秒
  • terminate()：不管任務是否完成，立即終止子進程
• Process 對象的常用屬性
  • name：當前進程的別名，默認為Process-x, x為從1開始遞增的整數(shù)
  • pid：當前進程的pid (進程號)

示例

import time
import os
import multiprocessing




def eat(num):
    for i in range(num):
        print("我正在吃飯......,我的進程號是：%d,父進程的進程號是：%d" % (os.getpid(),os.getppid()))
        time.sleep(1)




def drunk(num):
    for i in range(num):
        print("我正在喝水......我的進程號是：%d,父進程的進程號是：%d" % (os.getpid(),os.getppid()))
        time.sleep(1)




if __name__ == '__main__':
    # 創(chuàng)建兩個進程
    p1 = multiprocessing.Process(target=eat, args=(10,))
    p2 = multiprocessing.Process(target=drunk, args=(10,))
    # 啟動兩個進程
    p1.start()
    p2.start()


    print("主進程的進程號是：%d" %os.getpid())

輸出結果

進程線程區(qū)別

• 功能區(qū)別
  • 進程：能夠完成多任務，比如，在一臺電腦上運行多個qq
  • 線程：能夠完成多任務，比如，在一個qq中開多個聊天窗口
• 調(diào)度
  • 進程是資源分配的基本單位
  • 線程是cpu調(diào)度和執(zhí)行的最小單位
• 擁有資源
  • 進程擁有資源的一個獨立單位
  • 線程不擁有系統(tǒng)資源，但可以訪問隸屬于進程的資源
• 穩(wěn)定性

• 進程有獨立的地址空間，多進程較穩(wěn)定，因為其中一個出現(xiàn)狀況不影 響另外一個

• 同一個進程的多個線程，共用地址空間，多線程相比于多進程，穩(wěn)定性要差，因為一個線程出現(xiàn)問題會嚴重影響其他線程

• 依賴關系
  • 一個線程只能屬性一個進程
  • 一個進程至少有一個線程
• 針對全局變量的共享
  • 多進程間不共享全局變量（進程間都是獨立的）
  • 多線程間共享全局變量

進程間的通信

• 不同的進程間有時也需要進行數(shù)據(jù)傳遞，在Python中，可以使用 muitiprocessiong模塊的 Queue ，來實現(xiàn)進程間的數(shù)據(jù)傳遞
• Queue 是一個消息隊列，數(shù)據(jù)是先進先出的原則

示例

import time
import multiprocessing




def set_data(queue):
    numList=[1,2,3,4]
    for i in numList:
        # 給隊列中放數(shù)據(jù),如果隊列已經(jīng)滿了，則會阻塞，直到能放數(shù)據(jù)為止
        queue.put(i)


    time.sleep(1)




def get_data(queue):
    while True:
        # 判斷隊列中如果沒有數(shù)據(jù)了，則退出循環(huán)
        if queue.empty():
            break


        # 從隊列中取數(shù)據(jù)
        data=queue.get()
        print("從隊列中取出的數(shù)據(jù)是：",data)


if __name__ == '__main__':
    # 創(chuàng)建一個消息列表，容量是3(表示只能裝3個數(shù)據(jù))
    queue=multiprocessing.Queue(3)


    # 創(chuàng)建兩個進程
    p1 = multiprocessing.Process(target=set_data, args=(queue,))
    p2 = multiprocessing.Process(target=get_data, args=(queue,))
    # 啟動兩個進程
    p1.start()
    p2.start()

**輸出結果 **

進程池

• 需要創(chuàng)建成百上千個進程時，可以使用 muitiprocessing模塊提供的 Pool 方法
• 初始化Pool時 ，可以指定一個最大進程數(shù)，當有新的請求提交到Pool中時，如果池里面沒有滿，就會創(chuàng)建一個新的進程來執(zhí)行該請求，如果已經(jīng)滿了，那么就會等待，直到池中有空閑進程，會調(diào)用空閑進程來執(zhí)行新任務

示例

import time
import os
import multiprocessing


def work(msg):
    print("開始執(zhí)行工作,當前進程是：",os.getpid())
    time.sleep(2)
    print("接收到的消息數(shù)據(jù)是：%s"%msg)




if __name__ == '__main__':
    # 創(chuàng)建進程池，容量為3
    pool=multiprocessing.Pool(3)


    for i in range(10):
        # pool.apply_async(要調(diào)用的目標，（傳遞給目標的參數(shù)元組,））
        # 每次循環(huán)將會用空閑的子進程去執(zhí)行任務
        pool.apply_async(work,("傳遞參數(shù):%d"%i,))


    # 關閉進程池，關閉后進程池不再接收新請求
    pool.close()
    # 等待進程池中所有的子進程執(zhí)行完成 ，必須放在close 語句之后
    pool.join()

輸出結果

協(xié)程

迭代器

• 迭代是訪問集合元素的一種方式
• 迭代器是一個可以記住遍歷位置的對象。
• 迭代器對象從集合的第一個元素開始訪問，直到所有的元素都訪問完成
• 迭代器只會前進，不會后退
• 我們把對 list、set、str、tuple 等類型的數(shù)據(jù)使用 for...in ... 的方式從中獲取數(shù)據(jù)，這樣的過程稱為 遍歷（循環(huán)） ，也叫迭代

判斷一個數(shù)據(jù)類型是否可迭代，使用 isinstance(xxx,Iterable)

from collections.abc import Iterable


list1=[1,2]
str1="123"
tuple1=(1,2)
dict1={1:"a",2:"b"}
num=122


print(isinstance(list1,Iterable))
print(isinstance(str1,Iterable))
print(isinstance(tuple1,Iterable))
print(isinstance(dict1,Iterable))
print(isinstance(num,Iterable))

輸出結果

自已實現(xiàn)迭代器示例

class MyIterator:
    """自己實現(xiàn)一個迭代器"""


    def __init__(self):
        self.name = list()
        self.currentIndex = 0


    def add(self, arg):
        self.name.append(arg)


    def __iter__(self):
        # 如果想要一個對象成為可以被迭代的對象，即可以使用 for ... in ... ，那么必須實現(xiàn) __iter__ 方法
        return self


    def __len__(self):
        return len(self.name)


    def __next__(self):
        # 當使用for...in... 迭代時，會先調(diào)用 __iter__ 方法，然后調(diào)用其返回對象中的 __next__ 方法(即本方法)
        if self.currentIndex < len(self.name):
            result = self.name[self.currentIndex]
            self.currentIndex += 1
            return result
        else:
            # 拋出一個 停止迭代的異常
            raise StopIteration




myIter = MyIterator()
myIter.add("張三")
myIter.add("李四")
myIter.add("王五")


for i in myIter:
    print(i)


# 獲取集合長度
print(len(myIter))

**生成器

**

• 生成器是一種特殊的迭代器
• 創(chuàng)建生成器有兩種方式
  • 方式一：把一個列表生成式的[] 改成 ()

  • # 原始列表
    l=[x*2 for x in range(10)]
    # 構建生成器
    g=(x*2 for x in range(10))
    
    
    # 迭代創(chuàng)建的生成器
    for i in g:
        print(i)
    

• 方式二：使用 yield 關鍵字

• def create_age(num):
      currentAge=0
      while currentAge# 創(chuàng)建生成器中的 值,并打印 send 過來的參數(shù)值
          sendMsg=yield currentAge
          print("%s 的年齡是：%d"%(sendMsg,currentAge))
          currentAge+=1
  # 創(chuàng)建生成器，并初始化10個值
  obj=create_age(10)
  
  
  # 迭代一次 生成器中的值
  n=next(obj)
  ss=obj.send("name"+str(0))
  print("send的結果：",ss)
  
  
  # 迭代后續(xù)，生成器中的值
  for i in obj:
      print(i)
  

協(xié)程

• 實現(xiàn)方式一：采用yield 實現(xiàn)

import time


def eat():
    while True:
        print("我在吃飯.....")
        time.sleep(1)
        yield




def drunk():
    while True:
        print("我在喝水.....")
        time.sleep(1)
        yield


if __name__ == '__main__':
    # 創(chuàng)建兩個生成器
    eat=eat()
    drunk=drunk()


    while True:
        next(eat)
        next(drunk)

• 實現(xiàn)方式二：采用 greenlet 實現(xiàn)
  • 先安裝 greenlet 模塊：pip install greenlet

import time
from greenlet import greenlet




def eat():
    while True:
        print("我在吃飯.....")
        # 切換到g2中運行
        g2.switch()
        time.sleep(1)




def drunk():
    while True:
        print("我在喝水.....")
        # 切換到g1中運行
        g1.switch()
        time.sleep(1)




if __name__ == '__main__':
    # 創(chuàng)建兩個生成器
    g1 = greenlet(eat)
    g2 = greenlet(drunk)


    # 切換到g1中運行
    g1.switch()

• 實現(xiàn)方式三：采用 gevent實現(xiàn) （ 推薦使用 ）
  • 由于 greenlet 需要人手動切換，比較占用IO資源，并且會出現(xiàn)，一旦中間某個程序處于線程等待的話，會一直等待很長時間的問題。所以gevent就應運而生，gevent 遇到延時阻塞會自動切換
  • 先安裝 gevent模塊：pip install gevent

import time
import gevent
from gevent import monkey


# 有耗時操作時需要, 將程序中用到的耗時操作的代碼，換為gevent中自己實現(xiàn)的模塊
monkey.patch_all()




def work(num):
    for i in range(num):
        print(gevent.getcurrent(), i)
        # 使用 mokey.patch_all() 之后，程序會自動替換成 gevent里面的 gevent.sleep() 方法
        time.sleep(1)




if __name__ == '__main__':
    # 創(chuàng)建并啟動協(xié)程
    gevent.joinall({
        gevent.spawn(work, 10),
        gevent.spawn(work, 10)
    })

圖片下載器實現(xiàn)

import gevent
from gevent import monkey
from urllib import request


# 有耗時操作時需要, 將程序中用到的耗時操作的代碼，換為gevent中自己實現(xiàn)的模塊
monkey.patch_all()


def down_pic(filename,url):
    resp=request.urlopen(url)
    data=resp.read()


    # 寫入文件
    with open(filename,"wb") as f:
        f.write(data)




if __name__ == '__main__':
    # 創(chuàng)建并啟動協(xié)程
    gevent.joinall({
        gevent.spawn(down_pic, "1.jpg","https://himg3.qunarzz.com/imgs/201812/14/C._M0DCiiigrWCy4LQi1024.jpg"),
        gevent.spawn(down_pic, "2.jpg","https://source.qunarzz.com/site/images/zhuanti/huodong/shangwu.jpg")
    })

總結

• 進程是資源分配的單位
• 線程是操作系統(tǒng)調(diào)度的單位
• 進程切換需要的資源最大，效率很低
• 線程切換需要的資源一般，效率一般（不考慮GIL的情況下）
• 協(xié)程切換任務資源很小，效率高
• 多進程、多線程根據(jù)cpu核數(shù)不一樣可能是并行的，但是協(xié)程是在一個線程中，所以是并發(fā)