一咱圆、創(chuàng)建多線程

Python提供兩個(gè)模塊進(jìn)行多線程的操作，分別是thread和threading羽利，
前者是比較低級(jí)的模塊宫患，用于更底層的操作，一般應(yīng)用級(jí)別的開(kāi)發(fā)不常用这弧。

方法1：直接使用threading.Thread()

import threading

# 這個(gè)函數(shù)名可隨便定義
def run(n):
    print("current task：", n)

if __name__ == "__main__":
    t1 = threading.Thread(target=run, args=("thread 1",))
    t2 = threading.Thread(target=run, args=("thread 2",))
    t1.start()
    t2.start()

方法2：繼承threading.Thread來(lái)自定義線程類，重寫run方法

import threading

class MyThread(threading.Thread):
    def __init__(self, n):
        super(MyThread, self).__init__()  # 重構(gòu)run函數(shù)必須要寫
        self.n = n

    def run(self):
        print("current task：", n)

if __name__ == "__main__":
    t1 = MyThread("thread 1")
    t2 = MyThread("thread 2")

    t1.start()
    t2.start()

二、創(chuàng)建多進(jìn)程

Python 要進(jìn)行多進(jìn)程操作痛垛，需要用到muiltprocessing庫(kù)，其中的Process類跟threading模塊的Thread類很相似泽疆。所以直接看代碼熟悉多進(jìn)程。

方法1：直接使用Process, 代碼如下：

from multiprocessing import Process  

def show(name):
    print("Process name is " + name)

if __name__ == "__main__": 
    proc = Process(target=show, args=('subprocess',))  
    proc.start()  
    proc.join()

方法2：繼承Process來(lái)自定義進(jìn)程類玲献，重寫run方法, 代碼如下：

from multiprocessing import Process
import time

class MyProcess(Process):
    def __init__(self, name):
        super(MyProcess, self).__init__()
        self.name = name

    def run(self):
        print('process name :' + str(self.name))
        time.sleep(1)

if __name__ == '__main__':
    for i in range(3):
        p = MyProcess(i)
        p.start()
    for i in range(3):
        p.join()

多進(jìn)程通信
進(jìn)程之間不共享數(shù)據(jù)的。如果進(jìn)程之間需要進(jìn)行通信梯浪，則要用到Queue模塊或者Pipi模塊來(lái)實(shí)現(xiàn)捌年。

Queue
Queue 是多進(jìn)程安全的隊(duì)列，可以實(shí)現(xiàn)多進(jìn)程之間的數(shù)據(jù)傳遞挂洛。它主要有兩個(gè)函數(shù),put和get礼预。

put() 用以插入數(shù)據(jù)到隊(duì)列中，put 還有兩個(gè)可選參數(shù)：blocked 和 timeout虏劲。如果 blocked 為 True（默認(rèn)值）托酸，并且 timeout 為正值，該方法會(huì)阻塞 timeout 指定的時(shí)間柒巫，直到該隊(duì)列有剩余的空間励堡。如果超時(shí)，會(huì)拋出 Queue.Full 異常堡掏。如果 blocked 為 False应结，但該 Queue 已滿，會(huì)立即拋出 Queue.Full 異常泉唁。

get()可以從隊(duì)列讀取并且刪除一個(gè)元素鹅龄。同樣，get 有兩個(gè)可選參數(shù)：blocked 和 timeout亭畜。如果 blocked 為 True（默認(rèn)值）扮休，并且 timeout 為正值，那么在等待時(shí)間內(nèi)沒(méi)有取到任何元素拴鸵，會(huì)拋出 Queue.Empty 異常玷坠。如果blocked 為 False，有兩種情況存在宝踪，如果 Queue 有一個(gè)值可用侨糟，則立即返回該值，否則瘩燥，如果隊(duì)列為空秕重，則立即拋出 Queue.Empty 異常。

具體用法如下：

from multiprocessing import Process, Queue
 
def put(queue):
    queue.put('Queue 用法')
 
if __name__ == '__main__':
    queue = Queue()
    pro = Process(target=put, args=(queue,))
    pro.start()
    print(queue.get())   
    pro.join()