concurrent.py 文件源码

def __init__(self, name, thread_num, pool=None,
                 pool_type=ThreadPoolExecutor,
                 start_point=None, end_point=None, context_factory=Context,
                 extends_listeners=False, listeners=None, goto=None):
        """
        :param name Fork????
        :param thread_num ??????????
        :param pool ??????????
        :param pool_type ???????pool?????????????????
        :param start_point ????????
        :param end_point ????????
        :param context_factory ?????
        :param extends_listeners ??????????????
        :param listeners ????????????
        :param goto ???join???????????????????????join??
        """
        if self._listeners is None:
            self._listeners = []