“threadedprocesspoolexecutor”由修改后的“processpoolexecutor”形成,它生成使用“threadpoolexecutor”实例运行给定任务的进程。

threadedprocess的Python项目详细描述


https://img.shields.io/pypi/v/threadedprocess.svghttps://img.shields.io/pypi/l/threadedprocess.svghttps://img.shields.io/pypi/pyversions/threadedprocess.svghttps://travis-ci.org/nilp0inter/threadedprocess.svg?branch=master

threadedprocesspoolexecutor类是使用 进程池,每个进程上有一个内部线程池来执行调用 异步的。

threadedprocesspoolexecutor由修改后的processpoolexecutor组成 使用线程池执行器的进程(最多有max_个进程) 实例(最多有max_个线程)来运行给定的任务。

如果max_processesNone或没有给定,它将默认为 机器上的处理器。

如果max_threadsNone或没有给定,它将默认为 计算机上的处理器,乘以5

示例

fromconcurrent.futuresimportas_completedimportmathfromthreadedprocessimportThreadedProcessPoolExecutorimportrequestsRNGURL="https://www.random.org/integers/?num=1&min=1&max=100000000&col=1&base=10&format=plain&rnd=new"defget_prime():n=int(requests.get(RNGURL).text)ifn%2==0:return(n,False)sqrt_n=int(math.floor(math.sqrt(n)))foriinrange(3,sqrt_n+1,2):ifn%i==0:return(n,False)return(n,True)withThreadedProcessPoolExecutor(max_processes=4,max_threads=16)asexecutor:futures=[]for_inrange(128):futures.append(executor.submit(get_prime))forfutureinas_completed(futures):print('%d is prime: %s'%future.result())

欢迎加入QQ群-->: 979659372 Python中文网_新手群

推荐PyPI第三方库


热门话题
java我想读取一个带分隔符的或csv文件,并将相应的值保存在postgres DB中   java ANT在解压任务期间连接文件   java Log4j在一行中打印嵌套异常   解压缩HTTPInputStream时,java GZIPInputStream过早关闭   java如何在GWTExt的GridPanel中的标题下放置子标题?   java词典快速排序   dll管理JAVA中的非托管代码?   java无法通过我的Springboot Servlet应用程序使用SAAJ从SOAP消息获取附件   用Java更新MySQL表   java Json格式错误,当他已经得到一个数组时请求数组   Spring数据REST中资源所有权对java的限制   java Vaadin布局扩展   java使用jsoup获取元素外部但元素旁边的文本   java使用javax从GMail获取消息的UID。用IMAP发送邮件   Java中数字到单词的转换模块   java如何减少拨号表中的字体大小   java垃圾值>��� 在springmvc中对swaggerui(io.swagger)的描述中,如何删除它?