'''
線程之間執(zhí)行是無(wú)序的，cpu調(diào)度哪個(gè)線程就執(zhí)行哪個(gè)線程
主線程會(huì)等待所有子線程結(jié)束之后再結(jié)束，設(shè)置守護(hù)線程可以實(shí)現(xiàn)當(dāng)主線程結(jié)束時(shí)子線程立馬結(jié)束
設(shè)置守護(hù)線程：1.threading.Thread(daemon=True),2.線程對(duì)象.setDaemon(True)
線程之間共享全局變量，存在資源競(jìng)爭(zhēng)問(wèn)題
'''
?
?
# 導(dǎo)入模塊（模塊名.py，包名init.py）
import threading
import time
?
?
def task1(count):
? ? # 獲取當(dāng)前線程對(duì)象
? ? # t=threading.current_thread()
? ? # print('Task1_name:',t.name)
? ? print()
? ? for i in range(count):
? ? ? ? print('Task A ',i+1)
? ? ? ? time.sleep(0.5)
?
def task2(content,count):
? ? print('Task2_name:', threading.current_thread().name)
? ? for i in range(count):
? ? ? ? print(f'{content}__Task B ',i+1)
? ? ? ? time.sleep(0.5)
?
?
if __name__ == '__main__':
?
? ? t1=threading.Thread(target=task1,name='T1',daemon=True,args=(5,))
? ? t2=threading.Thread(target=task2,name='T2',kwargs={'content':'Yes','count':5})
? ? # 設(shè)置守護(hù)主線程的第二種方式
? ? # t1.setDaemon(True)
? ? t2.setDaemon(True)
? ? t1.start()
? ? t1.join() ? # 阻塞函數(shù)，t1執(zhí)行完畢才會(huì)向下執(zhí)行
? ? t2.start()
? ? # t2.join()
? ? print('Main thread over')

'''
資源競(jìng)爭(zhēng)問(wèn)題：sum+=1執(zhí)行時(shí)大致會(huì)分為三步（取值、加1、寫回），可能剛執(zhí)行2步cpu就去切換到了另一個(gè)線程去執(zhí)行
解決辦法：1.使用join()方法來(lái)設(shè)置線程同步（效率不高），2.加鎖(可以保證同一時(shí)刻只有一個(gè)線程在執(zhí)行)
'''
?
import threading
import time
?
?
sum=0
lock=threading.Lock()
?
def add_num1():
? ? global sum
? ? for i in range(1000000):
? ? ? ? # lock.acquire() ? ?# 加鎖
? ? ? ? sum+=1
? ? ? ? # lock.release() ? ?# 解鎖
? ? print(f'{threading.current_thread().name}的計(jì)算結(jié)果是{sum}')
?
?
def add_num2():
? ? global sum
? ? for i in range(1000000):
? ? ? ? # lock.acquire()
? ? ? ? sum+=1
? ? ? ? # lock.release()
? ? print(f'{threading.current_thread().name}的計(jì)算結(jié)果是{sum}')
?
if __name__ == '__main__':
? ? t1=threading.Thread(target=add_num1)
? ? t2=threading.Thread(target=add_num2)
? ? t1.start()
? ? # 設(shè)置阻塞函數(shù)，設(shè)置線程同步
? ? t1.join()
? ? t2.start()
? ? print(f'Main的sum值是{sum}')