python 控制线程最大数

在Python中，可以使用threading模块中的Semaphore类或BoundedSemaphore类来限制线程的最大数量。Semaphore类是一个计数器，用于控制对共享资源的访问。当一个线程需要访问共享资源时，它必须先获得一个信号量，如果当前可用的信号量数量为0，则线程将被阻塞，直到有一个信号量可用为止。当线程完成对共享资源的访问后，它必须释放信号量，以便其他线程可以访问该资源。BoundedSemaphore类与Semaphore类类似，但是它可以防止信号量数量超过初始值。在使用Semaphore类或BoundedSemaphore类时，需要先创建一个Semaphore对象或BoundedSemaphore对象，并指定最大线程数，然后在每个线程中使用acquire()方法获取信号量，使用release()方法释放信号量。下面是一个使用Semaphore类控制线程最大数的示例代码：

import threading
class MyThread(threading.Thread):
    def __init__(self, sem, num):
        threading.Thread.__init__(self)
        self.sem = sem
        self.num = num

    def run(self):
        self.sem.acquire()
        print("Thread %d is running" % self.num)
        self.sem.release()

if __name__ == '__main__':
    sem = threading.Semaphore(5) # 最大线程数为5
    for i in range(10):
        t = MyThread(sem, i)
        t.start()

上述代码中，创建了一个Semaphore对象sem，最大线程数为5。在每个线程中，使用acquire()方法获取信号量，使用release()方法释放信号量。当可用信号量数量为0时，线程将被阻塞，直到有一个信号量可用为止。运行上述代码后，可以看到最多同时有5个线程在运行。