threading多執行緒模組

class Thread:
​
    """注釋被我刪掉了"""
    
    _initialized = False  # 這是一個狀態位，來表示該執行緒是否被被初始化過
​
    def __init__(self, group=None, target=None, name=None,
                 args=(), kwargs=None, *, daemon=None):
                 
        """注釋被我刪掉了"""             
      
        assert group is None, "group argument must be None for now" #如果不是 None，daemon參數將顯式地設置該執行緒是否為守護模式。 如果是 None (默認值)，執行緒將繼承當前執行緒的守護模式屬性。
        if kwargs is None:
            kwargs = {}  # kwargs 是用於調用目標函數的關鍵字參數字典。默認是 {}。
        self._target = target  # 對於第一種調用方式來說，它就是我們的task函數。
        self._name = str(name or _newname())  # 執行緒名
        self._args = args  # _args是用於調用目標函數的參數元組。默認是 ()。
        self._kwargs = kwargs 
        if daemon is not None: # 判斷其是否為守護執行緒
            self._daemonic = daemon
        else:
            self._daemonic = current_thread().daemon
        self._ident = None # 這個是執行緒的編號
        if _HAVE_THREAD_NATIVE_ID:  # 判斷是否具有本地ID
            self._native_id = None
        self._tstate_lock = None  # 鎖定的狀態
        self._started = Event() # 開始
        self._is_stopped = False # 狀態位，是否停止
        self._initialized = True  # 將初始化狀態為改為True
        # Copy of sys.stderr used by self._invoke_excepthook()
        self._stderr = _sys.stderr
        self._invoke_excepthook = _make_invoke_excepthook()
        # For debugging and _after_fork()
        _dangling.add(self)

def run(self):
​
    """注釋被我刪掉了"""
    
    try:
        if self._target:  # 簡單吧，這個方法，就是判斷你有沒有傳入一個函數。即我們定義的task
            self._target(*self._args, **self._kwargs)  # 有的話就立即執行，我們傳入的name其實就放在了_args中。這裡將它打散出來了，所以我們的task函數中的第一個參數name能收到。
    finally:
        # Avoid a refcycle if the thread is running a function with
        # an argument that has a member that points to the thread.
        del self._target, self._args, self._kwargs  # 不管處不出錯，都會清理他們。當然，如果有則是執行完成後清理

import threading
import time

print("主執行緒任務開始運行")

class Threading(threading.Thread):
    """自定義類"""

    def run(self):
        print(self._args)  # ('執行緒[1]',)
        print(self._kwargs)  # {}

        print("子執行緒任務開始處理,參數:{0}".format(self._args[0]))
        time.sleep(3)  # <-- 這裡睡眠了三秒，可以看見主執行緒繼續往下走了
        print("子執行緒任務運行完畢")



if __name__ == '__main__':
    
    t1 = Threading(args=("執行緒[1]",))
    t1.start()  # 等待CPU調度..請注意這裡不是立即執行
    
    
    print("主執行緒任務處理完畢")

# ==== 執行結果 ====
    
"""
主執行緒任務開始處理
('執行緒[1]',)
主執行緒任務處理完畢
{}
子執行緒任務開始處理,參數:執行緒[1]
子執行緒任務處理完畢
"""

# ==== 情況一 ====

import threading
import time

print("主執行緒任務開始處理")

def task(th_name):
    print("子執行緒任務開始處理,參數:{0}".format(th_name))
    time.sleep(3)
    print("子執行緒任務處理完畢")

if __name__ == '__main__':

    t1 = threading.Thread(target=task,args=("執行緒[1]",))

    t1.setDaemon(True)  # <--- 放在start()上面，主執行緒運行完後會立即終止子執行緒的運行。但是由於有join()，故不生效。

    t1.start()  #  等待CPU調度..請注意這裡不是立即執行

    t1.join()  # <--- 放在start()下面，等2秒後主執行緒繼續執行

    print("主執行緒任務處理完畢")

# ==== 執行結果 ====

"""
主執行緒任務開始處理
子執行緒任務開始處理,參數:執行緒[1]
子執行緒任務處理完畢
主執行緒任務處理完畢
"""

# ==== 情況二 ====

import threading
import time

print("主執行緒任務開始處理")

def task(th_name):
    print("子執行緒任務開始處理,參數:{0}".format(th_name))
    time.sleep(3)
    print("子執行緒任務處理完畢")

if __name__ == '__main__':

    t1 = threading.Thread(target=task,args=("執行緒[1]",))

    t1.setDaemon(True)  # <--- 放在start()上面，主執行緒運行完後會立即終止子執行緒的運行。但是由於有join()，故不生效。

    t1.start()  #  等待CPU調度..請注意這裡不是立即執行

    t1.join(2)  # <--- 放在start()下面，等2秒後主執行緒繼續執行

    print("主執行緒任務處理完畢")

# ==== 執行結果 ====

"""
主執行緒任務開始處理
子執行緒任務開始處理,參數:執行緒[1]
主執行緒任務處理完畢
"""

import threading
import time

num = 0
def add():
    global num
    for i in range(10000000): # 一千萬次
        num += 1

def sub():
    global num
    for i in range(10000000):  # 一千萬次
        num -= 1

if __name__ == '__main__':
    start_time = time.time()

    add()
    sub()

    end_time = time.time()
    print("執行時間:",end_time - start_time)
    
# ==== 執行結果 ==== 三次採集

"""
大約在 1.3 - 1.4 秒
"""

# coding:utf-8

import threading
import time

num = 0
def add():
    global num
    for i in range(10000000):  # 一千萬次
        num += 1

def sub():
    global num
    for i in range(10000000):  # 一千萬次
        num -= 1

if __name__ == '__main__':
    start_time = time.time()

    t1 = threading.Thread(target=add,)
    t2 = threading.Thread(target=sub,)
    t1.start()
    t2.start()
    t1.join()
    t2.join()

    end_time = time.time()
    print(u"執行時間:",end_time - start_time)

# ==== 執行結果 ==== 三次採集

"""
大約 4 - 5 秒
"""