demo.py 文件源码

def multi_thread(func):
    @wraps(func)
    def wrapper(*args, **kwargs):
        url,start,end  = args
        jobs= []
        piece = (end-start)//THREAD_NUM
        for _ in range(THREAD_NUM):
            jobs.append(gevent.spawn(func,url,start,start+piece))
            start += piece
        gevent.joinall(jobs)
        # get  return value
        # result = []
        # for j in jobs:
        #     result.append(j.value)
        # return result
    return wrapper