在子进程或类似于使用concurrent.futures的线程中运行协同程序和函数。
aplex的Python项目详细描述
Aplex
aplex是一个python库，用于将asyncio与 多处理和线程。
- Aplex帮助您在其他进程中运行协同程序和函数 或异步线程。
- aplex提供了一个类似于标准库
concurrent.futures的用法， 这对你来说很熟悉，也很直观。 - 如果需要，aplex允许您以简单的方式进行负载平衡。
安装
对于一般用户，使用包管理器pip来 安装Aplex。
pip install aplex
对于贡献者，请使用pipenv安装：
git clone https://github.com/lunluen/aplex.git
cd aplex
pipenv install --dev
或使用设置工具
git clone https://github.com/lunluen/aplex.git
cd aplex
python setup.py develop
用法
要知道的定义：
A
workis acallableyou want to run with asyncio and multiprocessing or threading. It can be a coroutine function or just a function.
在下面的例子中，work是协程函数demo。
提交
您可以提交您的工作，例如：
importaiohttpfromapleximportProcessAsyncPoolExecutorasyncdefdemo(url):asyncwithaiohttp.request('GET',url)asresponse:returnresponse.statusif__name__=='__main__':pool=ProcessAsyncPoolExecutor(pool_size=8)future=pool.submit(demo,'http://httpbin.org')print('Status: %d.'%future.result())
注意：如果您在windows上运行python，if __name__ == '__main__':
是必要的。这就是多处理的设计。
结果：
Status: 200地图
对于多个作品，请尝试map：
iterable=('http://httpbin.org'for__inrange(10))forstatusinpool.map(demo,iterable,timeout=10):print('Status: %d.'%status)
等待结果
允许使用已存在的循环等待结果。很简单。只需将关键字参数awaitable设置为True！
例如：
pool=ProcessAsyncPoolExecutor(awaitable=True)
然后
future=pool.submit(demo,'http://httpbin.org')status=awaitfuture
地图怎么样？
asyncforstatusinpool.map(demo,iterable,timeout=10):print('Status: %d.'%status)
负载平衡
在aplex中，每个worker都是计算机上的进程或线程。也就是说，它们具有相同的计算能力。 但是，您的作品可能有不同的工作负载。那么你需要一个负载均衡器。
aplex提供了一些有用的负载平衡器。它们是RoundRobin、Random和Average。默认值是RoundRobin。
只需在construction关键字参数中设置此参数：
fromaplex.load_balancersimportAverageif__name__=='__main__':pool=ProcessAsyncPoolExecutor(load_balancer=Average)
完成。很容易。：100:
您还可以自定义一个：
fromapleximportLoadBalancerclassMyAwesomeLoadBalancer(LoadBalancer):def__init__(*args,**kwargs):super().__init__(*args,**kwargs)# Don't forget this.awesome_attribute='Hello Aplex!'defget_proper_worker(self):the_poor_guy=self.workers[0]returnthe_poor_guy
Worker loop factory
By the way, if you think the build-in asyncio loop is too slow:
^{pr 12}$Like this?
Scroll up and click ^{
Any feedback?
Feel free to open a issue (just don't abuse it).
Or contact me: ^{
Anything about aplex is welcome, such like bugs, system design, variable naming, even English grammer of docstrings!
How to contribute
Contribution are welcome.
Asking and advising are also kinds of contribution.
Please see CONTRIBUTING.md
许可证
欢迎加入QQ群-->： 979659372
