1 import time
 2 import threading
 3 lock = threading.BoundedSemaphore(3)#一次放三个(一次只通行三个)
 4 def func(arg):
 5     lock.acquire()
 6     time.sleep(1)
 7     print(arg)
 8     lock.release()
 9 for i in range(20):
10     t = threading.Thread(target=func, args=(i,))
11     t.start()

 1 lock = threading.Condition()
 2 def func(arg):
 3     print('线程进来了')
 4     lock.acquire()
 5     lock.wait() # 加锁这个特殊需要等待参数传递
 6     print(arg)
 7     time.sleep(1)
 8     lock.release()
 9 for i in range(10):
10     t =threading.Thread(target=func,args=(i,))
11     t.start()
12 while True:
13     inp = int(input('>>>'))
14     lock.acquire()
15     lock.notify(inp)#加的控制次数的 这个是特殊的
16     lock.release()

 1 import time
 2 import threading
 3
 4 lock = threading.Event()
 5
 6 def func(arg):
 7     print('线程来了')
 8     lock.wait() # 加锁：红灯
 9     print(arg)
10 for i in range(10):
11     t =threading.Thread(target=func,args=(i,))
12     t.start()
13 input(">>>>")
14 lock.set() # 绿灯
15 lock.clear() # 再次变红灯
16 for i in range(10):
17     t =threading.Thread(target=func,args=(i,))
18     t.start()
19 input(">>>>")
20 lock.set()

 1 import time
 2 import threading
 3 v = threading.local()
 4 def func(arg):
 5     # 内部会为当前线程创建一个空间用于存储：phone=自己的值
 6     v.phone = arg
 7     time.sleep(2)
 8     print(v.phone,arg) # 去当前线程自己空间取值
 9 for i in range(10):
10     t =threading.Thread(target=func,args=(i,))
11     t.start()

1 from concurrent.futures import ThreadPoolExecutor
2 import  time
3 def func(a1,a2):
4     time.sleep(5)
5     print(a1,a2)
6 a=ThreadPoolExecutor(4)#实例化对象让其限制次数
7 for i  in  range(40):
8     a.submit(func,i,15)

 1 import time
 2 import threading
 3 import queue
 4 q=queue.Queue()#实例化对象
 5 def mk(id):
 6     while 1:
 7         time.sleep(3)
 8         q.put("布加迪")#首先进入q.put
 9         print("师傅%s 生产了一个布加迪"% id)
10 for i  in  range(1,3):
11     t=threading.Thread(target=mk,args=(i,))
12     t.start()
13 def et(id):
14     while 1:
15         time.sleep(1)
16         v1=q.get()#然后冲进去
17         print("连达%s 吃了一个布加迪"% id)
18 for i  in  range(1,6):
19     t1=threading.Thread(target=et,args=(i,))
20     t1.start()