Python線程編程之Thread詳解

from threading import Thread
t = Thread()
功能: 創建線程對象
參數: target 綁定線程函數
	args 元組 給線程函數位置傳參
	kwargs 字典 給線程函數鍵值傳參

t.start()

"""
thread1.py 線程基礎使用
步驟:
1. 封裝線程函數
2.創建線程對象
3.啟動線程
4.回收線程
"""
import os
from threading import Thread
from time import sleep
a = 1
# 線程函數
def music():
    for i in range(3):
        sleep(2)
        print('播放:黃河大合唱 %s' % os.getpid())
    global  a
    print("a,",a)
    a = 1000
# 創建線程對象
t = Thread(target=music)
# 啟動線程
t.start()
for i in range(3):
    sleep(1)
    print('播放:beauty love %s' % os.getpid())
# 回收線程
t.join()
print('程序結束')
print("a,", a)

"""
thread3.py
線程屬性演示
"""
from threading import Thread
from time import sleep

def fun():
    sleep(3)
    print('線程屬性測試')

t = Thread(target=fun, name='ceshi')
# 主線程退出分支線程也退出 必須在start前使用 與join 沒有意義
t.setDaemon(True)
t.start()
print(t.getName())
t.setName('Tedu')
print('is alive:', t.is_alive())
print('daemon', t.daemon)

"""
自定義線程類例子
"""
from threading import Thread

# 自定義線程類
class ThreadClass(Thread):
    # 重寫父類 init
    def __init__(self, *args, **kwargs):
        self.attr = args[0]
        # 加載父類init
        super().__init__()
    # 假設需要很多步驟完成功能
    def f1(self):
        print('1')
    def f2(self):
        print(2)
    # 重寫run 邏輯調傭
    def run(self):
        self.f1()
        self.f2()

t = ThreadClass()
t.start()
t.join()

from threading import Thread
from time import sleep, ctime

class MyThread(Thread):
    def __init__(self, group=None, target=None, name=None,
                 args=(), kwargs=None, *, daemon=None):
        super().__init__()
        self.fun = target
        self.args = args
        self.kwargs = kwargs
    def run(self):
        self.fun(*self.args, **self.kwargs)

def player(sec, song):
    for i in range(3):
        print("Playing %s : %s" % (song, ctime()))
        sleep(sec)

t = MyThread(target=player, args=(3,), kwargs={'song': '量量'})
t.start()
t.join()

## 9.線程同步互斥方法

from threading import Event
# 創建線程event對象
e = Event()
# 阻塞等待e被set
e.wait([timeout]) 
# 設置e, 使wait結束阻塞
e.set() 
# 使e回到未被設置狀態
e.clear() 
# 查看當前e是否被設置
e.is_set() 

"""
event 線程互斥方法演示
"""
from threading import Event, Thread
s = None  # 用於通信
e = Event()
def yzr():
    print('楊子榮前來拜山頭')
    global s
    s = '天王蓋地虎'
    e.set() #操作完共享資源 e設置

t = Thread(target=yzr)
t.start()
print('說對口令就是自己人')
e.wait() #阻塞等待 e.set()
if s == '天王蓋地虎':
    print('寶塔鎮河妖')
    print('確認過眼神,你是對的人')
    e.clear()
else:
    print('打死他...')
t.join()
print('程序結束')

from threading import Lock
lock = Lock()創建鎖對象
lock.acquire() 上鎖 如果lock已經上鎖再調用會阻塞
lock.release() 解鎖
with lock: 上鎖
....
....
with 代碼塊解鎖自動解鎖

"""
thread_lock
線程鎖演示
"""
from threading import Thread, Lock
a = b = 0
lock = Lock()

def value():
    while True:
        # 上鎖
        lock.acquire()
        print('a=%d,b=%d' % (a, b)) if a != b else print('a不等於b')
        # 解鎖
        lock.release()

t = Thread(target=value)
t.start()
while True:
    # with 開始上鎖
    with lock:
        a += 1
        b += 1
    # with 解鎖 自動解鎖
t.join()
print('程序結束')

from time import sleep
from threading import Thread, Lock

# 交易類
class Account:
    def __init__(self, _id, balance, lock):
        # 用戶
        self._id = _id
        # 存款
        self.balance = balance
        # 鎖
        self.lock = lock
    # 取錢
    def withdraw(self, amount):
        self.balance -= amount
    # 存錢
    def deposit(self, amount):
        self.balance += amount
    # 餘額
    def get_balance(self):
        return self.balance

Tom = Account('Tom', 5000, Lock())
Alex = Account('Alex', 8000, Lock())

def transfer(from_, to, amount):
    # 鎖住自己賬戶
    if from_.lock.acquire():
        # 賬戶減少
        from_.withdraw(amount)
        sleep(0.5)
        if to.lock.acquire():
            to.deposit(amount)
            to.lock.release()
        from_.lock.release()
    print('轉賬完成 %s給%s轉賬%d' % (from_._id, to._id, amount))

# transfer(Tom, Alex, 1000)
t1 = Thread(target=transfer, args=(Tom, Alex, 2000))
t2 = Thread(target=transfer, args=(Alex, Tom, 3500))
t1.start()
t2.start()
t1.join()
t2.join()
print('程序結束')