Ограниченный семафорный предел до 10 - PullRequest
Новая
       14

Ограниченный семафорный предел до 10

0 голосов
/ 20 мая 2019

У меня проблема с ограничением потоков до 10 или 100. Я читал и увидел, что с помощью функции alf можно ограничить потоки, но это не работает. Я получаю ошибку
ошибка: не могу начать новую тему: 

if __name__ == '__main__':

    threadLimiter = threading.BoundedSemaphore(100)
    threadLimiter.acquire()
    try:
        for dirName, subdirList, fileList in os.walk(location):
            for fname in fileList:
                file_name = os.path.join(dirName, fname)
                thread = threading.Thread(target=run, args=(file_name,))
                thread.start()
    finally:
        threadLimiter.release()
...