async 队列性能测试

性能测试，与多进程对比，效率基本一样：

#coding=utf-8
import asyncio
import os
import cv2
import time
async def consumer(cons_index, q):print('consumer {}: starting'.format(cons_index))start=time.time()i=0while True:item = await q.get()# print('consumer {}: get {}'.format(n, item))if item is None:# None is the signal to stop.q.task_done()breakelse:print('get', cons_index, item[0],i,item[1].shape,time.time()-start)i+=1start = time.time()await asyncio.sleep(0.001)q.task_done()print('consumer {}: ending'.format(cons_index))async def producer(q, num_workers):# Add some numbers to the queue to simulate jobspaths=r'D:\data\VOCdevkit2007\VOC2007\JPEGImages/'files =os.listdir(paths)for i,file in enumer

async 队列性能测试相关推荐

python多进程队列性能测试
测试发现1280*720的图像传输,一张平均需要8ms,两张需要15ms, 内容越多,时间越长. # !/usr/bin/env python # -*- coding: utf-8 -*-impor ...
单机100万连接，每秒10万次请求服务端的设计与实现(三) - 变量共享、超线程与高性能队列
简要构架前文提到过一个框架性的服务器端架构思路,但没给出系统结构图,这里画个图吧,直观不少: M M M M M M 完成部分IO IO对象争用 M M M 网络IO 数据包分析线程 I/O队列数 ...
如何做一个在线转码小说的爬虫网站
前言作为一个有6年书龄的程序员,不搞一波爬虫来看小说真是对不起自己. 所以,我就又开始了愉快的搞事情之旅. 不过接下来我要做的是在线转码,也就是说不用保存数据库,这样就不用考虑数据库了,23333. ...
服务器.esp文件,ESP32 Arduino教程：通过软接入点(soft AP)实现HTTP服务器-esp文件
在本ESP32(http://www.dfrobot.com.cn/goods-1359.html)教程中,我们将检查如何设置一个异步HTTP web服务器,该设备作为软访问点运行. 本ESP32教程 ...
python递归合并排序_python 归并排序的递归法与迭代法(利用队列)实现，以及性能测试...
递归排序核心递归排序的核心是分与合分的最终结果就是将原数组中每一个数字分作一个数组, 合就是所有小数组不断排序,合并的过程. 合并的过程是先将两个含有一个数字的数组排序,合并(每次比较两个数 ...
JAVA应用开发MQ实战最佳实践——Series2：消息队列RocketMQ性能测试案例
简介:JAVA应用开发MQ实战最佳实践--Series2:消息队列RocketMQ性能测试案例往期内容 JAVA应用开发MQ实战最佳实践--Series1:RocketMQ综述及代码设计 1. 消息 ...
node.js async流程控制器--queue(队列)
queue流程控制器是一个并行的流程控制器,但是它与parallel的区别在于queue可以控制一次执行几个函数,而parallel只是让所有函数并行执行. 例子如下: var q = async.q ...
消息队列RocketMQ性能测试案例
1. 消息队列RocketMQ性能测试案例 1.1 RocketMQ测试分析客户场景,信息共享交换平台: 1.交换平台需支持每秒万级别数据传输 2.实现跨路段.跨部门.跨行业.跨区域信息即时共享,做 ...
性能测试和优化实录（mybatisplus异步写库@Async引起的对象无法释放问题）
通过调整和优化系统运行参数,观察性能测试结果: 1. 全部使用默认参数 1.1 启动脚本 java -jar server.jar 1.1 jmap -heap数据 # jmap -heap 2605 ...

async 队列性能测试

async 队列性能测试相关推荐

最新文章

热门文章