網站首頁 編程語言 正文
python中multiprosessing模塊的Pool類中的apply函數和apply_async函數的區別_python
作者:??HZ在掘金???? ? 更新時間: 2022-08-03 編程語言1、二者的區別
apply():?
- 非異步(子進程不是同時執行的),堵塞主進程。
- 它的非異步體現在:一個一個按順序執行子進程, 子進程不是同時執行的。
- 它的堵塞體現在:等到全部子進程都執行完畢后,繼續執行apply()后面主進程的代碼。
apply_async():
- 異步的,不堵塞主進程。
- 它的異步體現在:子進程之間是同時執行的。子進程被分配到不同的cpu上被執行。
- 它的非堵塞體現在:他不會等待子進程完全執行完畢, 主進程會繼續執行, 他會根據系統調度來進行進程之間的切換。如果想堵塞主要進程,需要用.join()函數來堵塞主進程。
2、apply()
import time
import multiprocessing
def doIt(num):
print("Process num is : %s" % num)
time.sleep(1)
print('process %s end' % num)
if __name__ == '__main__':
print('mainProcess start')
#記錄一下開始執行的時間
start_time = time.time()
# 創建一個進程池,允許最多可以有3個子進程可以同時執行。
pool = multiprocessing.Pool(3)
print('Child start')
for i in range(3):
pool.apply(doIt,[i])
print('mainProcess done time:%s s' % (time.time() - start_time))
結果如下所示:
從結果中我們可以看到,主進程開始執行之后, 創建的三個子進程也隨即開始執行, 后面的主進程被阻塞。而且三個子進程是一個接一個按順序地執行, 等到子進程全部執行完畢之后, 后面的主進程才會繼續執行, 打印出最后一句。所以,apply()函數果然是可以堵塞主進程,而且是非異步的。
3、apply_async()
顧名思義,async就是異步的意思。接下來是使用apply_async(), 只需要把上面的代碼使用 apply()的地方改成apply_async() 即可, 代碼不再貼上
我們來看看運行結果, 可以看出來, 截圖的第一句是上一個程序(也就是apply()函數)的執行消耗時間,?
最后一句是使用apply_async()所消耗的時間,?在這里, 主進程沒有被阻塞, 驗證了apply_async()是非阻塞主進程的, 子進程沒有執行, 驗證了他是根據系統調度完成的,
為什么會這樣呢?
原因是, 進程的切換時操作系統控制的, 我們首先運行的是主進程, 而CPU運行得又很快, 快到還沒等系統調度到子線程, 主進程就已經運行完畢了, 并且退出程序. 所以子進程就沒有運行了.
那么我們在使用apply_async()函數是不是就不能執行子進程呢?肯定可以啊!!!小老弟,想啥呢??還記得join()的作用嗎?他可以阻塞主進程, 等待所有子進程結束之后再運行,join()就是告訴主進程老子要運行子進程了,你先等等。?
import time
import multiprocessing
def doIt(num):
print("Process num is : %s" % num)
time.sleep(1)
print('process %s end' % num)
if __name__ == '__main__':
print('mainProcess start')
#記錄一下開始執行的時間
start_time = time.time()
# 創建一個進程池,最大允許3個子進程同時執行。
pool = multiprocessing.Pool(3)
print('Child start')
for i in range(3):
pool.apply_async(doIt,[i])
pool.close()
pool.join()
print('mainProcess done time:%s s' % (time.time() - start_time))
結果如下所示:
我們看看加入這兩句的運行結果, 我們可以看到即使是使用了非阻塞主進程的apply_async() 也能讓子進程運行完畢之后再執行主進程了。
CPU在執行第一個子進程的時候, 還沒等第一個子進程結束, 系統調度到了按順序調度到了第二個子進程,?以此類推, 一直調度運行子進程, 一個接一個地結束子進程的運行, 最后運行主進程,?而且我們可以看到使用apply_async()的執行效力會更高,看一下他們各自執行結果最后一句的執行消耗時間就知道了, 這也是官方推薦我們使用apply_async()的主要原因吧
原文鏈接:https://juejin.cn/post/7084059182315339790
相關推薦
- 2022-07-02 C語言由淺入深理解指針_C 語言
- 2023-03-26 Redis?分片集群的實現_Redis
- 2022-03-03 MacOS git pull / git clone Enter passphrase for ke
- 2024-03-08 Spring bean的實例化方式之靜態工廠和實例工廠的區別
- 2022-06-27 教你用Python按順序讀取文件夾中文件_python
- 2023-04-24 Python中__init__的用法和理解示例詳解_python
- 2022-08-07 Python繪制交通流折線圖詳情_python
- 2022-07-29 Linux文件系統介紹_linux shell
- 最近更新
-
- window11 系統安裝 yarn
- 超詳細win安裝深度學習環境2025年最新版(
- Linux 中運行的top命令 怎么退出?
- MySQL 中decimal 的用法? 存儲小
- get 、set 、toString 方法的使
- @Resource和 @Autowired注解
- Java基礎操作-- 運算符,流程控制 Flo
- 1. Int 和Integer 的區別,Jav
- spring @retryable不生效的一種
- Spring Security之認證信息的處理
- Spring Security之認證過濾器
- Spring Security概述快速入門
- Spring Security之配置體系
- 【SpringBoot】SpringCache
- Spring Security之基于方法配置權
- redisson分布式鎖中waittime的設
- maven:解決release錯誤:Artif
- restTemplate使用總結
- Spring Security之安全異常處理
- MybatisPlus優雅實現加密?
- Spring ioc容器與Bean的生命周期。
- 【探索SpringCloud】服務發現-Nac
- Spring Security之基于HttpR
- Redis 底層數據結構-簡單動態字符串(SD
- arthas操作spring被代理目標對象命令
- Spring中的單例模式應用詳解
- 聊聊消息隊列,發送消息的4種方式
- bootspring第三方資源配置管理
- GIT同步修改后的遠程分支