def METHOD_NAME(cls, name, timeout):
    tpool = cls._tpool[name]
    for t in tpool:
        t.METHOD_NAME(timeout)
        if t.isAlive():
            log.warn('Thread %s did not shutdown cleanly' % t.ident)