concurrent.py 文件源码

def __init__(
            self, name, sub_jobs, pool=None,
            pool_type=ThreadPoolExecutor, join=None,
            error_action="stop", error_handler=None, error_default_value=None,
            goto=None):
        """
        :param name ??????
        :param sub_jobs ?????
        :param pool ????????None??????pool_type??????pool
        :param pool_type ??????pool?None???????????pool
        :param join ????????????context????????????????
        :param error_action ??????????stop????????????
                            ???continue??????????????
        :param error_handler ?????????continue?????????error listener
                             ????????error_handler????
        :param error_default_value ???continue?????????????????
        :param goto ?????????
        """
        if self._error_action != "stop" and self._error_action != "continue":
            raise InvalidArgumentException(u"?????????stop??continue??")