# -*- coding: utf-8 -*-from threadpool import makeRequests, ThreadPoolimport timefrom multiprocessing import Process

class Finish(SyntaxWarning):    pass

class PauseInfo(SyntaxWarning):    passpause_num = 0

def func(para):    if para == pause_num:        print('start for %d and wait %ds' % (para, 4))        time.sleep(4)        print('error bcs ',para)        return False    if para % 2 == 0:        print('start for %d and wait %ds' % (para, para))        time.sleep(para)        print('stop for', para)        return True    while True:        print('continue for', para)        time.sleep(para)

def callback(request, result):    if result:        raise Finish    else:        raise PauseInfo

def main_thread(paras):    pool = ThreadPool(10)    requests = makeRequests(callable_=func, args_list=paras, callback=callback)    [pool.putRequest(req) for req in requests]    while True:        try:            pool.wait()        except Finish as e:            raise SystemExit        except PauseInfo as e:            print('Pause bcs %d but will continue' % pause_num)        except Exception as e:            print('Unknown error so will quit')            raise SystemExit

if name == 'main':    while True:        s = input('Input number list to test and any other word to quit')        paras = []        for para in s:            if para.isnumeric():                paras.append(int(para))            else:                break        try:            thread_test = Process(target=main_thread, args=(paras,))            thread_test.start()            thread_test.join(timeout=20)        except TimeoutError as e:            print('task timeout')        except Exception as e:            print('unknow error:',e)