Python线程——信号量（Semaphore）、队列（Queue）

信号量（Semaphore）

之前讲的线程锁（互斥锁）同时只允许一个线程更改数据，而Semaphore是同时允许一定数量的线程更改数据，比如厕所有4个坑，那最多只允许4个人上厕所，后面的人只能等里面有人出来了才能再进去。说白了就是在同一时间，可以只允许设定的数量的线程去执行。

import time
from threading import Semaphore, Thread


def func(sem, a, b):
    sem.acquire()
    time.sleep(1)
    print(a + b)
    sem.release()


sem = Semaphore(4)
for i in range(10):
    t = Thread(target=func, args=(sem, i, i + 5))
    t.start()

队列（Queue）

queue队列：使用import queue，用法与进程Queue一样

####class queue.Queue(maxsize=0) 先进先出

import queue

q=queue.Queue()
q.put('first')
q.put('second')
q.put('third')

print(q.get())
print(q.get())
print(q.get())

# 执行结果
结果(先进先出):
first
second
third

class queue.LifoQueue(maxsize=0) 后进先出

import queue

q=queue.LifoQueue()
q.put('first')
q.put('second')
q.put('third')

print(q.get())
print(q.get())
print(q.get())

# 执行结果
结果(后进先出):
third
second
first

class queue.PriorityQueue(maxsize=0)

根据优先级来取数据。存放数据的格式 : Queue.put((priority_number,data))，priority_number越小，优先级越高，data代表存入的值

import queue
q = queue.PriorityQueue()
q.put((1, "d1"))
q.put((-1, "d2"))
q.put((6, "d3"))
print(q.get())
print(q.get())
print(q.get())
 
#执行结果
(-1, 'd2')
(1, 'd1')
(6, 'd3')

注意：maxsize代表这个队列最大能够put的长度