Python并發編程之concurrent.futures

2019獨角獸企業重金招聘Python工程師標準>>> hot3.png

????concurrent.futures模塊提供了一個異步執行callables的高級接口。 可以使用ThreadPoolExecutor和ProcessPoolExecutor。 兩者都繼承了相同的接口,該接口由抽象的Executor類定義。

????一個抽象類,提供異步執行調用的方法。 它不應該直接使用,而是通過其具體的子類。

? ? submit (fn,?*args,?**kwargs):提交執行的函數并獲取一個Future對象,例如:

with ThreadPoolExecutor(max_workers=1) as executor:future = executor.submit(pow, 323, 1235)print(future.result())

????ThreadPoolExecutor:是Executor子類,它使用一個線程池來異步執行調用。concurrent.futures.ThreadPoolExecutor(max_workers=None,?thread_name_prefix='',?initializer=None,?initargs=())。例如:

import concurrent.futures
import urllib.request
URLS = ['http://www.foxnews.com/','http://www.cnn.com/','http://europe.wsj.com/','http://www.bbc.co.uk/','http://some-made-up-domain.com/']# Retrieve a single page and report the URL and contents
def load_url(url, timeout):with urllib.request.urlopen(url, timeout=timeout) as conn:return conn.read()# We can use a with statement to ensure threads are cleaned up promptly
with concurrent.futures.ThreadPoolExecutor(max_workers=5) as executor:# Start the load operations and mark each future with its URLfuture_to_url = {executor.submit(load_url, url, 60): url for url in URLS}for future in concurrent.futures.as_completed(future_to_url):url = future_to_url[future]try:data = future.result()except Exception as exc:print('%r generated an exception: %s' % (url, exc))else:print('%r page is %d bytes' % (url, len(data)))

????ProcessPoolExecutor:concurrent.futures.ProcessPoolExecutor(max_workers=None,?mp_context=None,?initializer=None,?initargs=()):使用如下:

import concurrent.futures
import math
executor = ProcessPoolExecutor(max_workers=5)def is_prime(n):if n % 2 == 0:return Falsesqrt_n = int(math.floor(math.sqrt(n)))for i in range(3, sqrt_n + 1, 2):if n % i == 0:return Falsereturn Truedef main():for i in range(10):
????????future = executor.submit(is_prime, n)if __name__ == '__main__':main()

????Future: Future類封裝了可調用的異步執行。 該實例由Executor.submit()創建。

轉載于:https://my.oschina.net/u/3316387/blog/2996178

本文來自互聯網用戶投稿,該文觀點僅代表作者本人,不代表本站立場。本站僅提供信息存儲空間服務,不擁有所有權,不承擔相關法律責任。
如若轉載,請注明出處:http://www.pswp.cn/news/252692.shtml
繁體地址,請注明出處:http://hk.pswp.cn/news/252692.shtml
英文地址,請注明出處:http://en.pswp.cn/news/252692.shtml

如若內容造成侵權/違法違規/事實不符,請聯系多彩編程網進行投訴反饋email:809451989@qq.com,一經查實,立即刪除!

相關文章

1.3鏈表

鏈表的物理存儲結構是用一組地址任意的存儲單元存儲數據的。不像順序表占據連續的一段內存空間,而是將存儲單元分散在內存的任意地址上。 鏈表結構中,每個數據元素記錄都存放到鏈表的一個節點(node)中,而每個節點之間由…

移植opencv3.20到3556AV100

1.移植環境: Ubuntu14.04 arm-hisiv200-linux-opencv3.20 下載地址 2.移植步驟: 1)安裝cmake-gui 2)新建一個opencv目錄存放opencv-3.2.0.zip,并解壓 擊Browse Source選擇~/hisi/opencv/opencv-3.2.0 點擊Brow…

ngnix 詳解

4 Nginx的rpm軟件包安裝 4.1 安裝包在位置 D:\講課內容--\新巴巴運動網\nginx高并發解決\nginx安裝包 4.2 此種安裝方式不用安裝gcc等編譯工具 4.3 安裝命令如下 rpm –ivh nginx 5 配置虛擬主機 5.1 什么是虛擬主機 虛擬主機是一種特殊的軟硬件技術,它可以將網絡上…

iscroll5制作上下拉刷新 tab出現的問題

1.iscoll5插件刷新后如果想改變現實位置如果向下幾px可以用 myScroll.scrollBy(0,0);方法,該值是相對當前位置。 2.iscoll5用到tab的時候,用點擊生成iscoll對象出現取消不了之前的對象的綁定事件,點擊多次后刷新執行多次的問題,解…

初談邏輯讀、物理讀、預讀

前言: 該文并不全是本人原創,里面的某些原理來自于CareySon。 SQL SERVER數據存儲的形式 要理解邏輯讀、物理讀、預讀這三個概念,先要搞懂SQL Server的數據存儲方式。 SQL Server數據庫包括數據文件和日志文件,一個數據庫可以有一…

Makefile常用萬能模板(包括靜態鏈接庫、動態鏈接庫、可執行文件)

1、生成可執行文件的makefile2、生成靜態鏈接庫的makefile3、生成動態鏈接庫的makefile 本文把makefile 分成了三份:生成可執行文件的makefile,生成靜態鏈接庫的makefile,生成動態鏈接庫的makefile。 這些makefile都很簡單,一般都…

TSQLDBServerHttpApi使用工作線程池

TSQLDBServerHttpApi使用工作線程池 TSQLDBServerHttpApi創建時,默認是使用單線程模式,且只使用一個數據庫連接,服務端要應對眾多的客戶端只靠一個工作線程(主線程)和一個數據庫連接, 服務端主線程不忙死才…

hibernate

Hibernate是一個開放源代碼的對象關系映射框架,他對JDBC進行了輕量級的封裝,使Java開發員可以隨心所欲的使用對象編程思維操作數據庫。 SessionFactory接口負責初始化Hibernate.他充當數據儲存源的代理,并負責創建Session對象。 Session&…

Python數據分析之pandas入門

一、pandas庫簡介 pandas是一個專門用于數據分析的開源Python庫,目前很多使用Python分析數據的專業人員都將pandas作為基礎工具來使用。pandas是以Numpy作為基礎來設計開發的,Numpy是大量Python數據科學計算庫的基礎,pandas以此為基礎&#x…

激光雷達和毫米波雷達的區別

什么是激光雷達 激光雷達,是以發射激光束探測目標的位置、速度等特征量的雷達系統。其工作原理是向目標發射探測信號(激光束),然后將接收到的從目標反射回來的信號(目標回波)與發射信號進行比較&#xff0c…

Git—使用方法

1、:插件的安裝(eclipse LUNA版本之后已經自動集成,不需要安裝插件)、 * 先打開該網頁提供了對應版本的EGit,自己選擇相應的版本。(http://wiki.eclipse.org/EGit/FAQ#Where_can_I_find_older_releases_of_EGit.3F&…

激光雷達與毫米波雷達對比

激光雷達是一種采用非接觸激光測距技術的掃描式傳感器,其工作原理與一般的雷達系統類似,通過發射激光光束來探測目標,并通過搜集反射回來的光束來形成點云和獲取數據,這些數據經光電處理后可生成為精確的三維立體圖像。采用這項技…

安全可靠國產系統下的應用怎么搭建?

據國家信息安全漏洞共享平臺(CNVD)統計數據,2016年我國共收錄通用軟硬件漏洞 10822個,漏洞來源涵蓋了眾多知名的國外廠商。應用軟件的不安全性對我國信息技術發展產生了重大威脅,近年來我國頻繁發布信息安全相關政策&a…

Win10 + Python + MXNet + VS2015配置

項目需要使用MTCNN來檢測、對齊、剪切出人臉,它是使用MXNet作為框架的,但是我自己的Ubuntu里各種框架亂成一團,不想再添亂就鐵了心要在windows里配一個。無奈網上的資料不多,掙扎了幾天之后決定留下這么一份文檔。 首先我們使用的…

bzoj 3224 Tyvj 1728 普通平衡樹

題目大意: 您需要寫一種數據結構(可參考題目標題),來維護一些數,其中需要提供以下操作: 1. 插入x數 2. 刪除x數(若有多個相同的數,因只刪除一個) 3. 查詢x數的排名(若有多個相同的數&#xff0c…

不懂毫米波雷達?5分鐘讀懂毫米波雷達的那些事兒

2019年是毫米波風生水起的一年,也是毫米波名聲大噪的一年。毫米波應用范圍廣泛,如毫米波雷達、毫米波天線等。而本文,將向大家介紹毫米波雷達,主要內容包括:毫米波雷達原理、毫米波雷達主要特點、毫米波雷達優勢以及毫…

飛鴿傳書(IPMSG)協議(翻譯稿)

協議聲明: 本協議是由日本人Shirouzu Hiroaki (白水 啟章)先生編寫。 wanpengcoder翻譯于Mr.Kanazawa英文文檔,轉載請注明出處。 http://www.cnblogs.com/wanpeng/ 如有翻譯不當之處望提出,以便改進,衷心感…

redis集群的搭建

########環境######### centos 7.2 , gcch 環境ruby 2.0.0 redis 3.2.8 redis-3.3.3gem 公司要求搭建redis集群, 本來覺得挺好搞的,沒想到弄到現在.... 1, 環境準備 gcc , ruby 等環境準備 yum -y install gcc ruby ruby-devel rubygems rpm-build zlib redis-ruby接口安裝, 我…

2017-2018-1 20155227 《信息安全系統設計基礎》第十三周學習總結

2017-2018-1 20155227 《信息安全系統設計基礎》第十三周學習總結 找出全書你認為最重要的一章,深入重新學習一下,要求(期末占10分): 完成這一章所有習題詳細總結本章要點給你的結對學習搭檔講解你的總結并獲取反饋我選…

進程間五種通信方式

進程間通信(IPC,InterProcess Communication)是指在不同進程之間傳播或交換信息。 IPC的方式通常有管道(包括無名管道和命名管道)、消息隊列、信號量、共享存儲、Socket、Streams等。其中 Socket和Streams支持不同主機…