一日一技:从Python源代码里面证明你的猜想

简介: 一日一技:从Python源代码里面证明你的猜想

摄影:产品经理

看过《Python爬虫开发 从入门到实战》的同学,应该对 multiprocessing这个模块比较熟悉,在书上我使用这个模块通过几行代码实现了一个简单的多线程爬虫:

import requests
from multiprocessing.dummy import Pool
def get(url):
    print(requests.get(url).text, '\n')
url_list = [
    'http://exercise.kingname.info/exercise_middleware_ip/1',
    'http://exercise.kingname.info/exercise_middleware_ip/2',
    'http://exercise.kingname.info/exercise_middleware_ip/3',
    'http://exercise.kingname.info/exercise_middleware_ip/4'
]
pool = Pool(3)
result = pool.map(get, url_list)

运行效果如下图所示:

(没有看过我的书的人可能会质疑, multiprocessing不是多进程模块吗?为什么你说是多线程?看过书的读者不会有这个疑惑,因为我在书上解释过原因)

现在,你有一个函数,没有任何参数,但是仍然想让他使用多线程,于是模仿上面的代码,你这样写:

import requests
from multiprocessing.dummy import Pool
def test():
    print('函数运行成功!')
pool = Pool(3)
result = pool.map(test, ())

运行以后发现,什么都没有打印出来,也就是说 test()函数根本没有运行。

如果你强行给函数添加一个没用的参数,结果又正常了:

import requests
from multiprocessing.dummy import Pool
def test(_):
    print('函数运行成功!\n')
pool = Pool(3)
result = pool.map(test, (0, ) * 3)

运行效果如下图所示

所以你隐隐觉得,如果 pool.map的第二个参数是空的可迭代对象,那么函数就不会运行。

(当然,使用过Python自带的 map函数的同学肯定直接就知道这一点,不过本文依然使用它来做例子,用于说明阅读源代码的方法。)

为了证明这一点,我们打开 Python安装目录/Lib/multiprocessing/pool.py文件,在里面找到 defmap(self,func,iterable,chunksize=None)这一行,如下图所示:

(本文使用Python 3.7.3作为演示,如果你的Python版本不是3.7.3,那么代码可能会有一些区别)

从代码里面可以看到,这里调用了 self._map_async(),传入参数,获得返回值以后,再调用了返回值的 .get()方法。

所以继续看 self._map_async()方法:

在这个方法里面,如果我们传入的可迭代对象为空,那么也就是这里的参数 iterable为空。于是

chunksize = 0
len(iterable) = 0

map的第一个参数,函数名被传入了下面这一行代码中:

  1. task_batches =Pool._get_tasks(func, iterable, chunksize)

查看 Pool._get_tasks这个静态方法,可以看到:

由于这里的参数 it就是空的可迭代对象, size为0,所以下面这一行代码返回空元组:

tuple(itertools.islice(it, size))

这个生成器直接就会结束,最后一行 yield(func,x)根本不会执行。

再来看代码里使用 MapResult类初始化了一个result对象,然后返回这个对象。

再进入到 MapResult类里面,如下图所示:

在这段 __init__中,可以得到如下几个参数的值:

self._success = True
self._value = []  # 因为[None] * 0 结果为[]
self._event.set()

关于 self._event.set()请看我的另一篇公众号:

一日一技:Python多线程的事件监控

返回的result对象的 .get()方法被调用了。但是由于 MapResult本身没有 .get()方法,于是变为调用父类 ApplyResult.get()方法。

再进入 ApplyResult里面,查看 .get()方法:

由于前面调用了 self._event.set(),所以这里的 self.ready()结果为 True,而由于 self._success在上面为 True,所以这里直接 returnself._value。也就是返回一个空的列表。

到此为止,在 pool.map的第二个参数为空的可迭代对象时,所有的流程就走完了。整个过程中,没有涉及到任何调用 func的过程。所以原有的函数不会被执行。

最后说说为什么在本文中我们看的是 multiprocessingPool类里面的 map方法,而不是 multiprocessing.dummyPool类里面的 map方法。

这是因为,如果我们打开 Python安装路径/Lib/multiprocessing/dummy/__init__.py,我们就可以看到,它的 Pool实际上返回的是一个 ThreadPool对象。而这个对象的代码,实际上也在 Python安装路径/Lib/multiprocessing/pool.py文件中,并且继承自 Pool类。所以他们的 map方法的代码是完全一样的。


目录
相关文章
|
8天前
|
Unix Linux Shell
Sphinx是一个Python文档生成工具,它可以解析reStructuredText或Markdown格式的源代码注释,并生成多种输出格式,如HTML、LaTeX、PDF、ePub等。
Sphinx是一个Python文档生成工具,它可以解析reStructuredText或Markdown格式的源代码注释,并生成多种输出格式,如HTML、LaTeX、PDF、ePub等。
|
2月前
|
搜索推荐 算法 前端开发
各种排序算法及Python源代码
各种排序算法及Python源代码
38 3
|
2月前
|
数据采集 前端开发 小程序
分享76个Python管理系统源代码总有一个是你想要的
分享76个Python管理系统源代码总有一个是你想要的
109 3
|
2月前
|
数据采集 自然语言处理 监控
分享53个杂七杂八的Python源代码总有一个是你想要的
分享53个杂七杂八的Python源代码总有一个是你想要的
35 1
|
2月前
|
数据采集 监控 搜索推荐
分享66个Python管理系统源代码总有一个是你想要的
分享66个Python管理系统源代码总有一个是你想要的
90 1
|
2月前
|
前端开发 搜索推荐 关系型数据库
分享32个Python管理系统源代码总有一个是你想要的
分享32个Python管理系统源代码总有一个是你想要的
56 1
|
2月前
|
前端开发 NoSQL Docker
分享46个Python博客源代码总有一个是你想要的
分享46个Python博客源代码总有一个是你想要的
95 1
|
2月前
|
机器学习/深度学习 人工智能 算法
分享135个游戏Python源代码总有一个是你想要的
分享135个游戏Python源代码总有一个是你想要的
182 1
|
2月前
|
JavaScript 前端开发 开发工具
Python之JavaScript逆向系列——3、浏览器的开发工具——源代码的使用
Python之JavaScript逆向系列——3、浏览器的开发工具——源代码的使用
34 0
|
2月前
|
数据采集 自然语言处理 搜索推荐
分享74个Python管理系统源代码总有一个是你想要的
分享74个Python管理系统源代码总有一个是你想要的
109 0