from threading import Thread
import time
num = 0
def test1():
  global num
  for i in range(1000000):
    num += 1
  print("--test1--num=%d" % num)
def test2():
  global num
  for i in range(1000000):
    num += 1
  print("--test2--num=%d" % num)
if __name__ == '__main__':
  Thread(target=test1).start()
  Thread(target=test2).start()
  print("num = %d" % num)
"""
num = 134116
--test1--num=1032814
--test2--num=1166243
"""
          

            
from threading import Thread, Lock
import time
num = 0
def test1():
  global num
  # 上鎖
  mutex.acquire()
  for i in range(1000000):
    num += 1
  # 解鎖
  mutex.release()
  print("--test1--num=%d" % num)
def test2():
  global num
  mutex.acquire()
  for i in range(1000000):
    num += 1
  mutex.release()
  print("--test2--num=%d" % num)
start_time = time.time() # 開(kāi)始時(shí)間
# 創(chuàng)建一把互斥鎖，默認(rèn)沒(méi)有上鎖
mutex = Lock()
p1 = Thread(target=test1)
p1.start()
# time.sleep(3)  # 取消屏蔽之后 再次運(yùn)行程序，結(jié)果會(huì)不一樣，，，為啥呢？
p2 = Thread(target=test2)
p2.start()
p1.join()
p2.join()
end_time = time.time() # 結(jié)束時(shí)間
print("num = %d" % num)
print("運(yùn)行時(shí)間:%fs" % (end_time - start_time)) # 結(jié)束時(shí)間-開(kāi)始時(shí)間
"""
輸出結(jié)果：
--test1--num=1000000
--test2--num=2000000
num = 2000000
運(yùn)行時(shí)間:0.287206s
"""
          

            
from threading import Lock, Thread
from time import sleep
class Task1(Thread):
  def run(self):
    while True:
      # 判斷是否上鎖成功，返回值為bool類型
      if lock1.acquire():
        print("--task1--")
        sleep(0.5)
        lock2.release()
class Task2(Thread):
  def run(self):
    while True:
      if lock2.acquire():
        print("--task2--")
        sleep(0.5)
        lock3.release()
class Task3(Thread):
  def run(self):
    while True:
      if lock3.acquire():
        print("--task3--")
        sleep(0.5)
        lock1.release()

if __name__ == '__main__':  
  # 創(chuàng)建一把鎖
  lock1 = Lock()  
  # 創(chuàng)建一把鎖，并且鎖上
  lock2 = Lock()
  lock2.acquire()  
  # 創(chuàng)建一把鎖，并且鎖上
  lock3 = Lock()
  lock3.acquire()  
  t1 = Task1()
  t2 = Task2()
  t3 = Task3()  
  t1.start()
  t2.start()
  t3.start()
"""
--task1--
--task2--
--task3--
--task1--
--task2--
--task3--
--task1--
--task2--
...
"""
          

            
import threading
import time
from queue import Queue
class Producer(threading.Thread):
  def run(self):
    global queue
    count = 0
    while True:
      if queue.qsize() < 1000:
        for i in range(100):
          count += 1
          msg = "生成產(chǎn)品" + str(count)
          queue.put(msg)
          print(msg)
      time.sleep(0.5)
class Consumer(threading.Thread):
  def run(self):
    global queue
    while True:
      if queue.qsize() > 100:
        for i in range(3):
          msg = self.name + "消費(fèi)了" + queue.get()
          print(msg)
      time.sleep(0.5)
          

            
import threading
"""
?個(gè)ThreadLocal變量雖然是全局變量，但每個(gè)線程都只能讀寫??線程的獨(dú)
?副本，互不?擾。
"""
# 創(chuàng)建全局ThreadLocal對(duì)象:
local_school = threading.local()
def process_student():
  # 獲取當(dāng)前線程關(guān)聯(lián)的student:
  std = local_school.student
  print('Hello, %s (in %s)' % (std, threading.current_thread().name))
def process_thread(name):
  # 綁定ThreadLocal的student:
  local_school.student = name
  process_student()
t1 = threading.Thread(target=process_thread, args=('dongGe',), name="Thread-A")
t2 = threading.Thread(target=process_thread, args=('?王',), name="Thread-B")
t1.start()
t2.start()