Skip to content

Latest commit

 

History

History

这个里面是实现各种并发池,框架使用不同种类的并发池从而使用不同的并发模式来执行函数任务。

'''
各种并发池的api都实现了submit,然后就自动执行函数。类似concurrent.futures包的api
'''


def fun(x):
    print(x)

pool = Pool(50)
pool.submit(fun,1)
实现的池包括


gevent

eventlet

asyncio

custom_threadpool_executor.py 可变有界线程池,可变是指线程池嫩自动扩大,最厉害的是能自动缩小线程数量,官方不具备此功能。