Python-сообщество

class CatParser(threading.Thread):
    def run(self):
        # что-то долго делает

class Parser(object):
    def start(self):
        for i in xrange(100):  # типа надо спарсить 100 категорий на сайте
            cp = CatParser(i)
            cp.start()
            while len(threading.enumerate()) > 10:  # типа ограничение на 10 потоков
                time.sleep(1)
        while len(threading.enumerate()) > 1:  # типа ждем, пока завершатся последние потоки
            time.sleep(1)
        print "Готово"

            while len(threading.enumerate()) > 10:  # типа ограничение на 10 потоков
                time.sleep(1)
        while len(threading.enumerate()) > 1:  # типа ждем, пока завершатся последние потоки
            time.sleep(1)

from threading import Semaphore, Event

class CatParser(threading.Thread):
    def __init__(self, sem):
        super(CatParser, self).__init__()
        self._sem = sem

    def run(self):
        try:
            pass
        finally:
            self._sem.release()

class Parser(object):

    def __init__(self):
        self._sem = Semaphore(10)
        self._stopEvent = Event()

    def stop(self):
        self._stopEvent.set()
        self._sem.release()

    def start(self):
        threads = []
        for i in xrange(100):
            self._sem.acquire()
            if self._stopEvent.isSet():
                break
            cp = CatParser(self._sem)
            cp.start()
            threads.append(cp)
        for cp in threads:
            cp.join(10)
        print "Готово"