python,信号量,semaphore

import threading,time
class MyThread(threading.Thread):
    def __init__(self,name):
        threading.Thread.__init__(self)
        self.name = name
    def run(self):
        semaphore.acquire()
        print(self.name)
        time.sleep(3)
        semaphore.release()

if __name__ == "__main__":
    semaphore = threading.BoundedSemaphore(5)
    for i in range(40):
        t = MyThread(‘Alex‘)
        t.start()

这段代码运行后,通过semaphore实现了同时可以允许5个线程同步运行,每隔3秒显示5个‘Alex‘